日韩av黄I国产麻豆传媒I国产91av视频在线观看I日韩一区二区三区在线看I美女国产在线I麻豆视频国产在线观看I成人黄色短片

歡迎訪問 生活随笔!

生活随笔

當(dāng)前位置: 首頁(yè) >

java本地连接zk集群

發(fā)布時(shí)間:2023/12/3 54 豆豆
生活随笔 收集整理的這篇文章主要介紹了 java本地连接zk集群 小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,幫大家做個(gè)參考.

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

?

【1】創(chuàng)建maven項(xiàng)目

添加依賴后, pom.xml? 長(zhǎng)這個(gè)樣子:

<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

添加測(cè)試方法, 如下:

public class TestZK {/*** zk server cluster 連接串 */private String connectString = "192.168.163.201:2181,192.168.163.202:2181,192.168.163.203:2181";/*** 超時(shí)時(shí)間*/private int sessionTimeout = 3000; /*** zk客戶端實(shí)例 */private ZooKeeper zkClient; @Testpublic void init() throws IOException {/* 連接zk服務(wù)器 */zkClient = new ZooKeeper(connectString, sessionTimeout, new Watcher() {@Overridepublic void process(WatchedEvent event) {}});} }

運(yùn)行日志

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!

?

?

總結(jié)

以上是生活随笔為你收集整理的java本地连接zk集群的全部?jī)?nèi)容,希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò),歡迎將生活随笔推薦給好友。