java RMI 协议通过zookeeper的实现

在上文中，介绍了zookeeper集群的基本应用，通过一个客户端，可以创建zookeeper的子节点，然后通过监听机制获取节点的信息。

这个功能主要用于分布式服务器之间的功能调用。

分布式应用，或者说微服务，是把一个功能组合拆分成多个子应用，然后各个子应用各自安装在不同的远程服务器上。这样的话，不同的功能之间有可能需调用其它子应用的功能，尤其是面向前端、客户端的服务器，作为一个用户交互的接口，肯定存在这种远程调用的需求。

java1.2开始提供一个RMI，remote method invocation。这个功能可以提供两台服务器之间java实现的功能之间相互调用。结合zookeeper，可以解耦不同功能，实现分布式应用的健壮性、灵活性。

服务端创建服务对象，然后像http通信一样，把这个服务对象通过bind函数绑定到ip和端口号。然后客户端就通过lookup函数（传入服务端ip和端口号），就可以使用服务端提供的这个对象的功能。

zookeeper的功能就是服务端的ip和端口号由服务端注册在zookeeper，然后客户端从服务端取。这样就提供了更大的灵活性。

附：服务端参考代码

public class ServerDemo implements Watcher {

public static void main(String[] args) throws IOException,

AlreadyBoundException, KeeperException, InterruptedException {

UsersService usersService = new UsersServiceImpl();

LocateRegistry. createRegistry ( 8888 );

String url = "rmi://localhost:8888/user" ;

Naming. bind (url,usersService);

// 将 url 信息放到 zookeeper 的节点中

ZooKeeper zooKeeper = new

ZooKeeper( "192.168.233.130:2181,192.168.233.130:2182,192.168.233.

130:2183" , 150000 , new ServerDemo());

// 创建 Znode

zooKeeper.create( "/service" ,url.getBytes(),

ZooDefs.Ids. OPEN_ACL_UNSAFE , CreateMode. PERSISTENT );

System. out .println( " 服务发布成功 " );

}

客户端：

public class ClientDemo implements Watcher {

public static void main(String[] args) throws IOException,

KeeperException, InterruptedException, NotBoundException {

ZooKeeper zooKeeper = new

ZooKeeper( "192.168.233.130:2181,192.168.233.130:2182,192.168.233.

130:2183" , 150000 , new ClientDemo());

byte [] bytes = zooKeeper.getData( "/service" , new

ClientDemo(), null );

String url = new String(bytes);

UsersService usersService = (UsersService)

Naming. lookup (url);

String result = usersService.findUsers( "Bj" );

System. out .println(result);

相关阅读:
Allegro172版本DFM规则之DFT Mask和silkscreen
机器学习笔记只隐马尔可夫模型(三)求值问题——前向算法(Forward Algorithm)
高频面试题：谈谈你对 Spring Boot 自动装配机制的理解
Github Copilot是什么？Ai高效编程！一键远程授权…
2022年最新前端面试题
只需这个下毒小工具，让Stable Diffusion彻底崩溃！狗变猫，车变牛，AI侵权打响反击战
事实表的分类
网络空间内生安全数学基础（1）——背景
iNFTnews | 福布斯的Web3探索
New Crack:::CAD .NET 14.1.X

原文地址：https://blog.csdn.net/m0_47161778/article/details/126094526