简单的JAVA版CORBA程序
为了简单的学习了解CORBA组件，这里用简单的java程序作为练习，
作业一： 要求编写实现显示“Hello，World！+班级+中文姓名”字符串。
作业二：编写实现连加、连减和加减混合等数学++/- -运算，并进行测试。
作业一：
（1）：idl接口定义文件，HelloWorld.idl：
因为要输出包含中文字符串，将函数声明为修改为wstring类型，避免乱码或其他字符集错误。
module sample{
interface HelloWorld{
wstring sayHello();
};
};
（2）：编译IDL接口
在刚刚定义的idl接口文件所在路径下，执行命令idlj –fall HelloWorld.idl
可以看到自动生成了一个sample文件夹，主要包括以下六个类，方便起见，我建了工程，拷入到工程里。
（3）：编写并编译以下三个类。
编写并编译服务端程序:HelloWorldServer.java
package szj;
import sample.*;
import org.omg.CosNaming.*;
import org.omg.CosNaming.NamingContextPackage.*;
import org.omg.CORBA.*;
import org.omg.CORBA.portable.*;
import org.omg.PortableServer.*;
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);
}
}
}
编写并编译客户端程序: 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);
}
}
}
编写并编译HelloWorldServant类
为了在客户端得到我想要的输出结果，比如helloworld我的班级加姓名，在HelloWorldServant类下做如下修改
package szj;
import sample.HelloWorldPOA;
class HelloWorldServant extends HelloWorldPOA { // 对象实现类
public String sayHello() {
return "\nHello World!软件工程1602班司志杰\n";
}
}
（4）：运行
启动名字服务器：输入tnameserv -ORBInitialPort 1050命令
可以看到以下截图说明启动成功
启动服务器程序：不要忘了修改端口号
如下图，启动成功
接着启动客户端程序，如下图运行成功。
作业二：
（1）：编写idl接口定义文件，counter.idl：
module CounterApp{
interface Counter{
readonly attribute long value;
void inc();
void dec();
};
};
（2）：编译IDL接口
在刚刚定义的idl接口文件所在路径下，执行命令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;
}
}
4 编写并编译服务端程序: 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);
}
}
}
（4）：运行
同第一个一样，运行之前不要忘了启动名字服务器：输入tnameserv -ORBInitialPort 1050命令，看到如下说明启动成功
接着启动服务器程序，和第一个一样不要忘了传入端口
见下图运行成功
接着启动客户端程序，如下图，测试成功