栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 前沿技术 > 大数据 > 大数据系统

编写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,才能正常运行

运行结果:

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/389451.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号