请教：java编写corba,客户端问题

xingyu1040

我刚刚学corba,试着用java编写了一点简单的程序，在编写实现DSI时遇见问题，Server段好像没问题，但运行Client端会报错，不知道是那里边错了，请大家帮忙看看，谢谢！！！

1. 
   
2. Hello.idl:
   
3. module HelloApp
   
4. {
   
5.     interface Hello
   
6.     {
   
7.         string printHelloArgs(in string arg1, in short arg2);
   
8.     };
   
9. };
   
10. 
    

复制代码

1. 
   
2. HelloServer.java
   
3. import HelloApp.*;
   
4. 
   
5. import java.util.*;
   
6. import org.omg.CosNaming.*;
   
7. import org.omg.CosNaming.NamingContextPackage.*;
   
8. import java.io.*;
   
9. import org.omg.CORBA.*;
   
10. 
    
11. // servant 必须扩展 DynamicImplementation
    
12. class HelloImpl extends DynamicImplementation
    
13. {
    
14. 
    
15.     // 存储已实现的接口的存储库标识符
    
16.     static String[] myIDs = {"IDL:JavaIDL/DSIExample:1.0"};
    
17.     ORB orb;
    
18. 
    
19.     // 创建对 ORB 的引用
    
20.     HelloImpl(ORB orb) {
    
21.         this.orb = orb;
    
22.     }
    
23.     // 必须实现 invoke() 以处理请求
    
24.     public void invoke(ServerRequest request) {
    
25.         try {
    
26.             System.out.println("DSI: invoke called, op = "+request.op_name());
    
27. 
    
28.             // 创建 NVList 以保留参数
    
29.             NVList nvlist = orb.create_list(0);
    
30. 
    
31.             // 每个方法名都需要如下 if 语句
    
32.             if (request.op_name().equals("printHelloArgs") == true) {
    
33. 
    
34.                     // 每个参数都需要 Any
    
35.                     Any any1 = orb.create_any();
    
36.                     any1.insert_string("");
    
37.                     nvlist.add_value("arg1", any1, ARG_IN.value);
    
38. 
    
39.                     Any any2 = orb.create_any();
    
40.                     any2.insert_string("");
    
41.                     nvlist.add_value("arg2", any2, ARG_IN.value);
    
42. 
    
43.                     // 将 NVList 传递到请求以获取值
    
44.                     request.params(nvlist);
    
45. 
    
46.                     System.err.println("Argument 1: In value: " + nvlist.item(0).value().extract_string());
    
47. 
    
48.                     System.err.println("Argument 2: In value: " + nvlist.item(1).value().extract_short());
    
49. 
    
50.                     TypeCode result_tc = orb.get_primitive_tc(TCKind.tk_void);
    
51.                     Any result_any = orb.create_any();
    
52.                     result_any.type(result_tc);
    
53. 
    
54.                     request.result(result_any);
    
55.             }
    
56.         }
    
57.         catch (Exception ex) {
    
58.             ex.printStackTrace();
    
59.             System.out.println("DSIExample: Exception thrown: " + ex);
    
60.         }
    
61.     }
    
62. 
    
63. 
    
64. // 实现 an _ids 方法以返回接口的存储库标识符
    
65. public String[] _ids() {
    
66.         return myIDs;
    
67. }
    
68. }
    
69. // 以常规方式实现的 HelloServer
    
70. public class HelloServer {
    
71. 
    
72.     public static void main(String args[])
    
73.     {
    
74.         try{
    
75.             // 创建并初始化 ORB
    
76.             ORB orb = ORB.init(args, null);
    
77. 
    
78.             // 创建 servant 并注册到 ORB
    
79.             HelloImpl helloRef = new HelloImpl(orb);
    
80.             orb.connect(helloRef);
    
81.             File fi = new File("ior");
    
82.             java.io.OutputStream f = new java.io.FileOutputStream(fi);
    
83.             java.io.DataOutputStream out = new java.io.DataOutputStream(f);
    
84.             String ior = orb.object_to_string(helloRef);
    
85.             out.writeBytes(ior);
    
86.             out.close();
    
87. 
    
88.             System.out.println("IOR is "+ ior);
    
89. 
    
90.             // 等待客户机调用
    
91.             orb.run();
    
92. 
    
93.         } catch (Exception e) {
    
94.             System.err.println("ERROR: " + e);
    
95.             e.printStackTrace(System.out);
    
96.         }
    
97.     }
    
98. }
    
99. 
    

复制代码

1. 
   
2. HelloClient.java
   
3. import java.io.*;
   
4. import HelloApp.*;
   
5. import org.omg.CORBA.*;
   
6. import org.omg.CosNaming.*;
   
7. import org.omg.PortableServer.*;
   
8. 
   
9. public class HelloClient{
   
10.         public static void main(String[] args){
    
11.                 try{
    
12.                         ORB orb = ORB.init(args,null);
    
13.                         POA rootpoa = (POA)orb.resolve_initial_references("RootPOA");
    
14.                         rootpoa.the_POAManager().activate();
    
15.                        
    
16.                         FileInputStream fis = new FileInputStream("ior");
    
17.                         java.io.DataInputStream dis = new java.io.DataInputStream(fis);
    
18.                         String ior = dis.readLine();
    
19.                         System.out.println(ior);
    
20.                         org.omg.CORBA.Object obj = orb.string_to_object(ior);
    
21.                         Hello helloRef = HelloHelper.narrow(obj);
    
22.                         System.out.println("+"+obj);
    
23.                         String sin = "string";
    
24.                         short shin = 3;
    
25.                         String str = helloRef.printHelloArgs(sin,shin);
    
26.                         System.out.println(str);
    
27.                         System.out.println("remote call success");
    
28.                     }
    
29.                     catch(Exception e){
    
30.                             e.printStackTrace(System.out);
    
31.                            
    
32.                             }
    
33.                 }
    
34. }
    

复制代码