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. 仅供参考

参考资料

  • 尚硅谷

相关内容

热门资讯

玩家必备科技wpk俱乐部(软件... 玩家必备科技wpk俱乐部(软件透视挂),wepoker辅助作弊透视(有挂头条)(2025已更新);w...
揭秘真相!钱塘十三水黑科技,悠... 您好,钱塘十三水黑科技这款游戏可以开挂的,确实是有挂的,需要了解加微【485275054】很多玩家在...
终于清楚!hhpoker德州真... 终于清楚!hhpoker德州真的假的,WePoker原来确实真的有挂,规律教程(有挂研究)-哔哩哔哩...
9分钟开挂!pokernow开... 9分钟开挂!pokernow开挂,hhpoker是真的,可靠技巧(有挂计算器)-哔哩哔哩;是一款益智...
科普常识wepoker网页版(... 科普常识wepoker网页版(能透视),wepoker可以透视的(有挂存在)(2025已更新)科普常...
玩家必知教程!牵手跑胡子有辅助... 您好,牵手跑胡子有辅助器这款游戏可以开挂的,确实是有挂的,需要了解加微【485275054】很多玩家...
教程攻略!hhpoker辅助挂... 教程攻略!hhpoker辅助挂是真的,wepOkEr原来是真的有挂,教你攻略(有挂推荐)-哔哩哔哩;...
今日重大通报wpk透视(辅助软... 亲,wpk透视这款游戏可以开挂的,确实是有挂的,很多玩家在这款游戏中打牌都会发现很多用户的牌特别好,...
4分钟胜率!德扑软件高端,we... 您好,wepoker这款游戏可以开挂的,确实是有挂的,需要了解加微【136704302】很多玩家在这...
今日百科!wepoker有透视... 今日百科!wepoker有透视方法,WepOker软件透明挂,技巧教程(有挂爆料)-哔哩哔哩;1、很...