java ice 连接服务器_ICE实现服务器客户端

java ice 连接服务器_ICE实现服务器客户端本文将结合实际项目,做一个基于ice的实际项目实例应用,该实例完成客户端调用服务端接口完成消息发送,计算的功能。1,创建java项目ICEServer,导入ice.jar.2,在项目下创建slice文件夹,编写model.ice,service.ice,service2.ice文件,其内容如下model.ice#ifndef_MODEL#define_MODELmodulecom{modul…

大家好,又见面了,我是你们的朋友全栈君。

本文将结合实际项目,做一个基于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 IntegerArray;

/**自定义Map类型**/

dictionary 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

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

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实现数学计算:

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实现发送消息

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实现服务器端接口注册:

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”, “default -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

#

# The IceGrid locator proxy.

#

Ice.Default.Locator=IceTestServiceGrid/Locator:tcp -p 10000

#

# IceGrid registry configuration.

#

IceGrid.Registry.Client.Endpoints=tcp -p 10000

IceGrid.Registry.Server.Endpoints=tcp

IceGrid.Registry.Internal.Endpoints=tcp

IceGrid.Registry.Data=db/rescenter_registry

IceGrid.Registry.PermissionsVerifier=IceTestServiceGrid/NullPermissionsVerifier

IceGrid.Registry.AdminPermissionsVerifier=IceTestServiceGrid/NullPermissionsVerifier

IceGrid.Registry.SSLPermissionsVerifier=IceTestServiceGrid/NullSSLPermissionsVerifier

IceGrid.Registry.AdminSSLPermissionsVerifier=IceTestServiceGrid/NullSSLPermissionsVerifier

#

# Dummy username and password for icegridadmin.

#

IceGridAdmin.Username=foo

IceGridAdmin.Password=bar

#set server active Connection Managerment

Ice.ACM.Server=60

#

# IceGrid node configuration.

#

IceGrid.Node.Name=node1

IceGrid.Node.Endpoints=tcp

IceGrid.Node.Data=db/node1

IceGrid.Node.CollocateRegistry=1

IceGrid.Node.Trace.Activator=1

IceGrid.Node.Trace.Adapter=2

IceGrid.Node.Trace.Server=3

根据需要在当前目录下创建db/node1,db/rescenter_registry文件夹

创建application.xml文件

-classpath

E:\workspace\ICEServer\bin

-Djava.ext.dirs=E:\workspace\ICEServer\lib

-server

com.alan.ice.IceService

创建start_server.bat

path=%path%;E:\Ice-3.3.0\bin

icegridnode –Ice.Config=config-ice.grid –deploy application.xml

pause

创建完成后就可以双击start_server.bat来启动服务了

6,创建客户端调用项目ICEClient,导入ice.jar以及前面生产的icetest.jar,在项目下创建IceClient .java

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” ,”localhost”, “10000”);

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 map = new HashMap();

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]

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/131430.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • cshtml 界面的传值(传到不同的界面)

    cshtml 界面的传值(传到不同的界面)在MVC模式中新建了一个文件夹Test   提交表单写在Index.cshtml 文件夹里面。代码如下:     用户名:    密码:    提交     其中action=”Message” 负责跳转到同级目录的文件。然后就是控制器的代码:因为我要跳转的界面是 Message.cshtml ,所以在控制

  • 十种排序算法总结

    十种排序算法总结

  • docker nginx挂载目录_挂载成功之后如何安装

    docker nginx挂载目录_挂载成功之后如何安装创建目录一般将nginx目录挂载到宿主机方便操作,创建nginx目录:mkdir/home/dockernginxmkdir/home/dockernginx/{conf,html,logs}创建nginx配置文件如下:vim/home/dockernginx/conf/nginx.confnginx默认配置如下:usernginx;worker_processesauto;error_log/var/log/nginx/error.lognotice;pi

  • navicat连接sqlserver 08001错误

    navicat连接sqlserver 08001错误1、sqlsever配置工具中将sqlserver服务启动2、sqlserver网络配置,3个都启动,然后tcpip右键属性,IP地址中将ipall的TCP动态端口删除,TCP端口填写14333、sqlserver网络配置,3个都启动,然后tcpip右键属性,IP地址中将ip2(ip地址)、ip4(127.0.0.1)的已启用选为“是”4、重启sqlserver服务5、防火墙上14…

  • pycharm激活码2021年最新破解方法

    pycharm激活码2021年最新破解方法,https://javaforall.cn/100143.html。详细ieda激活码不妨到全栈程序员必看教程网一起来了解一下吧!

  • objective c源码_以下C代码有哪些错误

    objective c源码_以下C代码有哪些错误我是前言看开源代码时,总会看到一些大神级别的代码,给人眼前一亮的感觉,多数都是被淡忘的C语言语法,总结下objc写码中遇到的各类非主流代码技巧和一些妙用:[娱乐向]objc最短的方法声明[C]结构体的初始化[C]三元条件表达式的两元使用[C]数组的下标初始化[objc]可变参数类型的block[objc]readonly属性支持扩展的写法[C]小括号内联复合表达式[娱乐向]奇葩的C

    2022年10月18日

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号