zookeeper实现RMI服务，高可用，HA

ops/2024/10/16 2:12:07/

这可不是目录

  • 1.RMI原理与说明
    • 1.1含义
    • 1.2流程
    • 1.3rmi的简单实现
    • 1.4RMI的局限性
  • 2.zookeeper实现RMI服务（高可用、HA）
    • 2.1实现原理
    • 2.2高可用分析
    • 2.3zookeeper实现
      • 2.3.1代码分析
      • 2.3.2公共部分
      • 2.3.3服务端
      • 2.3.4客户端
      • 2.3.5运行与部署
      • 2.3.6效果展示与说明

1.RMI原理与说明

1.1含义

远程方法调用
仅适用于JAVA

RMI是一种用于实现远程过程调用的应用程序编程接口。它使客户机上运行的程序可以调用远程服务器上的对象。远程方法调用特性使Java编程人员能够在网络环境中分布操作。RMI全部的宗旨就是尽可能简化远程接口对象的使用。RMI（Remote Method Invocation）远程方法调用是一种计算机之间利用远程对象互相调用实现双方通讯的一种通讯机制。使用这种机制，某一台计算机上的对象可以调用另外一台计算机上的对象来获取远程数据。

1.2流程

在这里插入图片描述

1.3rmi的简单实现

客户端：RmiClient.java

package com.rmi.client;import com.rmi.common.HelloService;import java.net.MalformedURLException;
import java.rmi.Naming;
import java.rmi.NotBoundException;
import java.rmi.Remote;
import java.rmi.RemoteException;public class RmiClient {public static void main(String[] args) throws MalformedURLException, NotBoundException, RemoteException {System.out.println("rmi client running");//定义urlString url ="rmi://127.0.0.1:1099/com.rmi.server.HelloServiceImpl";//寻找发布的服务Remote lookup = Naming.lookup(url);//强制类型转换HelloService helloService = (HelloService) lookup;//调用目标方法String result = helloService.sayHello("wunaiieq");System.out.println("result:"+result);}
}

远程接口：HelloService.java

package com.rmi.common;import java.rmi.Remote;
import java.rmi.RemoteException;public interface HelloService extends Remote {String sayHello(String name) throws RemoteException;
}

远程接口的实现类：HelloServiceImpl.java

package com.rmi.server;import com.rmi.common.HelloService;import java.rmi.RemoteException;
import java.rmi.server.UnicastRemoteObject;public class HelloServiceImpl extends UnicastRemoteObject implements HelloService {protected HelloServiceImpl() throws RemoteException {}@Overridepublic String sayHello(String name) throws RemoteException {return "Hello"+name;}
}

rmi服务：RmiServer

package com.rmi.server;import java.net.MalformedURLException;
import java.rmi.Naming;
import java.rmi.RemoteException;
import java.rmi.registry.LocateRegistry;public class RmiServer {public static void main(String[] args) throws Exception{//定义发布RMi服务的端口int port = 1099;String url = "rmi://127.0.0.1:1099/com.rmi.server.HelloServiceImpl";//注册服务:相当于在JNDI中创建了一个注册表LocateRegistry.createRegistry(port);//绑定服务:将RMI服务的实现类对象和url绑定Naming.rebind(url,new HelloServiceImpl());}
}

运行说明

  1. 先启动RmiServer，注册远程对象
  2. 再启动RmiCllient，查找此对象，并调用远程方法
    在这里插入图片描述

1.4RMI的局限性

  1. 只能使用Java，不支持跨语言
  2. RMI使用了Java默认的序列化方式，对于要求较高的系统，可能需要其他的序列化方案进行解决（Protobuf）
  3. RMI服务在运行时可能会出现单点故障的问题，因此需要配置实现高可用HA

zookeeperRMIHA_108">2.zookeeper实现RMI服务（高可用、HA）

2.1实现原理

服务注册与发现：RMI服务端在启动后，可以在ZooKeeper上注册一个临时节点（Ephemeral Node），并将自己的服务地址写入该节点。客户端在需要调用RMI服务时，可以监听ZooKeeper上的这些临时节点，以获取服务地址。由于ZooKeeper会监控这些节点的状态，一旦服务端节点宕机或断开连接，对应的临时节点就会被自动删除。客户端在感知到这一变化后，可以重新获取有效的服务地址，从而实现了服务的自动发现和故障切换。

负载均衡：ZooKeeper还可以作为服务注册中心，为多个RMI服务端实例提供统一的注册和发现接口。客户端在调用RMI服务时，可以通过ZooKeeper获取到多个服务端的地址，并根据一定的策略（如轮询、随机等）选择一个进行调用。这样可以实现负载的均衡分配，避免单个服务端过载。注意，此处只能实现相对均衡，原则上不等同于负载均衡服务器

服务状态监控：ZooKeeper可以监控RMI服务端的状态信息（如CPU使用率、内存占用率等），并将这些信息反馈给客户端或系统管理员。当发现某个服务端状态异常时，可以及时采取措施（如重启服务、扩展资源等）来恢复服务的正常运行。

zookeeper在此处相当于一个注册表

2.2高可用分析

在这里插入图片描述
1. rmi服务高可用
首先一个服务端只能运行于一台服务中心上，提供的同一个服务可以存在多个，这样当某一个服务宕机时，服务中心仍存在其他相同的服务。
因此，这样的同名服务，同时运行，但是端口不一致，客户端在调用这样的服务时，随机选取(自定义选取也可以)一个znode节点，调用rmi服务
2. 服务注册中心高可用
上述的服务已经保证了不会宕机，但服务中心仍存在宕机的可能。
因此配置zookeeper高可用，在每个zookeeper上运行相应的服务，以保证当一个服务中心宕机，仍然可以提供服务。

zookeeper_127">2.3zookeeper实现

2.3.1代码分析

将设置6个代码块，红框表示客户端程序，黄框表示服务器端，中间为公共部分
在这里插入图片描述

2.3.2公共部分

客户端和服务端应共同规定这个包中所有的接口
Constant.java
这个接口主要是规定一些常量，以便于服务端和客户端的使用

package com.zkrmi.common;public interface Constant {//zk集群的地址String ZK_CONNECTION_STRING="192.168.80.111:2181,192.168.80.112:2181,192.168.80.113:2181";//连接超时时间int ZK_SESSION_TIMEOUT = 5000;//服务列表对应的临时节点的parent节点String ZK_REGISTRY_PATH="/registry";//临时节点的路径，注意创建的是临时顺序节点，因此最后显示的是provider0，provider1....String ZK_provider_PATH=ZK_REGISTRY_PATH+"/provider";
}

HelloService.java
远程接口，这是提前定义好，应当被客户端和服务端同时知晓的，共同规定的。

package com.zkrmi.common;import java.rmi.Remote;
import java.rmi.RemoteException;public interface HelloService extends Remote {String sayHello(String name) throws RemoteException;
}

2.3.3服务端

任务1. 实现远程接口
任务2. 在zookeeper上注册远程方法服务
HelloServiceImpl.java
这串代码主要用于实现远程接口，没有什么特殊的点

package com.zkrmi.server;import com.rmi.common.HelloService;import java.rmi.RemoteException;
import java.rmi.server.UnicastRemoteObject;public class HelloServiceImpl extends UnicastRemoteObject implements HelloService {protected HelloServiceImpl() throws RemoteException {}@Overridepublic String sayHello(String name) throws RemoteException {//注意，在不同的zk集群上，请修改以下说明，在实际生产中，不同节点上的实现类应保持一致return "Hello_ZK112"+name;}
}

ServiceProvider.java
在zookeeper上发布可以提供的服务，即远程对象，这里进行了封装，后续的调用将在主函数中进行。

package com.zkrmi.server;import com.zkrmi.common.Constant;
import com.zookeeper.ZooKeeperFactory;
import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.ZooDefs;
import org.apache.zookeeper.ZooKeeper;import java.net.MalformedURLException;
import java.rmi.Naming;
import java.rmi.Remote;
import java.rmi.RemoteException;
import java.rmi.registry.LocateRegistry;
import java.util.concurrent.CountDownLatch;public class ServiceProvider {private CountDownLatch latch = new CountDownLatch(1);/*** 发布RMI服务** @param remote 远程对象，即HelloServiceImpl的实例* @param host 192.168.80.113，zookeeper的地址* @param port 11214,11215,11216,这个表示端口* @return rmi地址    rmi://192.168.80.113:11214/com.rmi.server.HelloServiceImpl*/private String publishServer(Remote remote, String host, int port) {String url = null;try {//设置发布服务的rmi地址  rmi://192.168.80.113:11214/com.rmi.server.HelloServiceImplurl = String.format("rmi://%s:%d/%s", host, port, remote.getClass().getName());//注册服务:相当于在JNDI中创建了一个注册表LocateRegistry.createRegistry(port);//绑定服务:将RMI服务的实现类对象和url绑定Naming.rebind(url, remote);} catch (RemoteException | MalformedURLException e) {e.printStackTrace();}return url;}/*** 创建临时节点** @param zk:传入一个zookeeper对象* @param url:url是临时节点的数据，表示rmi地址*/private void createNode(ZooKeeper zk, String url) {try {byte[] data = url.getBytes();//创建一个临时有序的节点String result = zk.create(Constant.ZK_provider_PATH, data, ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL_SEQUENTIAL);System.out.println("节点创建成功"+result);} catch (Exception e) {e.printStackTrace();}}/*** @param remote 调用时填入一个远程对象,这里使用remote进行标识，表示此对象可以从服务器端调用* */public void publish(Remote remote, String host, int port) throws Exception {//调用publishServer发布rmi服务，获取rmi的地址String url = publishServer(remote, host, port);//连接zookeeper集群if (url!=null){ZooKeeper zk =ZooKeeperFactory.create(Constant.ZK_CONNECTION_STRING);if (zk!=null){createNode(zk,url);}else {System.out.println("zk==null,节点创建失败");}}else {System.out.println("url==null,发布失败");}}}

Server.java
作为服务器端的主类，值得说明的是，远程服务端的端口自拟即可（建议在1024到49151）

package com.zkrmi.server;import com.rmi.common.HelloService;import java.rmi.RemoteException;//作为服务端的main类
public class Server {public static void main(String[] args) throws Exception {//zk节点String host ="192.168.80.112";//第一个端口System.out.println("server 10100 start");int port =Integer.parseInt("10100");//创建服务的生产者对象ServiceProvider provider0 = new ServiceProvider();//创建远程对象，客户端将使用此对象进行远程方法调用HelloService helloService =new HelloServiceImpl();//发布rmi服务provider0.publish(helloService,host,port);//第二个端口System.out.println("server 10101 start");int port1 =Integer.parseInt("10101");ServiceProvider provider1 = new ServiceProvider();provider1.publish(helloService,host,port1);}
}

2.3.4客户端

任务1：获取所有的rmi地址
任务2：当rmi地址更新，或者某个服务器异常时，需要重新获取
ServiceConsumer.java
客户端的方法支持，实现上述任务1和任务2的要求

package com.zkrmi.client;import com.zkrmi.common.Constant;
import com.zookeeper.ZooKeeperFactory;
import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.ZooKeeper;import java.rmi.ConnectException;
import java.rmi.Naming;
import java.rmi.Remote;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ThreadLocalRandom;public class ServiceConsumer {private CountDownLatch latch =new CountDownLatch(1);/**保存最新的rmi地址*/private volatile List<String> urlList =new ArrayList<>();/**构造器，用于观察/registry节点的所有子节点，并更新urlList*/public ServiceConsumer() throws Exception {ZooKeeper zk = ZooKeeperFactory.create(Constant.ZK_CONNECTION_STRING);if (zk!=null){watchNode(zk);}}/**观察/registry节点下所有子节点是否有变化* <br>初始化：构造器中调用一次，获取所有rmi地址* <br>若有：重新调用此方法，更新rmi地址* @param zk 用final定义，防止后续调用时获取的节点是新节点，监听不到变化* */private void watchNode(final ZooKeeper zk){try {//获取所有子节点名称，并设置监听List<String> nodeList = zk.getChildren(Constant.ZK_REGISTRY_PATH, new Watcher() {//当子节点发生变化时，再次调用这个watchNode方法@Overridepublic void process(WatchedEvent event) {if (event.getType()==Event.EventType.NodeChildrenChanged){watchNode(zk);}}});List<String> dataList =new ArrayList<>();//根据子节点名称进行遍历,获取所有子节点的数据，即rmi的地址for (String node:nodeList){byte[] data =zk.getData(Constant.ZK_REGISTRY_PATH+"/"+node,false,null);dataList.add(new String(data));}//获取所有rmi地址，更新-->重新调用此方法-->再度获取urlList =dataList;} catch (InterruptedException e) {throw new RuntimeException(e);} catch (KeeperException e) {throw new RuntimeException(e);}}/**查找rmi服务* */public <T extends Remote> T lookup(){T service =null;//由于前面的更新，因此urlList始终保持的是最新的int size =urlList.size();if (size>0){String url;if (size ==1){url = urlList.get(0);System.out.println("只获取到一个url:"+url);}else {url =urlList.get(ThreadLocalRandom.current().nextInt(size));System.out.println("获取一个随机的url:"+url);}System.out.println("当前url:"+url);service = lookupService(url);}return service;}@SuppressWarnings("unchecked")private <T> T lookupService(String url){T remote =null;try {remote=(T) Naming.lookup(url);}catch (Exception e){if (e instanceof ConnectException){System.out.println("连接中断，重试");if (urlList.size()!=0){url=urlList.get(0);return lookupService(url);}}}return remote;}
}

Client.java
作为客户端的主类，实现远程方法调用

package com.zkrmi.client;import com.rmi.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("wunaiieq");System.out.println(result);Thread.sleep(3000);}}
}

2.3.5运行与部署

  1. 建议部署于虚拟机上
  2. 为测试zookeeper效果，请将服务端部署于不同的zookeeper节点上
  3. 客户端可以运行于非zookeeper集群的主机
  4. 上述代码中缺少zookeeperFactory.java可以去博客中复制（不放这，太乱了）

打包
pom.xml
为实现如下效果，请打3个包，2个服务端，1个客户端，打包时修改pom.xml文件中的主函数

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>com.wunaiieq</groupId><artifactId>zookeeper02</artifactId><version>1.0-SNAPSHOT</version><properties><maven.compiler.source>1.8</maven.compiler.source><maven.compiler.target>1.8</maven.compiler.target><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding></properties><dependencies><dependency><groupId>org.apache.zookeeper</groupId><artifactId>zookeeper</artifactId><version>3.7.1</version></dependency></dependencies><build><plugins><plugin><!--声明--><groupId>org.apache.maven.plugins</groupId><artifactId>maven-assembly-plugin</artifactId><version>3.3.0</version><!--具体配置--><configuration><archive><manifest><!--jar包的执行入口--><mainClass>com.zkrmi.client.Client</mainClass></manifest></archive><descriptorRefs><!--描述符，此处为预定义的，表示创建一个包含项目所有依赖的可执行 JAR 文件;允许自定义生成jar文件内容--><descriptorRef>jar-with-dependencies</descriptorRef></descriptorRefs></configuration><!--执行配置--><executions><execution><!--执行配置ID，可修改--><id>make-assembly</id><!--执行的生命周期--><phase>package</phase><goals><!--执行的目标，single表示创建一个分发包--><goal>single</goal></goals></execution></executions></plugin></plugins></build>
</project>

2.3.6效果展示与说明

在这里插入图片描述

112 ， 113为连接到zookeeper集群的主机，作为服务中心
114为客户端，调用rmi服务
检查114的输出，可以看到，服务能正常调用

代码其他解释
zk集群中，113状态为leader，112follower，同时运行服务端jar包，均正常创建了rmi服务对象
ZK高可用
当一个zk节点宕机，另一个仍可以正常运行。保证服务不中断
服务高可用
由于服务的端口号不一致，因此当关闭一个服务时，仍存在rmi服务供客户端使用
客户端选择
在上述代码中，设置的时随机选择，这个不重要，自行设置即可


http://www.ppmy.cn/ops/126232.html

相关文章

【Jenkins】2024 最新版本的 Jenkins 权限修改为 root 用户启动，解决 permission-denied 报错问题

【Jenkins】2024 最新版本的 Jenkins 权限修改为 root 用户启动，解决 permission-denied 报错问题

最新版本的 Jenkins 修改 /etc/sysconfig/jenkins 中的 JENKINS_USERroot不会再生效&#xff0c;需要按照以下配置进行操作&#xff1a; vim /usr/lib/systemd/system/jenkins.service然后重启就可以了 systemctl daemon-reload # 重新加载 systemd 的配置文件 systemctl res…
阅读更多...
Flink入门

Flink入门

概念透析 实践练习章节介绍了作为 Flink API 根基的有状态实时流处理的基本概念&#xff0c;并且举例说明了如何在 Flink 应用中使用这些机制。其中 Data Pieplelin & ETL 小节介绍了有状态流处理的概念&#xff0c;并且在 Fault Tolerance 小节中进行了深入介绍。Streami…
阅读更多...
【Vue】Vue扫盲（六）关于 Vue 项目运行以及文件关系和关联的详细介绍

【Vue】Vue扫盲（六）关于 Vue 项目运行以及文件关系和关联的详细介绍

一、Vue 项目运行过程 编译阶段 Vue 通过编译器将构建的模板转换为渲染函数。这个过程包括模板解析、AST&#xff08;抽象语法树&#xff09;生成和优化等操作。 例如&#xff0c;对于一个简单的 Vue 模板 {{message}} &#xff0c;编译器会解析其中的插值表达式{{message}}&a…
阅读更多...
mysql集群-主库从库配置--主从库分离

mysql集群-主库从库配置--主从库分离

mysql集群 为什么要做主从库分离&#xff1f; 怎么进行分离&#xff1f; 设置2个数据库&#xff0c;为主库从库&#xff0c;主库存储&#xff0c;从库查询 怎么设置&#xff1f; 在你原本的配置yml文件中主库的ip是多少&#xff0c;从库是多少&#xff0c;都要和数据库的ip 一…
阅读更多...
系统架构评估

系统架构评估

系统架构评估是在对架构分析、评估的基础上&#xff0c;对架构策略的选取进行决策。它利用数学或逻辑分析技术&#xff0c;针对系统的一致性、正确性、质量属性、规划结果等不同方面&#xff0c;提供描述性、预测性和指令性的分析结果。 系统架构评估的方法通常可以分为3类&…
阅读更多...
vue项目 子组件在打开时调用父组件传过来的props里的数据

vue项目 子组件在打开时调用父组件传过来的props里的数据

1 分析: 父组件在加载时就会加载子组件,所以此时调不到数据, 我们可以利用父组件内子组件的ref属性,获取子组件的方法, 在父组件的触发方法中调用直接传值 例: 父组件: //父组件事件AttributesRelations(row){this.dialogForm rowthis.$refs.AttributesRelationsRef.Attribu…
阅读更多...
美畅物联丨视频汇聚从“设”开始：海康威视摄像机设置详解

美畅物联丨视频汇聚从“设”开始：海康威视摄像机设置详解

在运用畅联云平台进行视频汇聚与监控管理时&#xff0c;海康威视的安防摄像机凭借其卓越的性能与广泛的应用兼容性&#xff0c;成为了众多用户的首选产品。海康威视摄像机参数设置与调试对于实现高效的安防监控至关重要。今天&#xff0c;让我们一同深入学习海康摄像机的参数设…
阅读更多...
在Android中如何实现只要一更新了应用程序，就清除本地数据

在Android中如何实现只要一更新了应用程序，就清除本地数据

目录 步骤&#xff1a; Java 代码实现 代码说明&#xff1a; 扩展&#xff1a; 总结&#xff1a; 在 Android 中实现“每次应用程序更新后清除本地数据”的功能时&#xff0c;最常见的方法是将当前应用的版本号存储在本地&#xff08;例如 SharedPreferences 中&#xff0…
阅读更多...
最新文章

Copyright @ 2022~2023