一. 题目分析 目的: (1)掌握组件化开发的概念,了解CORBA模型及ORB机制; (2)掌握CORBA组件编程方法。 步骤: 1.配制环境JDK环境。 2.编写编译IDL接口。 3.编写编译服务端程序。 4.编写编译客户端程序。 5.运行测试与调试。 6.完成报告。 注意事项: 要转到class文件所在目录启动相应程序; 名字服务器、服务端和客户端要分别启动一个DOS命令提示符界面。 可采用批处理命令启动相应程序,分别为: (1)启动名字服务器: tnameserv -ORBInitialPort 1050 @pause (2)启动服务器端程序: java HelloWorldServer -ORBInitialPort 1050 @pause (3)启动客户端程序: java HelloWorldClient -ORBInitialPort 1050 @pause 要求编写实现显示“Hello,World!+班级+中文姓名”字符串。 二. 组件实现 题目1.Java版CORBA程序1——HelloWorld
编写IDL接口HelloWorld.idl: 创建文本文档HelloWorld.idl添加代码:
module sample{ interface HelloWorld{ string sayHello(); }; };
2编译IDL接口:X:\corba>idlj –fall HelloWorld.idl 编译结果生成sample包,生成下述文件:
3 编写并编译服务端程序:HelloWorldServer.java 创建文本文档HelloWorldServer.java 添加代码:
import sample.*; import org.omg.CosNaming.*; import org.omg.CosNaming.NamingContextPackage.*; import org.omg.CORBA.*; import org.omg.CORBA.portable.*; import org.omg.PortableServer.*; class HelloWorldServant extends HelloWorldPOA{ //对象实现类 public String sayHello(){ return "\nHello World!\n"; } } public class HelloWorldServer{ //服务程序 public static void main(String args[]){ try{ //初始化ORB ORB orb = ORB.init(args, null); //取根POA的引用 org.omg.CORBA.Object poaobj = orb.resolve_initial_references ("RootPOA"); org.omg.PortableServer.POA rootPOA = org.omg.PortableServer.POAHelper.narrow(poaobj); org.omg.PortableServer.POAManager manager = rootPOA.the_POAManager(); //创建伺服对象 HelloWorldServant objRef = new HelloWorldServant(); HelloWorld obj = objRef._this(orb); //绑定命名服务 NamingContext ncRef = NamingContextHelper.narrow(orb.resolve_initial_references("NameService")); NameComponent nc = new NameComponent("Hello", ""); NameComponent path[] = {nc}; ncRef.rebind(path, obj); //激活POA管理器 manager.activate(); //等待处理客户程序的请求 System.out.println("HelloWorld is running!"); orb.run(); }catch (Exception e) { System.err.println("ERROR: " + e); e.printStackTrace(System.out); } } }命令提示符执行语句:javac HelloWorldServer.java 4 编写并编译客户端程序: HelloWorldClient.java 创建文本文档HelloWorldClient.java 添加代码:
import sample.*; import org.omg.CosNaming.*; import org.omg.CORBA.*; public class HelloWorldClient { public static void main(String args[]) { try{ ORB orb = ORB.init(args, null); org.omg.CORBA.Object objRef = orb.resolve_initial_references("NameService"); NamingContext ncRef = NamingContextHelper.narrow(objRef); NameComponent nc = new NameComponent("Hello",""); NameComponent path[] = {nc}; HelloWorld helloWorld = HelloWorldHelper.narrow(ncRef.resolve(path)); String hello = helloWorld.sayHello(); System.out.println(hello); } catch (Exception e) { System.out.println("ERROR : " + e) ; e.printStackTrace(System.out); } } }命令提示符执行语句:javac HelloWorldClient.java 编译结果生成下述文件: 5 运行 启动名字服务器:X:\corba >tnameserv -ORBInitialPort 1050 启动服务端程序:X:\corba >java HelloWorldServer -ORBInitialPort 1050 输出:HelloWorld is running 启动客户端程序:X:\corba >java HelloWorldClient -ORBInitialPort 1050 输出:Hello World! 软工1702吴岐 题目2.JAVA版CORBA程序2——Counter 1.编写IDL接口counter.idl: 创建文本文档counter.idl添加代码:
module CounterApp{ interface Counter{ readonly attribute long value; void inc(); void dec(); }; };2.编译IDL接口:X:\corba>idlj –fall counter.idl 编译结果生成CounterApp包,生成下述文件 3.编写并编译对象实现代码:CounterImpl.java
import CounterApp.*; public class CounterImpl extends CounterPOA { private int count; public CounterImpl(){ count = 0; } public void inc(){ count++; } public void dec(){ count - -; } public int value(){ return count; } }编写并编译服务端程序: Server.java
import CounterApp.*; import java.io.*; import org.omg.CosNaming.*; import org.omg.CosNaming.NamingContextPackage.*; import org.omg.CORBA.*; import org.omg.CORBA.portable.*; import org.omg.PortableServer.*; public class Server { public static void main(String[] args){ try{ ORB orb = ORB.init(args, null); org.omg.CORBA.Object poaobj = orb.resolve_initial_references ("RootPOA"); org.omg.PortableServer.POA rootPOA = org.omg.PortableServer.POAHelper.narrow(poaobj); org.omg.PortableServer.POAManager manager = rootPOA.the_POAManager(); CounterImpl c_impl = new CounterImpl(); Counter c = c_impl._this(orb); NamingContext ncRef = NamingContextHelper.narrow(orb.resolve_initial_references("NameService")); NameComponent nc = new NameComponent("Count", ""); NameComponent path[] = {nc}; ncRef.rebind(path, c); FileOutputStream file = new FileOutputStream("Counter.ref"); PrintWriter writer = new PrintWriter(file); String ref = orb.object_to_string(c); writer.println(ref); writer.flush(); file.close(); System.out.println("Server started."+" Stop:Ctrl-c"); rootPOA.the_POAManager().activate(); orb.run(); }catch(IOException ex){ System.out.println("File error:"+ex.getMessage()); System.exit(2); }catch(Exception ex){ System.out.println("Exception: "+ex.getMessage()); System.exit(1); } } }编写并编译客户端程序: Client.java
import CounterApp.*; import java.util.*; import java.io.*; import org.omg.CORBA.*; import org.omg.CosNaming.*; public class Client { public static void main(String[] args){ try{ ORB orb = ORB.init(args, null); org.omg.CORBA.Object obj = orb.resolve_initial_references("NameService"); NamingContext ncRef = NamingContextHelper.narrow(obj); NameComponent nc = new NameComponent("Count",""); NameComponent path[] = {nc}; String ref = null; try{ Scanner reader = new Scanner(new File("Counter.ref")); ref = reader.nextLine(); }catch(IOException ex){ System.out.println("File error: "+ex.getMessage()); System.exit(2); } obj = orb.string_to_object(ref); if(obj == null){ System.out.println("Invalid IOR"); System.exit(4); } Counter c = null; try{ c = CounterHelper.narrow(obj); }catch(BAD_PARAM ex){ System.out.println("Narrowing failed"); System.exit(3); } int inp = -1; do{ System.out.print("Counter value: "+c.value()+"\nAction(+/-/e)?"); System.out.flush(); do{ try{ inp = System.in.read(); }catch(IOException ioe){} }while(inp != '+' && inp != '-' && inp != 'e'); if(inp == '+') c.inc(); else if(inp == '-') c.dec(); }while(inp != 'e'); }catch(Exception ex){ System.out.println("Exception: "+ex.getMessage()); System.exit(1); } } }运行如下,输入以下三条语句: javac CounterImpl.java javac Server.java javac Client.java 编译结果生成下述文件: 4.运行 启动名字服务器:X:\corba >tnameserv -ORBInitialPort 1050 启动服务端程序:X:\corba >java Server -ORBInitialPort 1050 输出:Server started. Stop: Ctrl-c 启动客户端程序:X:\corba >java Client -ORBInitialPort 1050 输入+ - 实现连加、连减和加减混合等数学++/- -运算: 三.调试、测试及运行结果 1.程序调试 错误:在第一个实验修改输出内容时发生错误 原因:CORBA处理字符串有:string和wstring两种类型,string类型主要用于处理ASCII类型的字符串,wstring用于处理多字节的字符串,例如:中文。 改正:将string改为wstring 结果: 2.程序测试 结果见上述组件实现步骤中最后一步 四.经验归纳 在运行程序过程中,遇到了很多问题:
环境变量的配置 这一点我是按照百度上的环境配置步骤一步一步走的,其中因为有一个分号没有打上去导致配置不成功,来来回回好几次。CORBA处理字符串string和wstring的区别 刚开始没仔细看老师发的题目文件,其中就有说明:string类型主要用于处理ASCII类型的字符串,wstring用于处理多字节的字符串,例如:中文,所以,题目1中需要使用wstring。对CORBA程序运行的步骤的理解(参考书本和百度) (1) Server启动,等待来自Client的请求 Server启动后,它首先生成一个POA(potable object adapter)。然后告诉POA他所能提供的服务,即Servant(Server按照IDL定义所实现的每个对象)。Server从POA处得到每个Servant的引用OR(Object Reference,类似于句柄)。 Server把自己提供的服务公布出来,这里有两个办法:○1将OR转换为一个字符串并输出;○2将这个OR绑定到一个简单易理解的名字上,这通过Naming Service完成。 (2) Client调用你定义的对象方法、 Client通过象Naming Service查询获得要访问的对象的引用OR(object reference),或通过一个IOR字符串获得;Client通过这个引用调用对象的方法,因为OR中有足够的信息来定位一个对象;这个调用被传递给ORB。 (3) 调用的完成 Client端的调用请求通过ORB被传递给正确的Server端的ORB,定位是根据OR实现的;这个ORB把调用请求交给真正的Server进行处理;Server又根据OR定位产生这个OR的POA,并把请求传给它;POA又把请求传给最后真正的Servant,完成调用并返回。