本文接上篇博文《ICE通信框架》如果你还没有接触过ice请先阅读我的上篇博文http://blog.csdn.net/liuzhoulong/archive/2011/03/04/6223450.aspx
本文将结合实际项目,做一个基于ice的实际项目实例应用,该实例完成客户端调用服务端接口完成消息发送,计算的功能。
1,创建java项目ICEServer,导入ice.jar.
2,在项目下创建slice文件夹,编写model.ice,service.ice,service2.ice文件,其内容如下
model.ice
#ifndef _MODEL #define _MODEL module com { module alan { module generated { module model { /**定义整型数组**/ sequence<int> IntegerArray; /**自定义Map类型**/ dictionary<string, string> CustomMap; /**消息类型**/ enum MessageType {ERROR,INFO,WARNING}; /**计算操作类型**/ enum CalcType {Adds,Subtract,Multiply,Divide}; /**消息的操作类型**/ enum ActionType {Add,Remove,Stop,Start,Pause}; /** 消息结构 **/ ["java:getset"] struct Message { /**消息类型**/ MessageType type; /**消息类型**/ ActionType action; /**相关id**/ IntegerArray relatedIds; /**扩展属性**/ CustomMap extention; }; }; }; }; }; #endif
service.ice
#ifndef _GENERATED #define _GENERATED #include <model.ice> module com { module alan { module generated { interface MessageServiceIce { /** * 向ice服务发送信息 * @param message 消息内容 * @return true 成功 false 失败 */ string sendMessage(model::Message msg); }; }; }; }; #endif
service2.ice
#ifndef _GENERATED #define _GENERATED #include <model.ice> module com { module alan { module generated { interface CalcServiceIce { /** * 服务端计算方法 * @param d1 计算数1 * @param d2 计算数2 * @param type 计算方式 * @return true 成功 false 失败 */ double calc(double d1, double d2, model::CalcType cal); }; }; }; }; #endif
3.dos环境下执行
cd E:/workspace/ICEService/slice
E:/Ice-3.3.0/bin/slice2java -I. --output-dir=../src *.ice //生产代码
E:/Ice-3.3.0/bin/slice2html -I. --output-dir=doc *.ice//生产doc文档,可以忽略
将生产generated包下代码以jar包方式导出icetest.jar,并在项目中建立lib目录放入其中(把ice.jar也放入lib下,以备后用),可以删除其生产代码,以jar方式调用其代码。
4,编写发布接口实现代码和服务器端代码
CalcServiceIceImpl .java实现数学计算:
package com.alan.generated.servant; import Ice.Current; import com.alan.generated._CalcServiceIceDisp; import com.alan.generated.model.CalcType; /** * @author zcq * @version 创建时间:2015-4-23 下午06:25:17 * 实现数学计算 */ public class CalcServiceIceImpl extends _CalcServiceIceDisp{ public double calc(double num1, double num2, CalcType type, Current arg3) { double re = 0.0d; switch (type) { case Adds: re = num1 + num2; break; case Subtract: re = num1 - num2; break; case Multiply: re = num1 * num2; break; case Divide: re = num1 / num2; break; default: break; } return re; } }
MessageServiceIceImpl .java实现发送消息
package com.alan.generated.servant; import java.util.Arrays; import Ice.Current; import com.alan.generated._MessageServiceIceDisp; import com.alan.generated.model.Message; /** * @author zcq * @version 创建时间:2015-4-23 下午06:51:47 * 发送消息 */ public class MessageServiceIceImpl extends _MessageServiceIceDisp { public String sendMessage(Message msg, Current __current) { String str = msg.getType() +" "+ msg.getAction()+" " + Arrays.toString(msg.getRelatedIds()); return str; } }
IceService .java实现服务器端接口注册:
package com.alan.generated.server; import Ice.Communicator; import Ice.ObjectImpl; import com.alan.generated.servant.CalcServiceIceImpl; import com.alan.generated.servant.MessageServiceIceImpl; /** * @author zcq * @version 创建时间:2015-4-23 下午06:52:27 * 服务器端接口 */ public class IceService { public static void main(String[] args){ int status = 0; Communicator ic = null; try{ ic = Ice.Util.initialize(args); Ice.ObjectAdapter adapter = ic.createObjectAdapterWithEndpoints("testAdapter", "tcp -h *"); ObjectImpl object1 = new MessageServiceIceImpl(); ObjectImpl object2 = new CalcServiceIceImpl(); adapter.add(object1, ic.stringToIdentity("messageService")); adapter.add(object2, ic.stringToIdentity("calcService")); 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) { try { ic.destroy(); } catch (Exception e) { System.err.println(e.getMessage()); status = 1; } } System.exit(status); } }
5,发布接口
在项目下创建deploy文件夹,在其下创建config-ice.grid配置文件
IceGrid.InstanceName=IceTestServiceGrid # 1 # # The IceGrid locator proxy. # Ice.Default.Locator=IceTestServiceGrid/Locator:tcp -h 127.0.0.1 -p 9600 #2 # # IceGrid registry configuration. # IceGrid.Registry.Client.Endpoints=tcp -h 127.0.0.1 -p 9600 #3 IceGrid.Registry.Server.Endpoints=tcp #4 IceGrid.Registry.Internal.Endpoints=tcp #5 IceGrid.Registry.Data=E:\eclipse_workspace\icetest2\db\rescenter_registry #6 IceGrid.Registry.PermissionsVerifier=IceTestServiceGrid/NullPermissionsVerifier #7 IceGrid.Registry.AdminPermissionsVerifier=IceTestServiceGrid/NullPermissionsVerifier #8 IceGrid.Registry.SSLPermissionsVerifier=IceTestServiceGrid/NullSSLPermissionsVerifier #9 IceGrid.Registry.AdminSSLPermissionsVerifier=IceTestServiceGrid/NullSSLPermissionsVerifier #10 # # IceGrid SQLconfiguration if using SQL database. # #Ice.Plugin.DB=IceGridSqlDB:createSqlDB #11 #IceGrid.SQL.DatabaseType=QSQLITE #12 #IceGrid.SQL.DatabaseName=register/Registry.db #13 # # #Ice Error andStandard output Set # #Ice.StdErr=master/stderr.txt #14 #Ice.StdOut= master/stdout.txt #15 # #Trace Registryproperties # Ice.ProgramName=IceMaster #16 IceGrid.Registry.Trace.Node=3 #17 IceGrid.Registry.Trace.Replica=3 #18 # # IceGrid node configuration. # IceGrid.Node.Name=node1 #19 IceGrid.Node.Endpoints=tcp #20 IceGrid.Node.Data=E:\eclipse_workspace\icetest2\db\node1 #21 IceGrid.Node.CollocateRegistry=1 #22 #IceGrid.Node.Output=db #23 #IceGrid.Node.RedirectErrToOut=1 #24 # # Trace properties. # IceGrid.Node.Trace.Activator=1 #25 IceGrid.Node.Trace.Adapter=2 #26 IceGrid.Node.Trace.Server=3 #27 # # Dummy username and password for icegridadmin. # IceGridAdmin.Username=foo #28 IceGridAdmin.Password=bar #29 #set server active Connection Managerment #Ice.ACM.Server=60 #配置项说明: #1 为这个应用实例指定一个唯一的标识 # 2 注册服务的端点信息(主注册服务和所有的从注册服务),节点注册时要用到 # 3 客户端访问注册服务器的端点信息 # 4 服务访问注册服务器的端点信息,通常是default # 5 内部访问端点信息,通常是default,节点用这个端口和注册服务通信 # 6 注册服务的数据目录的路径 # 7 设定防火墙安全代理,从而控制客户端访问注册表时可用的权限 # 8 设定防火墙安全代理,从而控制注册表管理者可用的权限 # 9 设定SSL安全代理,从而设定客户端访问注册表时的SSL安全访问机制 # 10 设定SSL安全代理,从而设定注册表管理者的SSL安全访问机制 # 11 指定Ice对象序列化的机制,如果不设置,默认用Freeze机制 # 12 指定使用数据库的类型 #13 指定使用数据库的名称 #14 指定标准错误输出文件 #15 指定标准输出文件 #16 指定主注册服务的名称 #17 指定主注册服务跟踪节点信息的级别(0~3),默认为0 #18 指定主/从热备注册服务的跟踪级别(0~3),默认为0 # 19 定义节点的名称,必须唯一 # 20 节点被访问的端口信息,注册服务使用这个端点和节点通信,通常设为default # 21 节点的数据目录的路径 # 22 定义节点是否和注册服务并置在一起,设为1时并置,设为0时不并置 # 23 节点标准输出信息重定向蹈的目录路径,会自动生成输出文件 # 24 节点上的服务程序的标准错误重定向到标准输出 # 25 激活器跟踪级别,通常有0,1,2,3级,默认是0 # 26 对象适配器跟踪级别,通常有0,1,2,3级,默认是0 # 27 服务跟踪级别,通常有0,1,2,3级,默认是0 # 28 IceGrid管理器登录该应用的用户名 # 29 IceGrid管理器登录该应用的密码
根据需要在当前目录下创建db/node1,db/rescenter_registry文件夹
创建application.xml文件
<icegrid> <application name="icetest2"> <server-template id="icetest2-server-template"> <parameter name="index" /> <server id="rescenter_${index}" exe="C:/Program Files/Java/jdk1.7.0_15/bin/java" activation="on-demand"> <!---server -Xms128m -Xmx256m -d64 -XX:PermSize=128m--> <option>-classpath</option> <option>E:\eclipse_workspace\icetest2\src</option> <option>-Djava.ext.dirs=E:\eclipse_workspace\icetest2\lib</option> <option>-server</option> <option>com.alan.generated.server.IceService</option> <adapter name="testAdapter" endpoints="tcp" replica-group="ReplicatedTestAdapter" /> <property name="Ice.ThreadPool.Server.SizeMax" value="3000" /> </server> </server-template> <replica-group id="ReplicatedTestAdapter"> <load-balancing type="adaptive" load-sample="1" n-replicas="1" /> <object identity="messageService" type="::com::alan::generated::servant::MessageServiceIceImpl" /> <object identity="calcService" type="::com::alan::generated::servant::CalcServiceIceImpl" /> </replica-group> <node name="node1"> <server-instance template="icetest2-server-template" index="1" /> </node> </application> </icegrid>
创建start_server.bat
path=%path%;D:/Program Files/ZeroC/Ice-3.5.1/bin cd E:\eclipse_workspace\icetest2\deploy icegridnode --Ice.Config=E:\eclipse_workspace\icetest2\deploy\config-ice.grid --deploy application.xml pause
创建完成后就可以双击start_server.bat来启动服务了
icegridnode --Ice.Config=config-ice.grid
6,创建客户端调用项目ICEClient,导入ice.jar以及前面生产的icetest.jar,在项目下创建IceClient .java
package com.alan.generated.client; import java.util.HashMap; import java.util.Map; import Ice.Communicator; import Ice.InitializationData; import Ice.Util; import com.alan.generated.CalcServiceIcePrx; import com.alan.generated.CalcServiceIcePrxHelper; import com.alan.generated.MessageServiceIcePrx; import com.alan.generated.MessageServiceIcePrxHelper; import com.alan.generated.model.ActionType; import com.alan.generated.model.CalcType; import com.alan.generated.model.Message; import com.alan.generated.model.MessageType; /** * @author zcq * @version 创建时间:2015-4-23 下午07:09:44 * 客户端调用项目 */ public class IceClient { public static void main(String[] args){ int status = 0; Communicator ic = null; try{ String str = String.format("%s:%s -h %s -p %s", "IceTestServiceGrid/Locator","tcp" ,"127.0.0.1", "9600"); InitializationData localInitializationData = new InitializationData(); localInitializationData.properties = Util.createProperties(); localInitializationData.properties.setProperty("Ice.Default.Locator", str); ic = Util.initialize(localInitializationData); MessageServiceIcePrx messageclient = MessageServiceIcePrxHelper.checkedCast(ic.stringToProxy("messageService")); CalcServiceIcePrx calcclient = CalcServiceIcePrxHelper.checkedCast(ic.stringToProxy("calcService")); if (messageclient == null || calcclient == null ) throw new Error("Invalid proxy"); Map<String ,String > map = new HashMap<String, String>(); Message msg = new Message(MessageType.INFO, ActionType.Add,new int[]{1},map); System.out.println(messageclient.sendMessage(msg));//调用接口完成消息发送 System.out.println(calcclient.calc(12, 4, CalcType.Adds));//调用接口完成数学计算 } catch (Ice.LocalException e) { e.printStackTrace(); status = 1; } catch (Exception e) { System.err.println(e.getMessage()); status = 1; } if (ic != null) { try { ic.destroy(); } catch (Exception e) { System.err.println(e.getMessage()); status = 1; } } System.exit(status); } }
7,执行IceClient ,控制台输出
INFO Add [1]
16.0
到此调用成功,实例完成。
相关推荐
总的来说,"Ice经典入门和实例"是一套完整的学习资料,涵盖了Ice的基本概念、核心功能、高级特性和实战应用,对于想要掌握这个分布式对象中间件的开发者来说,是非常宝贵的资源。通过深入学习和实践,你将能熟练地...
8. 调试技巧:使用VC6的调试工具,你可以学习如何调试ICE应用程序,定位和修复问题。 通过深入研究这个代码实例,你可以掌握ICE的基本用法,理解其设计原则,以及如何在实际项目中运用这些知识。这将有助于你构建...
4. **配置文件**:Ice应用通常需要配置文件来设置服务器地址、端口、身份验证等参数。这些配置信息会影响客户端和服务端的连接行为。 5. **运行脚本**:可能包含启动服务器和客户端的脚本,用于自动化测试和演示。 ...
- **1.2.7 使用 JavaScript 编写 Ice 应用**:提供了基于JavaScript的Ice应用程序实例。 - **1.2.8 使用 Objective-C 编写 Ice 应用**:展示了使用Objective-C语言实现Ice应用程序的方法。 - **1.2.9 使用 PHP 编写 ...
通过这个简单的ICE应用实例,初学者可以了解ICE的基本工作原理,掌握C++中如何创建客户端和服务端,以及如何进行通信。同时,实践操作将帮助理解ICE配置、代理使用、通信模式等概念,为进一步深入学习和开发奠定基础...
总结来说,"ICE编程实例"提供了关于如何使用ICE进行分布式系统开发的实例,涵盖C++和C#两个版本。这些实例有助于开发者深入理解ICE的用法,如何在实际项目中应用ICE进行跨平台通信,以及如何解决分布式环境中的常见...
在C++编程环境中,ICE为开发者提供了一套强大的工具和库,使得构建分布式应用程序变得更加简单。本示例程序是基于ICE的C++实现,适用于Visual Studio 2008开发环境,非常适合初学者学习和理解ICE框架的基本用法。 ...
描述中的“服务端”是ICE应用的一部分,它暴露了一组接口供客户端调用。在AMD模式下,服务端可以异步处理方法调用,即在接收到请求后不立即返回结果,而是先返回一个回调句柄,然后在准备好结果时通知客户端。这种...
在给定的 "ICE 简单客户端和服务端实例" 中,我们有两个关键组件:consoleClient 和 consoleServer,它们是 ICE 框架下的基础应用示例,用于演示客户端和服务端如何交互。** **VS2005 (Visual Studio 2005) 是 ...
本Demo是关于如何在iOS项目中利用ICE进行网络请求的实例,旨在帮助开发者理解并掌握ICE的集成与使用。下面将详细阐述相关知识点。 1. **ICE简介**: ICE是一种网络连接协议,它主要用于解决P2P(点对点)通信中的...
为了连接到Ice服务,我们需要在Qt应用中创建Ice的代理对象,并注册我们的回调实例。通常在`MyWindow`的构造函数中完成: ```cpp MyWindow::MyWindow(QWidget* parent) : QMainWindow(parent) , m_messageLabel...
平台编译环境:VS2017 ICE版本:3.7.7 ICEbuilder:5.0.9 源码中有两套程序: Server:启动服务器,等待连接 。连接后可双方通信 Client:连接服务器,与服务器通讯。 Slice: 手写几个接口即可。
2. **创建ICE对象**:客户端创建一个UpdateService或InstallService的实例,这实际上是创建了ICE代理对象。 3. **调用服务**:客户端通过代理对象调用服务端的文件传输接口,比如`uploadFile()`或`downloadFile()`。...
- **示例代码**:通过学习官方提供的示例代码,快速掌握ICE的使用方法。 #### 结论 ICE 3.3.1作为一个成熟的分布式编程框架,在多个领域都有广泛应用。通过对该版本的深入了解,可以帮助开发者更好地利用ICE的强大...
ICE客户端实现代码主要涉及到的是Tibco的ICE(Internet Communications Engine)中间件的使用,这是一种高性能、可伸缩的分布式计算框架。ICE提供了一种语言无关、平台无关的方式来构建分布式应用,支持C++、Java、...
#### 五、Ice应用实例:Hello World应用 - 在**Ice**中开发一个简单的Hello World应用涉及以下步骤: - 使用Slice语言定义服务接口; - 生成客户端和服务端的代码; - 实现服务端逻辑; - 客户端调用服务端提供...
对于IDE开发者,ICE提供了Visual Studio、Eclipse、Xcode等的辅助工具,这些工具能帮助开发者更高效地进行ICE应用开发。此外,官方和第三方的帮助手册也是学习ICE的重要资料,特别是针对Java用户的ZeroC Ice权威指南...
这个聊天demo是基于ICE实现的一个实例,它包含了ICE的配置文档和使用指南,帮助开发者了解如何在Visual Studio 2013环境中集成和使用ICE。 1. **ICE中间件**:ICE是由ZeroC公司开发的跨平台通信框架,它提供了多种...