编写Zookeeper代码连接ZK客户端及IDEA环境搭配

编写Zookeeper代码连接ZK客户端及IDEA环境搭配

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文件中加入配置后，依旧加载不出来。自动加载不行，那我们手动加载环境配置也是蛮快的。

1. 下载zookeeper带有源码的Jar包，并解压。比如zookeeper-3.4.10-sources.jar，下载地址在：https://repo1.maven.org/maven2/org/apache/zookeeper/zookeeper/。

2. 将下载的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，才能正常运行

运行结果：