[大数据]Zookeeper监听机制

@Slf4j
public class ZookeeperClientTest {

private static final String ZK_ADDRESS="192.168.109.200:2181";//链接地址

private static final int SESSION_TIMEOUT = 5000;//超时时间

private static ZooKeeper zooKeeper;//zookeeper客户端对象

private static CountDownLatch countDownLatch=new CountDownLatch(1);//zk客户端创建是异步守护线程，为了防止主线程执行完，创建还没完成，需要进行阻塞操作。

public static void main(String[] args){

	zookeeper=new Zookeeper(ZK_ADDRESS,SESSION_TIMEOUT,new Watcher(){
	@Override
	public void process(WatchedEvent event){
		if(event.getType()==Event.EventType.None&&
		event.getState()==Event.KeeperState.SyncConnected){
		log.info("链接已经建立");
		countDownLatch.countDown();
		}
		
	
	});
	countDownLatch.await();
	
	MyConfig myConfig=new MyConfig();
	myConfig.setKey("anyKey");
	myConfig.setName("anyName");

	//序列化
	ObjectMapper objectMapper=new ObjectMapper();
	byte[] bytes =objectMapper.writeValueAsBytes(myConfig);
	
	//创建节点
	zookeeper.create("/myconfig",bytes,ZooDefs.Ids.OPEN_ACL_UNSAFE,
	CreateMode.PERSISTENT);
	
	Watcher watcher=new Watcher(){
	@Override
	public void process(WathedEvent event){
	if(event.getType()==NodeDataChanged){

	//循环监听
	byte[]data=zookeeper.getData("/myConfig",this,null);
	//反序列化
	MyConfig newConfig=objectMapper.readValue(new String(data),MyConfig.class);
	log.info("发生了数据变化，变化为："+newConfig)
	}
  }
};
	zookeeper.getData("/myConfig",watcher,null);
}

	

@Data
@ToString
@NoArgsConstructor
public class MyConfig{
	private String key;
	private String name;
}