zookeeper服务器动态上下线监听案例
创始人
2024-09-26 10:52:32
0

zookeeper服务器动态上下线监听案例

文档

  1. linux安装java -centos安装java -linux配置java环境变量
  2. zookeeper单机安装
  3. zookeeper集群安装
  4. zookeeper客户端命令行操作、节点类型及监听器
  5. zookeeper集群写数据原理
  6. java操作zookeeper

说明

两种角色:服务器、客户端 客户端监听服务器的状态,服务器上线下变化时,客户端接收到通知 无论是服务器,还是客户端,对于zookeeper来说,都是zookeeper客户端 

原理

  1. zookeeper临时节点的性质:zookeeper客户端断开连接后,节点自动删除

  2. 客户端设置监听器,监听子节点变化,监听/servers节点的子节点:

    ls -w /servers 

    需要注意的是,监听器仅监听一次,想要重复监听,则需要重复设置监听

  3. 服务器连接,创建临时节点,客户端监听,服务器上线

  4. 服务器断开连接,临时节点自动删除,客户端监听,服务器下线

命令行模拟服务器动态上下线监听

  1. 客户端连接(启动一个zookeeper客户端),设置监听

    ls -w /servers 
  2. 服务器1连接(启动一个zookeeper客户端),新增子节点,节点类型为临时有序号节点,可以通过序号获知该子节点的创建顺序,创建即表示服务器在线

    create -e -s /servers/server 
  3. 此时客户端将收到监听回调,此时可以获取子节点列表,来查看最新的服务器在线情况

    ls /servers 

    客户端再次设置监听

    ls -w /servers 
  4. 服务器2连接,重复步骤2

  5. 客户端,重复步骤3

  6. 服务器1断开连接,创建的临时节点将自动删除

  7. 客户端,重复步骤3

  8. 服务器2断开连接,创建的临时节点将自动删除

  9. 客户端,重复步骤3

java代码实现服务器动态上下线监听

  1. 客户端示例代码DistributeClient.java

    package xin.yangshuai.zookeeper01.case1;  import org.apache.zookeeper.KeeperException; import org.apache.zookeeper.WatchedEvent; import org.apache.zookeeper.Watcher; import org.apache.zookeeper.ZooKeeper;  import java.io.IOException; import java.util.List;  public class DistributeClient {      // 注意:逗号左右不能有空格     private String connectString = "192.168.145.132:2181,192.168.145.133:2181,192.168.145.134:2181";     // 2000毫秒     private int sessionTimeout = 2000;      private ZooKeeper zkClient;      public void getConnect() throws IOException {          zkClient = new ZooKeeper(connectString, sessionTimeout, new Watcher() {             @Override             public void process(WatchedEvent watchedEvent) {                 // 初始化时,会执行一次                 System.out.println("当前监听的节点:" + watchedEvent.getPath());                 try {                     // 由于注册一次,监听一次,如果想持续监听,可重新注册                     // getServerList()方法设置了监听,所以每次调用将重新注册监听                     getServerList();                 } catch (KeeperException | InterruptedException e) {                     e.printStackTrace();                 }             }         });     }      private void getServerList() throws KeeperException, InterruptedException {         // 参数watch设置为true,表示使用zkClient创建时的Watcher,并监听当前节点的子节点的增删变化         // 提前创建好 /servers 节点         List children = zkClient.getChildren("/servers", true);         System.out.println("服务器在线数量:" + children.size());         for (String child : children) {             System.out.println("服务器 " + child + " 在线");         }     } } 
  2. 服务端示例代码DistributeServer.java

    package xin.yangshuai.zookeeper01.case1;  import org.apache.zookeeper.*;  import java.io.IOException;  public class DistributeServer {      // 注意:逗号左右不能有空格     private String connectString = "192.168.145.132:2181,192.168.145.133:2181,192.168.145.134:2181";     // 2000毫秒     private int sessionTimeout = 2000;      private ZooKeeper zkClient;      private String node;      public void getConnect() throws IOException {          zkClient = new ZooKeeper(connectString, sessionTimeout, new Watcher() {             @Override             public void process(WatchedEvent watchedEvent) {              }         });     }      // 注册     public void register() throws KeeperException, InterruptedException {         // 创建一个带序号的临时节点         // 提前创建好 /servers 节点         node = zkClient.create("/servers/server", null, ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL_SEQUENTIAL);         System.out.println("服务器 " + node + " 注册成功");     }      // 断开连接     public void close() throws InterruptedException {         System.out.println("服务器 " + node + " 下线");         zkClient.close();     }  } 
  3. 测试方法示例代码DistributeTest.java

    package xin.yangshuai.zookeeper01.case1;  import org.apache.zookeeper.KeeperException;  import java.io.IOException;  public class DistributeTest {      public static void main(String[] args) throws InterruptedException, IOException, KeeperException {          // 启动客户端,连接zookeeper,客户端设置监听         DistributeClient client = new DistributeClient();         client.getConnect();         // 启动服务器1,连接zookeeper         DistributeServer server1 = new DistributeServer();         server1.getConnect();         // 启动服务器2,连接zookeeper         DistributeServer server2 = new DistributeServer();         server2.getConnect();         Thread.sleep(5000);          // 服务器1上线         server1.register();         Thread.sleep(5000);          // 服务器2上线         server2.register();         Thread.sleep(5000);          // 服务器1下线         server1.close();         Thread.sleep(5000);          // 服务器2下线         server2.close();          Thread.sleep(Long.MAX_VALUE);     } } 
  4. 可以只启动客户端,保持运行状态。用命令行模拟服务端

  5. 仅供参考

参考资料

  • 尚硅谷

相关内容

热门资讯

七分钟机制!德扑之星真破解套路... 您好,这款游戏可以开挂的,确实是有挂的,需要了解加微【136704302】很多玩家在这款游戏中打牌都...
重大通报!we-poker正规... 大家肯定在之前WepoKer或者WepoKer中玩过重大通报!we-poker正规,WepoKer其...
2024新版wepoker微扑... 2024新版wepoker微扑克(辅助软件透明挂),德州wepoker作弊有(有挂功能)(2025已...
实测揭晓!榕城510k外挂,天... 实测揭晓!榕城510k外挂,天天十三水原来是有挂的,黑科技教程(有挂讲解)-哔哩哔哩;榕城510k外...
每日必看推荐!wepoker是... 每日必看推荐!wepoker是有人用挂,wePOKEr确实真的是有挂,德州论坛(有挂揭秘)-哔哩哔哩...
9分钟计算器!aa扑克有挂,w... 9分钟计算器!aa扑克有挂,wpk有那种辅助,攻略方法(有挂app)-哔哩哔哩;wpk是一款益智类棋...
必备教程德州wepoker(软... 必备教程德州wepoker(软件透视挂),wepoker是有辅助软件(新版有挂)(2025已更新)亲...
玩家必备攻略!we-poker... 玩家必备攻略!we-poker辅助器,WepoKer软件透明挂,教你攻略(有挂总结)-哔哩哔哩是一款...
新手必备!白金岛跑得快样来好牌... 新手必备!白金岛跑得快样来好牌,兴动麻将原来是有挂的,教你教程(确实有挂)-哔哩哔哩;白金岛跑得快样...
科技分享wpk透视(软件透视挂... 您好:wpk透视这款游戏可以开挂的,确实是有挂的,添加客服微信【485275054】安装软件,很多玩...