自定义服务的服务注册- zookeeper

自定义服务的服务注册- zookeeper

服务注册使用 zookeeper 的大致过程如下

• 链接 zookeeper 集群大概单机
  
• 注册本身的 ip + 端口到 zookeeper 的 node（这个 node 要是临时节点的，因为可以包管健康查抄以及服务发现的高可用
  

编码实现

1. package com.rpc.custom_rpc.registery;
3. import com.rpc.custom_rpc.config.CustomRpcConfig;
4. import com.rpc.pre.zookeeper.curator.ZkCuratorFrameworkServerOps;
5. import org.apache.zookeeper.CreateMode;
7. import java.nio.charset.StandardCharsets;
9. /**
10. * @author xl-9527
11. * @since 2024/12/14
12. **/
13. public class ServerRegistryImpl implements ServerRegistry {
14.     private final String ip;
15.     private final int port;
16.     private final ZkCuratorFrameworkServerOps zkCuratorFrameworkServerOps;
18.     public ServerRegistryImpl(final String ip, final int port) {
19.         this.ip = ip;
20.         this.port = port;
21.         this.zkCuratorFrameworkServerOps = new ZkCuratorFrameworkServerOps();
22.     }
24.     @Override
25.     public void registry(final String serviceName) {
26.         // 基础的路径注册为永久节点
27.         final String path = CustomRpcConfig.BASE_PATH + serviceName;
28.         if (!zkCuratorFrameworkServerOps.exists(path)) {
29.             zkCuratorFrameworkServerOps.createNode(path, null, true);
30.         }
32.         // 创建临时节点，这其实就是我们的服务的元数据信息
33.         zkCuratorFrameworkServerOps.createNode(path + "/" + ip + ":" + port, (ip + ":" + port).getBytes(StandardCharsets.UTF_8), CreateMode.EPHEMERAL);
34.     }
35. }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。