ICE入门(1)

xiaoxiao2026-03-14  12

关键字: 技术

<!-- @page { margin: 2cm } P { margin-bottom: 0.21cm } -->

ICE 文档翻译(部分,基于3.3.1 )

Printer.ice

内容

Java代码 <embed type="application/x-shockwave-flash" width="14" height="15" src="http://you-meng.iteye.com/javascripts/syntaxhighlighter/clipboard_new.swf" pluginspage="http://www.macromedia.com/go/getflashplayer" allowscriptaccess="always" quality="high" flashvars="clipboard=module%20demo%7B%0A%20%20%20%20interface%20Printer%7B%0A%20%20%20%20%20%20%20%20void%20printString(string%20s)%3B%0A%20%20%20%20%7D%3B%0A%7D%3B"></embed> module demo{      interface Printer{          void printString(string s);      };  };    

 

3.4. 书写一个简单的java 应用程序

 

这个模块向我们展示了我们将如何基于java 实现一个简单的ICE 应用

 

1. 编译基于java 的slice 声明

第一步是创建一个基于java 应用的简单的slice 声明,在linux 下面你可以使用面的方法来实现:

$ mkdir generated

$ slice2java --output-dir generated Printer. ice

其中 –output-dir 选项的意义是指定你用slice2java 命令生成的代码的路径,上文的意义是将代码生成在当前目录的generated 下面。如果不出意外的话你会发现slice2java 命令执行完后为你生成了一些javasource 文件,我们不必关心其中的细节,但是我们必须知道他为我们生成了我们在Printer.ice 中定义的Printer 接口(_PrinterDisp ),接下来的实现,将会继承这个类。

 

2. 书写服务器端的代码:

slice 声明好我们服务端的类以后,我们必须得创建一个属于自己的class ,供服务器端调用,下面的是死规定:这个类的类名必须使用我们的定义的接口名+I 的后缀(即PrinterI )而且必须继承_PrinterDisp 类。_PrinterDisp 是抽象类,他里面有个方法,正是你在Printer.ice中定义的那个方法名,你要在这个方法里添加你想要实现的代码。这里我们实现的很简单,仅仅是让他打印从客户端接收到的字符串而已。

完整的服务前端代码如下:

Java代码 <embed type="application/x-shockwave-flash" width="14" height="15" src="http://you-meng.iteye.com/javascripts/syntaxhighlighter/clipboard_new.swf" pluginspage="http://www.macromedia.com/go/getflashplayer" allowscriptaccess="always" quality="high" flashvars="clipboard=public%20class%20Server%20%7B%0A%0Apublic%20static%20void%0A%0Amain(String%5B%5D%20args)%0A%0A%7B%0A%0Aint%20status%20%3D%200%3B%0A%0AIce.Communicator%20ic%20%3D%20null%3B%0A%0Atry%20%7B%0A%0Aic%20%3D%20Ice.Util.initialize(args)%3B%0A%0AIce.ObjectAdapter%20adapter%0A%0A%3D%20ic.createObjectAdapterWithEndpoints(%0A%0A%22SimplePrinterAdapter%22%2C%20%22default%20-p%2010000%22)%3B%0A%0AIce.Object%20object%20%3D%20new%20PrinterI()%3B%0A%0Aadapter.add(%0A%0Aobject%2C%0A%0Aic.stringToIdentity(%22SimplePrinter%22))%3B%0A%0Aadapter.activate()%3B%0A%0Aic.waitForShutdown()%3B%0A%0A%7D%20catch%20(Ice.LocalException%20e)%20%7B%0A%0Ae.printStackTrace()%3B%0A%0Astatus%20%3D%201%3B%0A%0A%7D%20catch%20(Exception%20e)%20%7B%0A%0ASystem.err.println(e.getMessage())%3B%0A%0Astatus%20%3D%201%3B%0A%0A%7D%0A%0Aif%20(ic%20!%3D%20null)%20%7B%0A%0A%2F%2F%20Clean%20up%0A%0A%2F%2F%0A%0Atry%20%7B%0A%0Aic.destroy()%3B%0A%0A%7D%20catch%20(Exception%20e)%20%7B%0A%0ASystem.err.println(e.getMessage())%3B%0A%0Astatus%20%3D%201%3B%0A%0A%7D%0A%0A%7D%0A%0ASystem.exit(status)%3B%0A%0A%7D%0A%0A%7D%20"></embed> public class Server {    public static void    main(String[] args)    {    int status = 0;    Ice.Communicator ic = null;    try {    ic = Ice.Util.initialize(args);    Ice.ObjectAdapter adapter    = ic.createObjectAdapterWithEndpoints(    "SimplePrinterAdapter""default -p 10000");    Ice.Object object = new PrinterI();    adapter.add(    object,    ic.stringToIdentity("SimplePrinter"));    adapter.activate();    ic.waitForShutdown();    catch (Ice.LocalException e) {    e.printStackTrace();    status = 1;    catch (Exception e) {    System.err.println(e.getMessage());    status = 1;    }    if (ic != null) {    // Clean up    //    try {    ic.destroy();    catch (Exception e) {    System.err.println(e.getMessage());    status = 1;    }    }    System.exit(status);    }    }     

 

注意这个代码的结构。

 

main 方法中包含了2 个try 模块,我们在其中实现了自己的全部的服务器端的代码,其中第一个我们catch 住了ICE 可能抛出的运行时异常,我们的目的是如果ICE 遇到了某种运行时异常,我们就把完整的堆栈打印出来并且返回main 方法,这时虚拟机就会被告知发生了异常并且会退出程序。第二个异常是完全无法预料的,如果发生了我们同样也会告知程序退出。

当程序退出之前,我们先要销毁communicator 对象(当然前提是我们已经正确创建了这个对象),这样做可以正确的终止ICE 运行时,否则后果自负。

 

第一个try 模块包含的如下代码:

 

Java代码 <embed type="application/x-shockwave-flash" width="14" height="15" src="http://you-meng.iteye.com/javascripts/syntaxhighlighter/clipboard_new.swf" pluginspage="http://www.macromedia.com/go/getflashplayer" allowscriptaccess="always" quality="high" flashvars="clipboard=%20ic%20%3D%20Ice.Util.initialize(args)%3B%0A%0AIce.ObjectAdapter%20adapter%20%3D%20ic.createObjectAdapterWithEndpoints(%20%22SimplePrinterAdapter%22%2C%20%22default%20-p%2010000%22)%3B%0A%0AIce.Object%20object%20%3D%20new%20PrinterI()%3B%0A%0Aadapter.add(%20object%2C%20ic.stringToIdentity(%22SimplePrinter%22))%3B%0A%0Aadapter.activate()%3B%0A%0Aic.waitForShutdown()%3B%20"></embed>  ic = Ice.Util.initialize(args);    Ice.ObjectAdapter adapter = ic.createObjectAdapterWithEndpoints( "SimplePrinterAdapter""default -p 10000");    Ice.Object object = new PrinterI();    adapter.add( object, ic.stringToIdentity("SimplePrinter"));    adapter.activate();    ic.waitForShutdown();     

这段代码经历了以下步骤:

*. 通过执行Ice.Util.initialize 方法我们初始化了ICE 服务(我们传递了args 参数,以防服务初始化时需要什么参数。),成功以后将会返回ICE 运行时的主句柄Ice::Communicator 对象。

*. 我们通过调用在Communicator 之上的createObjectAdapterWithEndpoints 方法,创建了一个对象adapter ,命名为“SimplePrinterAdapter”,和adapter 对象的默认监听端口“default -p 10000” ,端口为10000, 一目了然。

*. 接下来就是服务端运行时的初始化并且我们通过实力化PrinterI 对象实现了Printer 的接口。

 

*. 我们通过执行add 方法来通知这个adapter ,ICE 添加了新的服务,被添加的参数一定是要经过初始化的才可以,这个服务的名字叫做“SimplePrinter” (如果有多个printers ,每一个都要被命名成新的不同名字,并且还添加新的服务名称。也就相当于你添加了新的服务给ICE )。

 

*. 最后我们的waitForShutdown. 方法就是让ICE 线程挂起,直到你调用关闭运行时的方法,或者通过信号响应(貌似翻译的不对)(到目前位置我们只能手动kill 了。)

 

 

请注意,即使只有上面的哪一点点代码,也已经适用于几乎所有的server 了(几乎所有的服务声明都是这样的),你可以把那段代码放入一个Helper 类,然后你以后开发的时候就再也不用去每次都书写那些代码了。我们可以用如下方法编译:

 

$ mkdir classes

$ javac -d classes -classpath classes:$ICEJ_HOME/lib/Ice.jar -source 1.4 Server.java PrinterI.java generated/Demo/*.java

 

当然我本人比较推荐eclipse 或者其他的可以自动编译的工具。

 

上面的命令将编译我们通过slice 生成的代码, 我们定义了ICEJ_HOME 环境变量作为包含ICE 运行库环境的根目录(例如:如果你把ICE安装在/opt/IceJ 目录下,那么你的$ICEJ_HOME 的意义就是表示目录/opt/IceJ ),另外需要注意的是ICE 所有java 代码都是使用ant 编译的,关于ant 不懂的话可以看看ICE 的Demo 或者或者google 一下。

 

客户端代码如下:

 

客户端的代码看起来有点像服务器端的代码:

Java代码 <embed type="application/x-shockwave-flash" width="14" height="15" src="http://you-meng.iteye.com/javascripts/syntaxhighlighter/clipboard_new.swf" pluginspage="http://www.macromedia.com/go/getflashplayer" allowscriptaccess="always" quality="high" flashvars="clipboard=public%20class%20Client%20%7B%0A%0Apublic%20static%20void%0A%0Amain(String%5B%5D%20args)%0A%0A%7B%0A%0Aint%20status%20%3D%200%3B%0A%0AIce.Communicator%20ic%20%3D%20null%3B%0A%0Atry%20%7B%0A%0Aic%20%3D%20Ice.Util.initialize(args)%3B%0A%0AIce.ObjectPrx%20base%20%3D%20ic.stringToProxy(%0A%0A%22SimplePrinter%3Adefault%20-p%2010000%22)%3B%0A%0ADemo.PrinterPrx%20printer%0A%0A%3D%20Demo.PrinterPrxHelper.checkedCast(base)%3B%0A%0Aif%20(printer%20%3D%3D%20null)%0A%0Athrow%20new%20Error(%22Invalid%20proxy%22)%3B%0A%0A%0Aprinter.printString(%22Hello%20World!%22)%3B%0A%0A%7D%20catch%20(Ice.LocalException%20e)%20%7B%0A%0Ae.printStackTrace()%3B%0A%0Astatus%20%3D%201%3B%0A%0A%7D%20catch%20(Exception%20e)%20%7B%0A%0ASystem.err.println(e.getMessage())%3B%0A%0Astatus%20%3D%201%3B%0A%0A%7D%0A%0Aif%20(ic%20!%3D%20null)%20%7B%0A%0A%2F%2F%20Clean%20up%0A%0A%2F%2F%0A%0Atry%20%7B%0A%0Aic.destroy()%3B%0A%0A%7D%20catch%20(Exception%20e)%20%7B%0A%0ASystem.err.println(e.getMessage())%3B%0A%0Astatus%20%3D%201%3B%0A%0A%7D%0A%0A%7D%0A%0ASystem.exit(status)%3B%0A%0A%7D%0A%0A%7D%20"></embed> public class Client {    public static void    main(String[] args)    {    int status = 0;    Ice.Communicator ic = null;    try {    ic = Ice.Util.initialize(args);    Ice.ObjectPrx base = ic.stringToProxy(    "SimplePrinter:default -p 10000");    Demo.PrinterPrx printer    = Demo.PrinterPrxHelper.checkedCast(base);    if (printer == null)    throw new 相关资源:Ice入门完整实例
转载请注明原文地址: https://www.6miu.com/read-5045869.html

最新回复(0)