1、编写*.ice 文件
module myHelloWorld{
interface HelloWorld{
void say(string s);
};
};
2、生成存根 ,命令slice2java ice文件
3、开发服务端
导入生成的存根文件
引入ICE安装目录下面相应的jar包:Ice.jar
4、开发服务端代码如下
步骤一:编写Servant类即带有Disp的存根文件也就是说继承_HelloWorldDisp 这个类,这个类是个抽象类定义如下:
public abstract class _HelloWorldDisp extends Ice.ObjectImpl implements HelloWorld{}
servant类是ice所定义的接口,在服务器端的实现类。我们在该类中可以编写服务器端对请求的具体处理。
代码如下:
package myHelloWorld.server;
import Ice.Current;
import myHelloWorld._HelloWorldDisp;
public class HelloWorld_gaojs extends _HelloWorldDisp{
private static final long serialVersionUID = 1L;
public void say(String s, Current __current) {
System.out.println("Hello World!"+" the string s is " + s);
}
}
步骤二:创建远程的服务器类
package myHelloWorld.server;
public class ServerStart {
/**
* @param args
*/
public static void main(String[] args) {
int status = 0;
// Communicator实例,是ice run time的主句柄
Ice.Communicator ic = null;
try {
// 调用Ice.Util.Initialize()初始化Ice run time
System.out.println("初始化ice run time...");
ic = Ice.Util.initialize(args); // args参数可传可不传
// 创建一个对象适配器,传入适配器名字和在10000端口处接收来的请求
System.out.println("创建对象适配器,监听端口10000...");
Ice.ObjectAdapter adapter = ic.createObjectAdapterWithEndpoints(
"SimplePrinterAdapter", "default -p 10000");
// 实例化一个PrinterI对象,为Printer接口创建一个servant
System.out.println("为接口创建servant...");
Ice.Object object = new HelloWorld_gaojs();
// 调用适配器的add,告诉它有一个新的servant,传递的参数是刚才的servant,这里的“gaojs”是Servant的名字
System.out.println("对象适配器加入servant...");
adapter.add(object, Ice.Util.stringToIdentity("gaojs"));
// 调用适配器的activate()方法,激活适配器。被激活后,服务器开始处理来自客户的请求。
System.out.println("激活适配器,服务器等待处理请求...");
adapter.activate();
// 这个方法挂起发出调用的线程,直到服务器实现终止为止。或我们自己发出一个调用关闭。
ic.waitForShutdown();
} catch (Ice.LocalException e) {
e.printStackTrace();
status = 1;
} catch (Exception e) {
e.printStackTrace();
status = 1;
} finally {
if (ic != null) {
ic.destroy();
}
}
System.exit(status);
}
}
5、开发客服端,导入存根文件和jar包,其中存根文件可以比服务端少三个。
import myHelloWorld.HelloWorldPrx;
import myHelloWorld.HelloWorldPrxHelper;
public class Client {
public static void main(String[] args) {
int status = 0;
// Communicator实例
Ice.Communicator ic = null;
try {
// 调用Ice.Util.Initialize()初始化Ice run time
ic = Ice.Util.initialize(args);
// 根据servant的名称以及服务器ip、端口获取远程服务代理
Ice.ObjectPrx base = ic.stringToProxy("gaojs:default -p 10000");
// 将上面的代理向下转换成一个Printer接口的代理
HelloWorldPrx helloWorld = HelloWorldPrxHelper.checkedCast(base);
// 如果转换成功
if (helloWorld == null) {
throw new Error("Invalid proxy");
}
// 调用这个代理,将字符串传给它
helloWorld.say("客户端测试");
} catch (Ice.LocalException e) {
e.printStackTrace();
status = 1;
} catch (Exception e) {
e.printStackTrace();
status = 1;
} finally {
if (ic != null) {
ic.destroy();
}
}
System.exit(status);
}
}
6、运行测试
1)启动服务端
2)启动客户端
相关推荐
zeroIce可跨平台跨语言,搭建分布式集群rpc服务器。演示IceBox
zeroIce是一个跨平台跨语言的通讯框架,利用zeroIce可快速搭建c#的rpc服务器。
c#整合zeroIce ——— 大文件分片下载,文件可支持到2G.
unit.1完成zeroIce和c#整合演示。演示c#环境下的rpc服务器。
Zero Ice中文教程里面详细介绍了Ice的分布式设计,中文版本。
基于ICE方式SIP穿透SymmetricNAT技术研究
Zeroc Ice 3.4.2/3.5.1/3.6.4/3.7.0 总共4个版本的pdf帮助文档打包. Ice(Internet Communications Engine)是ZeroC公司的杰作,继承了CORBA的血统,是新一代的面向对象的分布式系统中间件。
平台编译环境:VS2017 ICE版本:3.7.7 ICEbuilder:5.0.9 源码中有两套程序: Server:启动服务器,等待连接 。连接后可双方通信 Client:连接服务器,与服务器通讯。 Slice: 手写几个接口即可。
ZeroICE通信框架技术介绍,开发介绍,例子介绍
方便没办法翻场的同学下载,收2分不贵。