zookeeper代码编写环境配置,网络好的朋友可以让IDEA自动加载,不行的话我们也可以手动加载。再编写代码监听zk服务器,idea配置就成功了
配置环境1.创建一个 Maven 工程
2.添加 pom 文件
junit junit RELEASE org.apache.logging.log4j log4j-core 2.8.2 org.apache.zookeeper zookeeper 3.4.10
3.拷贝 log4j.properties 文件到项目根目录
需要在项目的 src/main/resources 目录下,新建一个文件,命名为“log4j.properties”,在
文件中填入。
log4j.rootLogger=INFO, stdout log4j.appender.stdout=org.apache.log4j.ConsoleAppender log4j.appender.stdout.layout=org.apache.log4j.PatternLayout log4j.appender.stdout.layout.ConversionPattern=%d %p [%c]- %m%n log4j.appender.logfile=org.apache.log4j.FileAppender log4j.appender.logfile.File=target/spring.log手动加入zookeeper环境jar包
我的IDEA可能因为网络不好,在.xml文件中加入配置后,依旧加载不出来。自动加载不行,那我们手动加载环境配置也是蛮快的。
-
下载zookeeper带有源码的Jar包,并解压。比如zookeeper-3.4.10-sources.jar,下载地址在:https://repo1.maven.org/maven2/org/apache/zookeeper/zookeeper/。
-
将下载的zookeeper-3.4.10-sources.jar解压后,将里面的org目录复制到项目中。
这样就完成了zookeeper源码的导入,比Ant编译手动添加Sources之类的,方便很多。
重启一下IDEA就可以使用配置环境了。
手动加载环境借鉴:https://www.jianshu.com/p/9d45d8000a57
测试连接服务器zk使用new zookeeper监听服务器
import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.ZooKeeper;
import org.junit.Test;
import java.io.IOException;
public class ZK_Test {
private static String connectString = "10.1.85.105:2181,10.1.85.106:2181,10.1.85.107:2181"; //连接服务器的ip地址和端口
private static int sessionTimeout = 2000; //会议超时为2s
private ZooKeeper zkClient = null;
@Test
public void init() throws IOException {
try {
zkClient = new ZooKeeper(connectString, sessionTimeout, new Watcher() {
public void process(WatchedEvent event) {
}
});
} catch (Exception e){
e.printStackTrace();
}
}
}
注意:要在init()函数前加上@Test,才能正常运行
运行结果:


