当前页面: 开发资料首页 → J2EE 专题 → 用CORBA创建Client/Server 程序
用CORBA创建Client/Server 程序
摘要: 用CORBA创建Client/Server 程序
CORBA概要：
在一个通常的用C++或者JAVA写的面向对象的程序里，程序包含所有应用程序需要用到的类。编译器编译和连接这些对象，当你用new语句初始化对象时，它们被创建在应用程序所在的内存里并且被当作一个简单的过程来执行。
CORBA是一种技术允许一个Client程序调用属于一个Server的对象，这个Server可以是运行在同一台机器或者是几千里外的机器。在它的最基本的阶段，CORBA是非常简单的-实例化一个在你的处理内存空间的对象代替你在通常的程序中所做的，你可以实例化这个对象无论在哪一个网络的Server上。调用这个对象的方法以及这些方法需要传递的参数被打包成网络包的格式发送到服务器上。这个功能实际上是运行在服务器上，返回结果通过网络传递到调用者。
这种方案的优点是服务器可以作为高效的、共享的资源中心，以Server为基础的CORBA对象可以访问Server的数据库和其它服务。当然，它的缺点是速度。每秒调用功能的数目被网络速度严格限制，以便保证其它技术通过网络传输数据，因而，CORBA不是独仪无二的。DCOM，甚至Socket都要忍受同样的延迟。
用CORBA方法特别的方面是可以方便的调用ORB（Object Request Broker）， ORB处理和操作Client和Server之间的连接。在下面的例子里我们将要用Inprise VisiBroker ORB。用VisiBroker，Client和Server都用一个叫做OSAGENT的服务，OSAGENT用一个标准的端口（通常是14000）连接Client，OSAGENT可以当作一个目录去帮助Client的ORB去找到一个它要找的对象。
用java设置一个简单的CORBA的Client和Server是非常简单的，在下面我们将要看到几段例子代码段去显示这个过程，在接下来的部分我们将要解释代码怎样工作的，我们从关键字"安装"开始。
用文档中的例子代码,除了VisiBroker ORB之外你需要下载Sun的JDK1.1，你能下载SDK从http://java.sun.com/products/jdk/1.1/index.html。我们用JDK1.1代替1.2是为了避免和java2的ORB冲突。你可以得到VisiBroker ORB从http://www.inprise.com/visibroker/。先装SDK，再装ORB。
例子代码
为了创建一个CORBA Server并且让Client访问它，你要决定Server类将要做什么再开始。在这个例子里我们要用一个非常简单的Server类，这个类拥有一个私有的整型变量，在这个类里的一个方法将要增加这个整型变量，并且另一个方法将要允许Client访问这个变量的正确值，下面是这个类的接口描述：
//Counter.idl
module Counter{
interface Count
void increment();
long getCounter();
这个类被命名为Count，它的两个方法是Increment和getCounter，这个类被包含在一个叫Counter的模板中，只要你愿意这个模板可以包含好几个不同的类，把这IDL代码放在一个叫Counter.idl名字的文件中。
为了用这个IDL文件，你需要IDL2JAVA去运行它，这个工具将要创Client和Server要用到的类，IDL2JAVA产生的Client类叫做Helper并且被命名为CountHelper.java，Client用helper类去调用Server的功能，IDL2JAVA产生的Server类叫做ImplBase并且被命名为_CountImpleBase.java，你将要执行这些Server扩展ImplBase的方法。
注意：当你在Client直接用CounterHelper.java类时，当你调用一个Counter接口的方法时执行在Client的代码是_st_Counter.java。这个类调用stub把数据打包发送到Server并且返回正确的数据，它同Server端的skeleton(是_sk_Counter.java,继承与_CounterImplBase.java)通信。
下一页
客户端代码是非常简单的，下面是你能创建的最小的客户端程序。
// Client.java
public class Client
public static void main(String[] args)
Counter.Count count = null;
org.omg.CORBA.ORB orb = null;
// Initialize the ORB
orb = org.omg.CORBA.ORB.init();
// Bind to the object on the server
count = Counter.CountHelper.bind(orb, "test");
// Call the server functions
count.increment();
System.out.println("Current Count = " + count.getCounter());
// clean up
count = null;
orb.shutdown();
在这段代码里你可以看到Client实例化ORB，绑定helper对象为了连接Server，接着开始调用方法，为了编译这段代码，储存文件名为Client.java并且输入：
vbjc Client.java
另外，为ORB可以加入三个jar文件到你的Class Path中并其用javac编译Client（三个jar文件是：vbjorb.jar,vbjapp.jar和vbjtools.jar）
假如你想让客户端代码发现问题并且告诉你，你要修改Client.java如下：
// Client.java
public class Client
public static void main(String[] args)
Counter.Count count = null;
org.omg.CORBA.ORB orb = null;
// Initialize the ORB
try
orb = org.omg.CORBA.ORB.init();
catch (org.omg.CORBA.SystemException se)
System.err.println("initializtion problem in the ORB " + se);
System.exit(1);
// Bind to the object on the server
try
count = Counter.CountHelper.bind(orb, "test");
catch (org.omg.CORBA.SystemException se)
System.err.println("Binding problem in the ORB " + se);
System.exit(1);
try
count.increment();
System.out.println("Current Count = " + count.getCounter());
catch (org.omg.CORBA.SystemException se)
System.err.println("Increment failure " + se);
System.exit(1);
// clean up
try
count = null;
orb.shutdown();
catch (org.omg.CORBA.SystemException se)
System.err.println("Problem with cleanup " + se);
System.exit(1);
当你初始化ORB并且绑定到Server时你有多个选项：
1．ORB可以从命令行中接受并且分析这些选项。
2．你可以设置绑定选项。
3．你可以直接连到一个指定的机器。
下面的代码段为你展示了这三个选项
orb = org.omg.CORBA.ORB.init(args, null);
org.omg.CORBA.BindOptions bindOptions = new
org.omg.CORBA.BindOptions();
bindOptions.defer_bind = false;
bindOptions.enable_rebind = true;
count = Counter.CountHelper.bind(orb, "test", "marshall.iftech.com",
bindOptions);
这是初始化从命令行中接受参数，绑定接受了一个指定的机器名和选项。
在Server你需要创建两段代码，一段为了Client绑定而且执行Count类（Count类继承与ImplBase类），如下所示：
// CountImpl.java
public class CountImpl extends Counter._CountImplBase
private int c = 0;
public CountImpl(String name) {
super(name);
public CountImpl() {
super();
public void increment() {
c = c + 1;
System.out.println(c);
public int getCounter()
return c;
这个类不能再少了，它的功能只是实现类里的方法，执行这个类的Server代码如下：
// Server.java
public class Server
public static void main(String[] args)
org.omg.CORBA.ORB orb = null;
org.omg.CORBA.BOA boa = null;
Counter.Count count = null;
try
orb = org.omg.CORBA.ORB.init(args, null);
catch (org.omg.CORBA.SystemException se)
System.err.println("Initialization problem in the ORB " + se);
System.exit(1);
try
boa = orb.BOA_init();
catch (org.omg.CORBA.SystemException se)
System.err.println("Initialization problem in the BOA " + se);
System.exit(1);
try
count = new CountImpl("test");
boa.obj_is_ready(count);
System.out.println(count + " ready.");
boa.impl_is_ready();
catch (org.omg.CORBA.SystemException se)
System.err.println("Ready problem " + se);
System.exit(1);
Server代码用Server.java保存，编译这个Serve.java:
? vbjc Server.java
现在可以测试了,输入如下命令：
> osagent
? vbj Server
将要启动Server，输入如下命令：
> osfind
> vbj Client
OSFIND命令将要确认Server在运行，OSFIND列出它能找到的正在运行的Server和提供服务的对象。第二个命令执行Client，你应该看Client和Server在屏幕上打印的计数值的最新值，你可以运行多次客户端程序来增加这个计数值。
Server代码通过初始化ORB开始运行，接着初始化Server的BOA(Basic Object Adapter),BOA的任务是告诉Server 的ORB什么时候Server的类准备好了,接着Server实例化一个Count对象，命名为"test"并且告诉ORB：Count对象和Server都准备好了。Imple_is_ready方法允许Server在被外部程序访问以前可以实例化多个对象以及执行其它的初始化。
你能够运行Server序在另一台机器上，它应以两种工作方式的一种就行工作。假如Client和Server在同一个网段，OSFIND通过广播一个请求可以找到Server，假如不在同一个网段，你可以修改客户段代码直接连到Server上。
可以在java程序中用CORBA，下面的代码显示一个非常简单的调用这个例子Server的Applet：
// ButtonTest.java
import java.awt.*;
import java.applet.*;
public class ButtonTest extends Applet
Button b;
Counter.Count count = null;
org.omg.CORBA.ORB orb = null;
public ButtonTest()
setLayout(new BorderLayout());
b = new Button("Apply");
add("North", b);
// ---------
// Bind to the counter
String args[] = new String[10];
args[0] = "test";
try {
orb = org.omg.CORBA.ORB.init();
catch (org.omg.CORBA.SystemException se) {
System.err.println("ORB init failure " + se);
System.exit(1);
try {
count = Counter.CountHelper.bind(orb, "test");
catch (org.omg.CORBA.SystemException se) {
System.err.println("ORB bind failure " + se);
System.exit(1);
public void paint(Graphics g)
long i = count.getCounter();
g.drawString(" " + i, 50, 50);
public boolean action(Event ev, Object arg)
if (ev.target instanceof Button)
try {
count.increment();
catch (org.omg.CORBA.SystemException se) {
System.err.println("Increment failure " + se);
System.exit(1);
repaint();
return true;
return false;
保存为Button.java并且用下面的命令编译:
> vbjc ButtonTest.java
现在创建一个简单的web page来调用这个Applet，如下：
保存为first.htm文件，用applet viewer运行这个applet:
? appleviewer first.htm
任何一个java程序都可以用这个方法访问CORBA。
Client和Server在处理中都运行了ORB，ORB通过网络帮助Client和Server互相绑定，帮助传递参数和激活相应的方法。
用CORBA，Server必须在Client连接以前运行，当Client尝试绑定到Server时，它的ORB开始同OSAGENT对话， OSAGENT列出Server上所有的提供服务对象的名字，默认通信的端口号为14000,OSAGENT知道Server在运行。当Server开始运行时，ORB随机挑选一个端口，并且告诉OSAGENT，接着OSAGENT告诉Client的Server机器名和ORB的端口号，Client的ORB直接连接到Server的端口上，通过它调用所有的方法。
另外，Client和Server在不同的机器上，但是在同一个网段，则在这个网段里必须有一个OSAGENT在运行，Client和Server通过广播包互相通信。
还有，Client和Server在不同的网段中，Client则直接连到Server，Server必须运行一个OSAGENT，当Client要连到Server时，它首先和OSAGENT对话得到Server的ORB端口号，接着直接连到Server。
总结
从这个例子中，你可以看到基本的CORBA是非常简单的，仅仅两三行代码需要加到Client和Server程序中去激活CORBA，连接好以后，客户和服务器程序用标准的代码进行通信，CORBA的简易姓使它非常容易的创建Client/Server程序。
Java, java, J2SE, j2se, J2EE, j2ee, J2ME, j2me, ejb, ejb3, JBOSS, jboss, spring, hibernate, jdo, struts, webwork, ajax, AJAX, mysql, MySQL, Oracle, Weblogic, Websphere, scjp, scjd, scwcd 作者:dj
↑返回目录
前一篇: 最佳实践：有状态会话 bean运行结束时应及时被显式删除
后一篇: 如何用JDO开发数据库应用