大数据全系列 教程
1869个小节阅读:465.3k
目录
JAVA全系列 教程
面向对象的程序设计语言
Python全系列 教程
Python3.x版本,未来主流的版本
人工智能 教程
顺势而为,AI创新未来
大厂算法 教程
算法,程序员自我提升必经之路
C++ 教程
一门通用计算机编程语言
微服务 教程
目前业界流行的框架组合
web前端全系列 教程
通向WEB技术世界的钥匙
大数据全系列 教程
站在云端操控万千数据
AIGC全能工具班
A A
White Night
xxxxxxxxxx
package com.itbaizhan.zookeeper.curd;
import org.apache.log4j.Logger;
import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.ZooKeeper;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import java.io.IOException;
public class ZKCurd {
//定义会话的超时时间
private final static int SESSION_TIME=30000;
//定义zk集群的ip地址
private final static String ZK_SERVERS = "192.168.20.102:2181,192.168.20.103:2181,192.168.20.104:2181";
//日志对象
private final static Logger LOGGER = Logger.getLogger(ZKCurd.class);
private ZooKeeper zkCli = null;
private Watcher watcher = new Watcher() {
@Override
public void process(WatchedEvent watchedEvent) {
LOGGER.info("event:"+watchedEvent.toString());
}
};
@Before
public void connect() throws IOException {
zkCli = new ZooKeeper(ZK_SERVERS,SESSION_TIME,watcher);
//获取当前会话的sessionId
long sessionId = zkCli.getSessionId();
LOGGER.info("sessionId:"+sessionId);
System.out.println("zkCli:"+zkCli);
}
@After
public void close() throws InterruptedException {
zkCli.close();
}
}