随笔-109  评论-187  文章-25  trackbacks-0
上篇文章讲述了jacorb 的配置,本章讲叙其应用,随后的几篇文章会重点讲述corba的开发
 

JACORB开发以及corba的请求方式:

   JacORB的应用开发一般分为以下五步:

1.IDL接口定义

2.编译IDL接口定义生成Java

3.实现步骤2中生成的接口

4.写服务器启动类,并注册到ORB

5.写客户端去获取服务对象引用

 

本例子是采用JACORB里面的一个GRID的例子,从这里例子我们能看出CORBA开发的一些基本步骤,犹豫本例子采用的都是JAVA开发的,由于也受到JACORB的框架限制,并不能很好看出跨语言平台以及如何做到分布式的开发,但是本例 2种基本的方式能够展现出来corba两中            调用方式:

   第一种方式:根据server生成的IDL以及IOR文件,交给客户端,客户端根据这IOR文件来定位server,然后根据IDL接口生成自己的调用代码(本例中是JAVA,当然也可以自己用别的语言来实现)

   第二种方式:根据Naming Service 的方式来定位server,有点类似于JNDI的方式,有个Naming Server server端把一些服务注册上去,clientnaming server来找这些服务.

 

以上是2种最基本的方式来实现 CORBA的这2种调用方式,第一种方式虽然麻烦一点,但是也是很有效的。本例子用JAVA实现的serverClient 充分的展示了这2种调用方式

 

 1.IDL接口定义

 

  全部Corba结果是从一个接口开始的,因为Corba与语言无关,所以它依靠一种接口定义语言来表达如何向实现接口的服务发出请求以及得到应答.

 这是Jacorb里面Grid的例子,IDL的详细语法可以去OMG找些相关的资料来看,比较简单

grid.idl

// IDL defintion of a 2-D grid:

 

module demo

{

module grid

{

    interface MyServer

    {

    typedef fixed <5,2> fixedT;

    readonly attribute short height;  // height of the grid

    readonly attribute short width;   // width of the grid

    // set the element [n,m] of the grid, to value:

    void set(in short n, in short m, in fixedT value);

    // return element [n,m] of the grid:

    fixedT get(in short n, in short m);

    exception MyException

    {

        string why;

    };

    short opWithException() raises( MyException );

    };

};

};

我们用这样一个与任何语言无关的IDL文件将来生成一些与语言相关一些文件,这些文件里面定义了 包名,类名,方法名.

2.编译IDL接口定义生成Java

根据下图就可以看出来生成的文件哪些是server的那些client

 

 

3.实现步骤2中生成的接口

package demo.grid;

/**

* A very simple implementation of a 2-D grid

*/

import demo.grid.MyServerPackage.MyException;

public class gridImpl extends MyServerPOA

{

protected short height = 31;

protected short width = 14;

protected java.math.BigDecimal[][] mygrid;

public gridImpl()

{

mygrid = new java.math.BigDecimal[height][width];

for( short h = 0; h < height; h++ )

{

for( short w = 0; w < width; w++ )

{

mygrid[h][w] = new java.math.BigDecimal("0.21");

}

}

}

public java.math.BigDecimal get(short n, short m)

{

if( ( n <= height ) && ( m <= width ) )

return mygrid[n][m];

11

else

return new java.math.BigDecimal("0.01");

}

public short height()

{

return height;

}

public void set(short n, short m, java.math.BigDecimal value)

{

if( ( n <= height ) && ( m <= width ) )

mygrid[n][m] = value;

}

public short width()

{

return width;

}

public short opWithException()

throws demo.grid.MyServerPackage.MyException

{

throw new demo.grid.MyServerPackage.MyException("This is only

a test exception,

}

}

4.写服务器启动类,并注册到ORB

MyServer接口来访问。以下是个类的源代码:

package demo.grid;

import java.io.*;

import org.omg.CosNaming.*;

public class Server

{

////// public static void main( String[] args )

{

org.omg.CORBA.ORB orb = org.omg.CORBA.ORB.init(args, null);

try

{

org.omg.PortableServer.POA poa =

org.omg.PortableServer.POAHelper.narrow(

orb.resolve_initial_references("RootPOA"));

poa.the_POAManager().activate();

org.omg.CORBA.Object o = poa.servant_to_reference(new

gridImpl());

if( args.length == 1 )

{

// write the object reference to args[0]

PrintWriter ps = new PrintWriter(

new FileOutputStream(

new File( args[0] )));

ps.println( orb.object_to_string( o ) );

ps.close();

}

else

{

// register with the naming service

NamingContextExt nc =

NamingContextExtHelper.narrow(

orb.resolve_initial_references("NameService"));

nc.bind( nc.to_name("grid.example"), o);

12

}

}

catch ( Exception e )

{

e.printStackTrace();

}

orb.run();

}

}

5.写客户端去获取服务对象引用

package demo.grid;

import org.omg.CosNaming.*;

public class Client

{

public static void main(String args[])

{

try

{

MyServer grid;

org.omg.CORBA.ORB orb = org.omg.CORBA.ORB.init(args,null);

if(args.length==1 )

{

// args[0] is an IOR-string

grid =

MyServerHelper.narrow(orb.string_to_object(args[0]));

}

else

{

NamingContextExt nc =

NamingContextExtHelper.narrow(

orb.resolve_initial_references("NameService"));

grid = MyServerHelper.narrow(

nc.resolve(nc.to_name("grid.example")));

}

short x = grid.height();

System.out.println("Height = " + x);

short y = grid.width();

System.out.println("Width = " + y);

x -= 1;

y -= 1;

13

System.out.println("Old value at (" + x + "," + y +"): " +

grid.get( x,y));

System.out.println("Setting (" + x + "," + y +") to 470.11");

grid.set( x, y, new java.math.BigDecimal("470.11"));

System.out.println("New value at (" + x + "," + y +"): " +

grid.get( x,y));

try

{

grid.opWithException();

}

catch (jacorb.demo.grid.MyServerPackage.MyException ex)

{

System.out.println("MyException, reason: " + ex.why);

}

}

catch (Exception e)

{

e.printStackTrace();

}

}

}

JACORB的调用方式分为 2种方式

(一)IOR定位调用方式

 首先我们展示的是IOR定位调用方式,需要server把生成的IOR文件交给client

  首先运行server 把生成的ior文件保存到一个文件中:

jaco demo.grid.Server d://test/NS_Ref

打开d://test/NS_Ref可以看到如下内容:

IOR:000000000000001B49444C3A64656D6F2F677269642F4D795365727665723A312E300000000000020000000000000070000102000000000E6C6F6F636B7977616E672D30310012980000001C5374616E64617264496D706C4E616D652F00151F2C4C294C3C011139000000020000000000000008000000004A414300000000010000001C00000000000100010000000105010001000101090000000105010001000000010000002C0000000000000001000000010000001C00000000000100010000000105010001000101090000000105010001

 

 

其实这个内容我们可以用JACORB提供command可以反解析的

Dior –f d://test/NS_Ref

 

------IOR components-----

TypeId  :       IDL:demo/grid/MyServer:1.0

TAG_INTERNET_IOP Profiles:

        Profile Id:     IIOP Version :  1.2

        Host    :       loockywang-01

        Port    :       4760

        Object key (URL):      StandardImplName/%00%15%1F,L)L%3C%01%119

        Object key (hex):    0x53 74 61 6E 64 61 72 64 49 6D 70 6C 4E 61 6D 65 2

F 00 15 1F 2C 4C 29 4C 3C 01 11 39

        -- Found 2 Tagged Components--

        #0: TAG_ORB_TYPE

                Type: 1245790976 (JacORB)

        #1: TAG_CODE_SETS

                ForChar native code set Id: ISO 8859-1

                Char Conversion Code Sets: UTF-8

                ForWChar native code set Id: UTF-16

                WChar Conversion Code Sets: UTF-8

 

Components in MULTIPLE_COMPONENTS profile: 1

        #0: TAG_CODE_SETS

                ForChar native code set Id: ISO 8859-1

                Char Conversion Code Sets: UTF-8

                ForWChar native code set Id: UTF-16

                WChar Conversion Code Sets: UTF-8

 

 

从这段内容里面我们可以看到HOST PORT等信息也就是说client有办法定位到server的位置以及服务了

 IOR的内容 作为参数来运行 client程序

C:\Documents and Settings\jpwang>jaco demo.grid.Client IOR:000000000000001B49444

C3A64656D6F2F677269642F4D795365727665723A312E300000000000020000000000000070000102000000000E6C6F6F636B7977616E672D303100135C0000001B5374616E64617264496D706C4E616D652F00151F2D0C241517473600000000020000000000000008000000004A414300000000010000001C00000000000100010000000105010001000101090000000105010001000000010000002C00000

00000000001000000010000001C00000000000100010000000105010001000101090000000105010001

得到如下运行结果

Height = 31

Width = 14

Old value at (30,13): 0.21

Setting (30,13) to 470.11

New value at (30,13): 470.11

MyException, reason: This is only a test exception, no harm done :-)

done.

 

 

 

 

(二)Naming Service的调用方式

 

1:启动ns

Naming service的调用一定要启动naming server,在这里JACORB提供一个command ns

 

只要配置文件写的都对,只需要启动NS就可以了

 

>ns 回车

 

2:启动server

jaco demo.grid.Server

3:监控你的namingserver 通过命令nmg

或者通过命令lsns 得到如下结果.

C:\Documents and Settings\jpwang>lsns

[ configuration jacorb loaded from file D:\work\nj\JACORB\etc\jacorb.properties

]

   grid.example

 

 

4:运行client

C:\Documents and Settings\jpwang>jaco demo.grid.Client

得到如下结果

Height = 31

Width = 14

Old value at (30,13): 0.21

Setting (30,13) to 470.11

New value at (30,13): 470.11

MyException, reason: This is only a test exception, no harm done :-)

done.

 

posted on 2007-11-22 10:41 小小程序程序员混口饭吃 阅读(7308) 评论(2)  编辑  收藏 所属分类: java

评论:
# re: 用JACORB开发corba应用 2008-03-25 21:22 | hongguoyuan
使用jacorb运行它自带的小例子grid,出现如下错误。敢问楼主知道如何解决否?不胜感谢!!



[ configuration jacorb loaded from file F:\workspace\jaco2\etc\jacorb.properties ]
int orb ok!
[jacorb.orb] INFO :
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
JacORB V 2.2, www.jacorb.org
(C) Gerald Brose, XTRADYNE Technologies/FU Berlin, 7-May-2004
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
[jacorb.orb.intercept] INFO : InterceptorManager started with 0 SIs, 0 CIs and 1 IORIs
[jacorb.poa] INFO : oid:
00 15 2B 2D 40 0A 29 2E 01 41 11 ..+-@.)..A.
object is activated
[jacorb.orb.giop] INFO : ClientConnectionManager: created new conn to target 202.112.157.79:10021
[jacorb.iiop.conn] INFO : Retrying to connect to 202.112.157.79:10021
[jacorb.iiop.conn] INFO : Retrying to connect to 202.112.157.79:10021
[jacorb.iiop.conn] INFO : Retrying to connect to 202.112.157.79:10021
[jacorb.iiop.conn] INFO : Retrying to connect to 202.112.157.79:10021
[jacorb.iiop.conn] INFO : Retrying to connect to 202.112.157.79:10021
org.omg.CORBA.TRANSIENT: Retries exceeded, couldn't reconnect to 202.112.157.79:10021 vmcid: 0x0 minor code: 0 completed: No
at org.jacorb.orb.iiop.ClientIIOPConnection.connect(Unknown Source)
at org.jacorb.orb.giop.GIOPConnection.write(Unknown Source)
at org.jacorb.orb.CDROutputStream.write(Unknown Source)
at org.jacorb.orb.giop.ServiceContextTransportingOutputStream.write_to(Unknown Source)
at org.jacorb.orb.giop.GIOPConnection.sendMessage(Unknown Source)
at org.jacorb.orb.giop.GIOPConnection.sendRequest(Unknown Source)
at org.jacorb.orb.giop.ClientConnection.sendRequest(Unknown Source)
at org.jacorb.orb.giop.ClientConnection.sendRequest(Unknown Source)
at org.jacorb.orb.Delegate.invoke_internal(Unknown Source)
at org.jacorb.orb.Delegate.invoke(Unknown Source)
at org.jacorb.orb.Delegate.is_a(Unknown Source)
at org.omg.CORBA.portable.ObjectImpl._is_a(ObjectImpl.java:112)
at org.omg.CosNaming.NamingContextExtHelper.narrow(NamingContextExtHelper.java:73)
at demo.grid.SimpleServer.main(SimpleServer.java:48)

  回复  更多评论
  
# re: 用JACORB开发corba应用[未登录] 2014-07-30 16:01 | jayden
请问下这个怎么做动态调用,能不能做?如果这样的例子求一个307106941@qq.com  回复  更多评论
  

只有注册用户登录后才能发表评论。


网站导航: