ZkClient watch 操作

忘是亡心i 2022-02-02 06:49 160阅读 0赞

### 文章目录 ###

*   *   *  1、依赖
         *  2、zkClient.subscribeChildChanges() 监听当前节点和下面子节点的新增、删除
         *   *  2.1、运行结果：
         *  3、zkClient.subscribeDataChanges() 监听 当前节点和子节点的内容修改、删除
         *   *  3.1、运行结果：

### 1、依赖 ###

<dependency>
    	<groupId>com.101tec</groupId>
    	<artifactId>zkclient</artifactId>
    	<version>0.10</version>
    </dependency>

### 2、zkClient.subscribeChildChanges() 监听当前节点和下面子节点的新增、删除 ###

监听当前节点和下面子节点的新增、删除。不监听数据发生修改和变化。

**参数说明：**

*  第1个参数： 路径path，要监听的节点
 *  第2个参数：这个一个回调函数，要实现 IZkChildListener 接口，并重写 subscribeChildChanges()

package com.aop8.zkclient.watcher;
    
    public class ZkClientWatcher1 { 	
    	
    	/** session超时时间 */
    	static final int SESSION_OUTTIME = 5000;//ms 
    	
    	public static void main(String[] args) throws Exception { 
    		ZkClient zkc = new ZkClient(new ZkConnection("127.0.0.1:2181"), 5000);
    		
    		//对父节点添加监听子节点变化。
    		zkc.subscribeChildChanges("/super", new IZkChildListener() { 
    			@Override
    			public void handleChildChange(String parentPath, List<String> currentChilds) throws Exception { 
    				System.out.println("parentPath: " + parentPath);
    				System.out.println("currentChilds: " + currentChilds);
    			}
    		});
    		
    		Thread.sleep(3000);
    		
    		zkc.createPersistent("/super");
    		Thread.sleep(1000);
    		
    		zkc.createPersistent("/super" + "/" + "c1", "c1内容");
    		Thread.sleep(1000);
    		
    		zkc.createPersistent("/super" + "/" + "c2", "c2内容");
    		Thread.sleep(1000);		
    		
    		zkc.delete("/super/c2");
    		Thread.sleep(1000);	
    		
    		zkc.deleteRecursive("/super");
    		Thread.sleep(Integer.MAX_VALUE);		
    	}
    }

#### 2.1、运行结果： ####

parentPath: /super
    currentChilds: []
    ============添加 c1 ==============
    parentPath: /super
    currentChilds: [c1]
    ============添加 c2 ==============
    parentPath: /super
    currentChilds: [c1, c2]
    ============删除 c2 ==============
    parentPath: /super
    currentChilds: [c1]
    ============删除 super ==============
    parentPath: /super
    currentChilds: null
    parentPath: /super
    currentChilds: null

### 3、zkClient.subscribeDataChanges() 监听 当前节点和子节点的内容修改、删除 ###

这是一个回调函数，要实现 IZkDataListener 接口，并重写 handleDataChange() 和 handleDataDeleted() 两个方法。

package com.aop8.zkclient.watcher;
    
    
    public class ZkClientWatcher2 { 
    	
    	/** session超时时间 */
    	static final int SESSION_OUTTIME = 5000;//ms 
    	
    	
    	public static void main(String[] args) throws Exception { 
    		ZkClient zkc = new ZkClient(new ZkConnection("127.0.0.1:2181"), 5000);
    		
    		zkc.createPersistent("/super", "1234");
    		
    		//对父节点添加监听子节点变化。
    		zkc.subscribeDataChanges("/super", new IZkDataListener() { 
    			
    			@Override
    			public void handleDataChange(String path, Object data) throws Exception { 
    				System.out.println("变更的节点为:" + path + ", 变更内容为:" + data);
    			}
    			
    			@Override
    			public void handleDataDeleted(String path) throws Exception { 
    				System.out.println("删除的节点为:" + path);
    			}			
    		});
    		
    		Thread.sleep(3000);
    		zkc.writeData("/super", "456", -1);
    		Thread.sleep(1000);
    
    		zkc.delete("/super");
    		Thread.sleep(Integer.MAX_VALUE);
    		
    		zkc.close();
    	}
    }

#### 3.1、运行结果： ####

变更的节点为:/super, 变更内容为:456 
    删除的节点为:/super