使用J2SE1.4开发CORBA程序(五)

类别:Java 点击:0 评论:0 推荐:

最后是实现客户端。如代码7所示。客户端完成以下任务:

n         创建和初始化ORB。

n         使用通用名称服务corbaname的URL解析AddServant。使用该URL查找在本机上运行的名称服务,然后运行在端口2900上并监听请求。找到名称服务后,它就会从名称服务中找到对象AddServer。

n         调用对象的addArrays方法并输出结果。本例中客户端每6秒调用一次addArrays方法。如果在客户端下次调用请求前该服务器被停止了,那么由于永久生命期策略客户端将会自动重启该服务器。

代码示例7:AddClient3.java

import ArithApp.*;

import org.omg.CORBA.ORB;

import org.omg.CORBA.OBJ_ADAPTER;

import org.omg.CosNaming.NamingContext;

import org.omg.CosNaming.NamingContextHelper;

import org.omg.CosNaming.NameComponent;

import org.omg.PortableServer.POA;

 

public class AddClient3 {

 

  public static void main(String args[]) {

    try{

      // create and initialize the ORB

      ORB orb = ORB.init(args, null);

 

      org.omg.CORBA.Object obj = orb.string_to_object(

        "corbaname::localhost:2900#AddServer");

 

      Add impl = AddHelper.narrow(obj);

 

      // the arrays to be added

      int a[] = {6, 6, 6, 6, 6, 6, 6, 6, 6, 6};

      int b[] = {7, 7, 7, 7, 7, 7, 7, 7, 7, 7};

       

      // the result will be saved in this new array

      ArithApp.AddPackage.arrayHolder c =

        new ArithApp.AddPackage.arrayHolder();

 

      while(true) {

        System.out.println("Calling

          the persistent AddServer3..");

        impl.addArrays(a, b, c);

        // print the new array

        System.out.println("The sum of the two arrays is: ");

        for(int i=0;i<ArithApp.Add.SIZE;i++) {

          System.out.println(c.value[i]);

        }

 

        System.out.println("...will

          call the server again in a few seconds....");

        System.out.println("...if the

          server is down, it will be automatically restarted...");

        Thread.sleep(6000);

      }

    } catch ( Exception e ) {

       System.err.println( "Exception in AddClient3..." + e );

       e.printStackTrace( );

    }

  }

}

现在可以编译AddServant、AddServer3、AddClient3类,还有那些由idlj编译器生成的框架文件。可以使用javac编译器进行编译:

prompt> javac *.java ArithApp/*.java

运行该程序需以下步骤:

1.启动orbd名称服务:

prompt> orbd -ORBInitialPort 2900

上面命令就说明你想要orbd服务运行在2900端口上。需要由命令行参数-ORBInitialPort指定。

2.启动AddServer3服务端。

要在ORBD中注册永久服务,需要使用命令servertool启动该服务器,servertool是个命令行程序,供开发者注册、取消、启动和关闭永久服务。

可以用如下命令启动servertool(注意一定要在orbd服务使用的端口号上启动才可正确运行它):

prompt> servertool -ORBInitialPort 2900

你可以看见servertool的命令行界面如下:

servertool>

本例中我们使orbd和servertool运行在同一台主机上。如果你想要在另一台主机上运行servertool,那么你需要使用命令行参数-ORBInitialHost指明运行orbd服务的主机。

现在可以使用register命令注册AddServer3服务。你需要指定服务名称、程序名称和该实现代码存放的路径。如图所示:

正如你所看见的,servertool注册了该服务,而且为它分配了一个唯一的ID号(本例中是257),该ID号可以用于今后的内部服务管理。如果你注册了一个已存在的服务,那么ID号将返回0。

敲入help命令就可以看见servertool中所有命令的列表。如图所示。

3.启动AddClient3客户端:

prompt> java AddClient3 -ORBInitialPort 2900

你可以看见客户端输出了两数组的相加和。

为了要展示永久服务器的特性,我们现在关闭该服务。如图所示。

首先我们列出当前所有的已注册服务,找到我们编写的服务的ID号,然后使用shutdown命令关闭它。

 

即使该服务已经被关闭了,但你仍可以观察到客户端控制台每6秒就输出数组相加结果。这是因为该服务是个永久服务,所以即使服务器被停止了仍会在客户请求时自动重启该服务。当然这些对客户端来说都是透明的。

我们还可以使用listactive命令列出当前的活动服务清单:

orbd保存了服务器和有关于它们状态的所有信息。当你运行orbd服务时,它就会在它的启动目录下创建一个子目录。子目录的名称默认是orb.db。该子目录包含了已注册服务的信息以及日志文件。如果你看了子目录orb.db/logs下的文件,你就会发现诸如名为257.out和257.err的文件。这些文件记录了服务的启动和关闭时间,还有发生的所有错误信息。在本例中该子目录就在c:\airthmetic下。

小结

上面的例子介绍了如何使用新定义的POA开发CORBA应用程序,以及如何开发暂时和永久服务端。

如果你有现成的使用BOA编写的CORBA程序,那么你就需要将它重写成使用POA的,然后你的程序就可以在由不同开发商提供的ORB间使用了。

参考文献

CORBA Programming with J2SE 1.4,Qusay H. Mahmoud,May 2002,developers.sun.com

本文地址:http://com.8s8s.com/it/it16514.htm