5.2.5 调用服务

通过调用 ServiceConsumer 的 lookup() 方法来查找 RMI 远程服务对象。我们使用一个“死循环”来模拟每隔 3 秒钟调用一次远程方法。

xxxxxxxxxx
package com.itbaizhan.zookeeper.zkrmi.client;
import com.itbaizhan.zookeeper.zkrmi.common.HelloService;
public class Client {
    public static void main(String[] args) throws Exception {
        ServiceConsumer consumer = new ServiceConsumer();
        while (true) {
            HelloService helloService = consumer.lookup();
            String result = helloService.sayHello("GTJin");
            System.out.println(result);
            Thread.sleep(3000);
        }
    }
}

5.2.6 使用方法

根据以下步骤验证 RMI 服务的高可用性：

• 运行三个 Server 程序，一定要确保 port 是不同（11214、11215、11216）的。
• 运行一个 Client 程序,看控制台。
• 停止其中一个 Server 程序，并观察 Client 控制台的变化（停止一个 Server 不会导致 Client 端调用失败）。
• 重新启动刚才关闭的 Server 程序，继续观察 Client 控制台变化（新启动的 Server 会加入候选）。
• 先后停止所有的 Server 程序，还是观察 Client 控制台变化（Client 会重试连接，多次连接失败后，自动关闭）。

5.2.7 总结

通过使用 ZooKeeper 实现了一个简单的 RMI 服务高可用性解决方案，通过 ZooKeeper 注册所有服务提供者发布的 RMI 服务，让服务消费者监听 ZooKeeper 的 Znode，从而获取当前可用的 RMI 服务。此方案不局限于 RMI 服务，对于任何形式的服务都可以（比如：WebService），也提供了一定参考。