日韩性视频-久久久蜜桃-www中文字幕-在线中文字幕av-亚洲欧美一区二区三区四区-撸久久-香蕉视频一区-久久无码精品丰满人妻-国产高潮av-激情福利社-日韩av网址大全-国产精品久久999-日本五十路在线-性欧美在线-久久99精品波多结衣一区-男女午夜免费视频-黑人极品ⅴideos精品欧美棵-人人妻人人澡人人爽精品欧美一区-日韩一区在线看-欧美a级在线免费观看

歡迎訪問 生活随笔!

生活随笔

當前位置: 首頁 > 编程资源 > 编程问答 >内容正文

编程问答

java本地连接zk集群

發布時間:2023/12/3 编程问答 42 豆豆
生活随笔 收集整理的這篇文章主要介紹了 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集群的全部內容,希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯,歡迎將生活随笔推薦給好友。