Java ICE简明入门教程之demo环境搭建

一、什么是ICE?

ICE简介

ICE官网：https://zeroc.com/

Internet Communications Engine，或称Ice，是ZeroC开发的一个面向对象的中间件平台，其实就是一个分布式的RPC框架，进行系统间通信。

ICE的主要优点是高性能，跨语言，跨平台，面向对象，开源等等，提供面向对象的远程过程调用、网格计算和发布/订阅功能，并有基于GPL的双许可协议和一个私有许可协议。

ICE推荐书籍：《ZeroC Ice权威指南》

ICE有哪些优势？

多平台支持

Ice通过与编程语言无关的中立语言Slice（Specification Language froIce）来描述服务的接口，从而达到对象接口与其实现想分离的目的。

性能高

在各个RCP框架的性能对比中ice的tps遥遥领先，而且并发越高tps比其他越高，其次thrift，dubbo和grpc则差了很多。Grpc最差估计跟用了HTTP2有关。

二、安装配置

安装

下载地址：

https://zeroc.com/downloads/ice

这里我下载的是3.6版本

配置环境变量

下载安装完成之后要进行环境变量配置。

ICE_HOME = C:\Program Files (x86)\ZeroC\Ice-3.6.5

PATH=%ICE_HOME%\bin

检测是否安装成功：

cmd打开dos窗口: slice2java -v，有版本号说明成功。

三、IDEA下新建ICE文件

pom.xml加入坐标

 <dependencies>
        <dependency>
            <groupId>com.zeroc</groupId>
            <artifactId>ice</artifactId>
            <version>3.6.5</version>
        </dependency>
</dependencies>

新建ice目录和ice文件

1、新建slice文件夹，并标记为源码目录。

然后创建包路径，最后再创建Hello.ice文件

2、安装插件

创建完成后以文件形式打开，会自动提示安装IDEA ice插件

安装插件 Frozen Idea

3、Hello.ice 输入一下内容

[["java:package:com.test.ice.service"]] // 定义java包名  父结构
module demo    //模块包名
{
interface Hello   //接口服务名称
    {
        string sayHello(string s);   //具体的方法
    };
};

四、使用slice2java编译ice文件生成java代码

打开cmd窗口进入Hello.ice目录下执行以下命令：

slice2java .\Hello.ice --output-dir ..\src\main\java

报错：slice2java: error: cannot create directory `..\src\main\java/com': No such file or directory

原因：目标生成的文件路径不对

正确的路径如下：

slice2java .\Hello.ice --output-dir ..\..\..\..\..\java

执行后生成10个文件

五、增加三个类 HelloI Client Server

代码如下：

Hellol.java

package com.test.ice.service.demo;

import Ice.Current;

import java.util.logging.Logger;

public class HelloI extends _HelloDisp {
    private static final long serialVersionUID = -3966457693815687559L;
    private Logger log = Logger.getLogger(this.getClass().getSimpleName());


    public String sayHello(String s, Current __current) {
        log.info("具体的服务接口实现类中的sayHello方法被调用了。。。");
        return "Hello " + s;
    }
}

Client.java

package com.test.ice.service.demo;

import Ice.Communicator;
import Ice.ObjectPrx;
import Ice.Util;

import java.util.logging.Logger;

/**
 * @program: IceDemo
 * @description:
 * @author: Liu Tao
 * @create: 2021-10-06 18:38
 **/
public class Client {
    private static Logger log = Logger.getLogger(Client.class.getSimpleName());

    public static void main(String[] args) {
        log.info("客户端启动...");
        // 通信器
        Communicator ic = null;
        // 初始化这个通信器
        ic = Util.initialize(args);
        // 根据地址生成一个服务代理对象
        // HelloIce -- 服务端那边自己定义的名字
        ObjectPrx proxy = ic.stringToProxy("HelloIce:default -p 1888");
        // 转换成HelloService类型的代理服务
        HelloPrx hello = HelloPrxHelper.checkedCast(proxy);
        //调用方法
        String s = hello.sayHello("World!");
        System.out.println(">>"+s);
    }

}

Server.java

package com.test.ice.service.demo;

import Ice.Communicator;
import Ice.Identity;
import Ice.ObjectAdapter;
import Ice.Util;

import java.util.logging.Logger;


public class Server {
    private static Logger log = Logger.getLogger(Server.class.getSimpleName());

    public static void main(String[] args) {
        // 通信器
        Communicator ic = null;
        // 初始化这个通信器
        ic = Util.initialize(args);
        // 创建ice适配器,将服务调用地址和服务映射起来
        // "HelloServiceAdapter"是适配器名, "default -p 1888"是服务调用的地址
        ObjectAdapter adapter = ic.createObjectAdapterWithEndpoints("HelloServiceAdapter","default -p 1888");
        // 将服务的具体实现类servant交给这个适配器
        Object servant = new HelloI();
        // "HelloIce"--服务接口在ice中注册名,转成唯一标识identity
        Identity id = Util.stringToIdentity("HelloIce");
        adapter.add((Ice.Object) servant, id);
        // 激活这个适配器
        adapter.activate();

        log.info("server服务容器启动成功。。。");
    }
}

六、启动程序

先启动server

报错：内部错误 (java.lang.UnsupportedClassVersionError): org/xblackcat/frozenidea/jps/ModelSerializerExtension has been compiled by a more recent version of the Java Runtime (class file version 55.0), this version of the Java Runtime only recognizes class file versions up to 52.0

解决：升级JDK版本为11，重新启动。

再启动Client

以上的代码是同一台电脑之间调用，如果需要跨服务器之间调用，或者无论其他什么语言的客户端调用，只需要获取远程服务代理的时候加上ip即可。default默认采取tcp协议，所以下边的代码其实等同于上边我们调用本地机器的代码。

 Ice.ObjectPrx base = ic.stringToProxy("HelloIce:tcp -h 127.0.0.1 -p 10000");

下面是一个更完整的案例代码 client.java

package com.test.ice.service.demo;

import Ice.Communicator;
import Ice.ObjectPrx;
import Ice.Util;

import java.util.logging.Logger;


public class Client {
    private static Logger log = Logger.getLogger(Client.class.getSimpleName());

    public static void main(String[] args)
    {
        int status = 0;
        // Communicator实例
        Communicator ic = null;
        try
        {
            // 调用Ice.Util.Initialize()初始化Ice run time
            ic = Util.initialize(args);

            //   根据servant的名称以及服务器ip、端口获取远程服务代理
            ObjectPrx base = ic.stringToProxy("SimplePrinter:default -p 12121");

            // 将上面的代理向下转换成一个Printer接口的代理
            HelloPrx hello = HelloPrxHelper.checkedCast(base);

            // 如果转换成功
            if (hello == null)
            {
                throw new Error("Invalid proxy");
            }

            // 调用这个代理，将字符串传给它
            String s = hello.sayHello("World!");
            System.out.println(s+"<<");

        } catch (Ice.LocalException e)
        {
            e.printStackTrace();
            status = 1;
        } catch (Exception e)
        {
            e.printStackTrace();
            status = 1;
        } finally
        {
            if (ic != null)
            {
                ic.destroy();
            }
        }
        System.exit(status);
    }

}