java本地连接zk集群

【README】基于centos8 搭建zookeeper 集群，refer2 https://blog.csdn.net/PacosonSWJTU/article/details/111409079

【1】创建maven项目

添加依赖后， pom.xml 长这个样子：

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>com.hello</groupId><artifactId>zk20201219A</artifactId><version>0.0.1-SNAPSHOT</version><dependencies><dependency><groupId>junit</groupId><artifactId>junit</artifactId><version>RELEASE</version></dependency><dependency><groupId>org.apache.logging.log4j</groupId><artifactId>log4j-core</artifactId><version>2.8.2</version></dependency><!-- https://mvnrepository.com/artifact/org.apache.zookeeper/zookeeper --><dependency><groupId>org.apache.zookeeper</groupId><artifactId>zookeeper</artifactId><version>3.4.10</version></dependency>
</dependencies>
</project>

在 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
log4j.appender.logfile.layout=org.apache.log4j.PatternLayout
log4j.appender.logfile.layout.ConversionPattern=%d %p [%c] - %m%n

添加测试方法，如下：


public class TestZK {/*** zk server cluster 连接串 */private String connectString  = "192.168.163.201:2181,192.168.163.202:2181,192.168.163.203:2181";/*** 超时时间*/private int sessionTimeout = 3000;  /*** zk客户端实例 */private ZooKeeper zkClient; @Testpublic void init() throws IOException {/* 连接zk服务器   */zkClient = new ZooKeeper(connectString, sessionTimeout, new Watcher() {@Overridepublic void process(WatchedEvent event) {}});}
}

运行日志

2020-12-19 14:29:18,254 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:zookeeper.version=3.4.10-39d3a4f269333c922ed3db283be479f9deacaa0f, built on 03/23/2017 10:13 GMT2020-12-19 14:29:18,255 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:host.name=DESKTOP-E4IASRJ2020-12-19 14:29:18,255 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:java.version=1.8.0_1722020-12-19 14:29:18,255 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:java.vendor=Oracle Corporation2020-12-19 14:29:18,255 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:java.home=D:\Java\jdk1.8.0_172\jre2020-12-19 14:29:18,255 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:java.class.path=#############2020-12-19 14:29:18,256 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:java.library.path=##########2020-12-19 14:29:18,256 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:java.io.tmpdir=##########2020-12-19 14:29:18,256 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:java.compiler=<NA>2020-12-19 14:29:18,256 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:os.name=Windows 102020-12-19 14:29:18,256 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:os.arch=amd642020-12-19 14:29:18,256 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:os.version=10.02020-12-19 14:29:18,256 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:user.name=pacoson2020-12-19 14:29:18,256 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:user.home=C:\Users\pacoson2020-12-19 14:29:18,256 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:user.dir=D:\bench-cluster\spring_in_action_eclipse\zk20201219A2020-12-19 14:29:18,257 INFO [org.apache.zookeeper.ZooKeeper] - Initiating client connection, connectString=192.168.163.201:2181,192.168.163.202:2181,192.168.163.203:2181 sessionTimeout=3000 watcher=com.hello.zk.TestZK$1@4c3e4790

bingo!

java本地连接zk集群相关推荐

报错：使用java api连接redis集群时报错 READONLY You can't write against a read only slave....
报错: READONLY You can't write against a read only slave. 报错原因: 因为连接的是从节点,从节点只有读的权限,没有写的权限解决方案: 进入red ...
报错：使用java api连接redis集群时报错 READONLY You can't write against a read only slave.
报错: READONLY You can't write against a read only slave. 报错原因: 因为连接的是从节点,从节点只有读的权限,没有写的权限解决方案: 进入red ...
java本地创建zk节点
[README] java本地连接zk cluster, refer to https://blog.csdn.net/PacosonSWJTU/article/details/111404364; ...
eclipse手动pom本地包_环境篇--Eclipse如何远程连接Hadoop集群调试
关注 DLab数据实验室公众号带你一起学习大数据- 写在前面:最近终于闲下来了,打算把之前了解到的内容整理一下,先从搭建环境开始吧- 现在接触大数据开发的朋友可能直接使用Spark或者其他的查询引 ...
mongodb java连接集群_java连接mongodb集群
MongoDb 的分片拓展与副本集 Mongodb 数据库分片是通过并行处理数据实现负载均衡的一种重要手段[12],同时也是数据库集群实现分布式计算的关键技术.在生产环境中,...... 本地数据访 ...
本地Spark连接远程集群Hive(Scala/Python)
精选30+云产品,助力企业轻松上云!>>> 点击蓝色"大数据每日哔哔"关注我加个"星标",第一时间获取大数据架构,实战经验摘要:本地Spa ...
java访问oracle集群,JAVA查询Oracle数据库集群连接字符串
下载必备最新排行装机分类.游戏手机驱动源码LinuxMac小游戏.商城招聘百科知道软件盒子论坛3G版本站搜索新闻资讯软件下载当前位置: 网站首页 > 编程开发 > 编程语言 > ...
java 连接mongodb 集群_Java 连接MongoDB集群的几种方式
先决条件先运行mongodb肯定是必须的,然后导入以下包: import com.mongodb.MongoClient; import com.mongodb.MongoClientURI; im ...
尚硅谷大数据技术Zookeeper教程-笔记01【Zookeeper(入门、本地安装、集群操作)】
视频地址:[尚硅谷]大数据技术之Zookeeper 3.5.7版本教程_哔哩哔哩_bilibili 尚硅谷大数据技术Zookeeper教程-笔记01[Zookeeper(入门.本地安装.集群操作)] ...

java本地连接zk集群

java本地连接zk集群相关推荐

最新文章

热门文章