JAVA的Corba客户端 - 服务端 通信实现

module helloapp {
interface Hello {
string sayHello();
oneway void shutdown();
};
};

package server;


import org.omg.CORBA.ORB;

import helloapp.HelloPOA;

public class HelloImpl extends HelloPOA {

private ORB orb;

public void setOrb(ORB orb) {
this.orb = orb;
}

@Override
public String sayHello() {
return "\nHello World!!\n";
}

@Override
public void shutdown() {
orb.shutdown(false);
}

}

package server;

import helloapp.Hello;
import helloapp.HelloHelper;

import org.omg.CORBA.ORB;
import org.omg.CORBA.ORBPackage.InvalidName;
import org.omg.CosNaming.NameComponent;
import org.omg.CosNaming.NamingContextExt;
import org.omg.CosNaming.NamingContextExtHelper;
import org.omg.CosNaming.NamingContextPackage.CannotProceed;
import org.omg.CosNaming.NamingContextPackage.NotFound;
import org.omg.PortableServer.POA;
import org.omg.PortableServer.POAHelper;
import org.omg.PortableServer.POAManagerPackage.AdapterInactive;
import org.omg.PortableServer.POAPackage.ServantNotActive;
import org.omg.PortableServer.POAPackage.WrongPolicy;

public class Main {
public static void main(String[] args) {
try {
// 创建一个ORB实例
ORB orb = ORB.init(args, null);

// 得到一个RootPOA的引用,并激活POAManager
POA rootpoa = POAHelper.narrow(orb
.resolve_initial_references("RootPOA"));
rootpoa.the_POAManager().activate();

// create servant and register it with ORB
// 创建一个HelloImpl实例(servant),并注册到ORB上
HelloImpl helloImpl = new HelloImpl();
helloImpl.setOrb(orb);

// 在服务中得到对象的引用
org.omg.CORBA.Object ref = rootpoa.servant_to_reference(helloImpl);
Hello href = HelloHelper.narrow(ref);

//得到一个根名称的上下文
org.omg.CORBA.Object objRef = orb.resolve_initial_references("NameService");

// Use NamingContextExt which is part of the Interoperable
// Naming Service (INS) specification.
NamingContextExt ncRef = NamingContextExtHelper.narrow(objRef);

// 在命名上下文中绑定这个对象
String name = "Hello";
NameComponent path[] = ncRef.to_name(name);
ncRef.rebind(path, href);

System.out.println("HelloServer ready and waiting ...");

//启动线程服务，等待客户端的调用
orb.run();
} catch (InvalidName e) {
e.printStackTrace();
} catch (AdapterInactive e) {
e.printStackTrace();
} catch (ServantNotActive e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (WrongPolicy e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (org.omg.CosNaming.NamingContextPackage.InvalidName e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (NotFound e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (CannotProceed e) {
// TODO Auto-generated catch block
e.printStackTrace();
}

System.out.println("HelloServer Exiting ...");
}
}

package client;

import helloapp.Hello;
import helloapp.HelloHelper;

import org.omg.CORBA.ORB;
import org.omg.CosNaming.NamingContextExt;
import org.omg.CosNaming.NamingContextExtHelper;

public class HelloClient {
static Hello helloImpl;

public static void main(String[] args) {
try {
// 创建一个ORB实例
ORB orb = ORB.init(args, null);

// 获取根名称上下文
org.omg.CORBA.Object objRef = orb.resolve_initial_references("NameService");

// Use NamingContextExt instead of NamingContext. This is
// part of the Interoperable naming Service.
NamingContextExt ncRef = NamingContextExtHelper.narrow(objRef);

// 从上下文中获取接口实现对象
String name = "Hello";
helloImpl = HelloHelper.narrow(ncRef.resolve_str(name));
System.out.println(helloImpl.sayHello());
System.out.println("asdfasdfdasf");
} catch (Exception e) {
e.printStackTrace();
}
}
}