`

ICE入门(1)

    博客分类:
  • ICE
阅读更多

关键字: 技术

<!-- @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>
  1. module demo{  
  2.     interface Printer{  
  3.         void printString(string s);  
  4.     };  
  5. };  
 

 

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>
  1. public class Server {  
  2.   
  3. public static void  
  4.   
  5. main(String[] args)  
  6.   
  7. {  
  8.   
  9. int status = 0;  
  10.   
  11. Ice.Communicator ic = null;  
  12.   
  13. try {  
  14.   
  15. ic = Ice.Util.initialize(args);  
  16.   
  17. Ice.ObjectAdapter adapter  
  18.   
  19. = ic.createObjectAdapterWithEndpoints(  
  20.   
  21. "SimplePrinterAdapter""default -p 10000");  
  22.   
  23. Ice.Object object = new PrinterI();  
  24.   
  25. adapter.add(  
  26.   
  27. object,  
  28.   
  29. ic.stringToIdentity("SimplePrinter"));  
  30.   
  31. adapter.activate();  
  32.   
  33. ic.waitForShutdown();  
  34.   
  35. catch (Ice.LocalException e) {  
  36.   
  37. e.printStackTrace();  
  38.   
  39. status = 1;  
  40.   
  41. catch (Exception e) {  
  42.   
  43. System.err.println(e.getMessage());  
  44.   
  45. status = 1;  
  46.   
  47. }  
  48.   
  49. if (ic != null) {  
  50.   
  51. // Clean up  
  52.   
  53. //  
  54.   
  55. try {  
  56.   
  57. ic.destroy();  
  58.   
  59. catch (Exception e) {  
  60.   
  61. System.err.println(e.getMessage());  
  62.   
  63. status = 1;  
  64.   
  65. }  
  66.   
  67. }  
  68.   
  69. System.exit(status);  
  70.   
  71. }  
  72.   
  73. }   
 

 

注意这个代码的结构。

 

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>
  1.  ic = Ice.Util.initialize(args);  
  2.   
  3. Ice.ObjectAdapter adapter = ic.createObjectAdapterWithEndpoints( "SimplePrinterAdapter""default -p 10000");  
  4.   
  5. Ice.Object object = new PrinterI();  
  6.   
  7. adapter.add( object, ic.stringToIdentity("SimplePrinter"));  
  8.   
  9. adapter.activate();  
  10.   
  11. 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>
  1. public class Client {  
  2.   
  3. public static void  
  4.   
  5. main(String[] args)  
  6.   
  7. {  
  8.   
  9. int status = 0;  
  10.   
  11. Ice.Communicator ic = null;  
  12.   
  13. try {  
  14.   
  15. ic = Ice.Util.initialize(args);  
  16.   
  17. Ice.ObjectPrx base = ic.stringToProxy(  
  18.   
  19. "SimplePrinter:default -p 10000");  
  20.   
  21. Demo.PrinterPrx printer  
  22.   
  23. = Demo.PrinterPrxHelper.checkedCast(base);  
  24.   
  25. if (printer == null)  
  26.   
  27. throw new</
    分享到:
    评论

相关推荐

Global site tag (gtag.js) - Google Analytics