<dependency>
? ? ?<groupId>org.apache.curator</groupId>
? ? ?<artifactId>curator-framework</artifactId>
? ? ?<version>4.0.0</version>
</dependency>
<dependency>
? ? ? <groupId>org.apache.curator</groupId>
? ? ? <artifactId>curator-recipes</artifactId>
? ? ? <version>4.0.0</version>
</dependency>

zookeeper的config類：

application.properties
?
################################## zookeeper ##################################
kafka.zookeeper.host=127.0.0.1:2181
kafka.zookeeper.maxRetry=3
kafka.zookeeper.sessionTimeout=60000
kafka.zookeeper.connectTimeout=10000
kafka.zookeeper.namespace=sensecrowd

@Configuration
@ConfigurationProperties(prefix = "kafka.zookeeper")
public class ZookeeperConfig {
? ? private final Logger LOGGER = LoggerFactory.getLogger(ZookeeperConfig.class);?
? ? private String host;?
? ? private int maxRetry;?
? ? private int sessionTimeout;?
? ? private int connectTimeout;?
? ? private String namespace;
?
? ? @Bean
? ? public CuratorFramework curatorFramework(){
? ? ? ? RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 1);
? ? ? ? CuratorFramework client =
? ? ? ? ? ? ? ? CuratorFrameworkFactory.builder()
? ? ? ? ? ? ? ? ? ? ? ? .connectString(host)
? ? ? ? ? ? ? ? ? ? ? ? .sessionTimeoutMs(sessionTimeout)
? ? ? ? ? ? ? ? ? ? ? ? .connectionTimeoutMs(connectTimeout)
? ? ? ? ? ? ? ? ? ? ? ? .retryPolicy(retryPolicy)
? ? ? ? ? ? ? ? ? ? ? ? /*.aclProvider(new ACLProvider() {
? ? ? ? ? ? ? ? ? ? ? ? ? ? private List<ACL> acl ;
? ? ? ? ? ? ? ? ? ? ? ? ? ? @Override
? ? ? ? ? ? ? ? ? ? ? ? ? ? public List<ACL> getDefaultAcl() {
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? if(acl ==null) {
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ArrayList<ACL> acl = ZooDefs.Ids.CREATOR_ALL_ACL;
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? acl.clear();
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? acl.add(new ACL(ZooDefs.Perms.ALL, new Id("auth", "admin:admin")));
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? this.acl = acl;
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? return acl;
? ? ? ? ? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ? ? ? ? ? ? @Override
? ? ? ? ? ? ? ? ? ? ? ? ? ? public List<ACL> getAclForPath(String s) {
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? return acl;
? ? ? ? ? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ? ? ? ? })*/
// ? ? ? ? ? ? ? ? ? ? ? ?.namespace(namespace)
? ? ? ? ? ? ? ? ? ? ? ? .build();
? ? ? ? client.start();
? ? ? ? client.getConnectionStateListenable().addListener(new ZookeeperConnectionListener(host,maxRetry,sessionTimeout,connectTimeout,namespace));
? ? ? ? return client;
? ? }
?
? ? @PreDestroy
? ? private void destroyClient(){
? ? ? ? curatorFramework().close();
? ? ? ? LOGGER.info("==================關(guān)閉成功==================");
? ? }
?
? ? public String getHost() {
? ? ? ? return host;
? ? }
?
? ? public void setHost(String host) {
? ? ? ? this.host = host;
? ? }
?
? ? public int getMaxRetry() {
? ? ? ? return maxRetry;
? ? }
?
? ? public void setMaxRetry(int maxRetry) {
? ? ? ? this.maxRetry = maxRetry;
? ? }
?
? ? public int getSessionTimeout() {
? ? ? ? return sessionTimeout;
? ? }
?
? ? public void setSessionTimeout(int sessionTimeout) {
? ? ? ? this.sessionTimeout = sessionTimeout;
? ? }
?
? ? public int getConnectTimeout() {
? ? ? ? return connectTimeout;
? ? }
?
? ? public void setConnectTimeout(int connectTimeout) {
? ? ? ? this.connectTimeout = connectTimeout;
? ? }
?
? ? public String getNamespace() {
? ? ? ? return namespace;
? ? }
?
? ? public void setNamespace(String namespace) {
? ? ? ? this.namespace = namespace;
? ? }
}

可項(xiàng)目遇到了兩個(gè)問(wèn)題

1）、項(xiàng)目運(yùn)行控制臺(tái)會(huì)報(bào)Log4j日志警告，原因是我的項(xiàng)目使用的springboot整合的log4j模塊而curator包含slf4j的日志包，zookeeper包含log4j的日志包，所以log4j的版本沖突導(dǎo)致。

2）、curator可以查看節(jié)點(diǎn)信息，但創(chuàng)建節(jié)點(diǎn)會(huì)導(dǎo)致程序進(jìn)程阻塞，根據(jù)zookeeper版本不同報(bào)出不同的問(wèn)題，我使用的是默認(rèn)的curator4.0.0自帶的zookeeper版本，3.5.+-beta版，添加節(jié)點(diǎn)報(bào)，并且程序阻塞：

Unable to read additional data from server sessionid 0x1002fd7768a015f

解決辦法

修改pom依賴，第一解決log4j和slaf4j依賴版本沖突問(wèn)題，第二curator依賴的zookeeper版本修改成你服務(wù)器安裝的zookeeper服務(wù)的版本，完美解決。

<!-- zookeeper -->
? ? ? ? ? ? <dependency>
? ? ? ? ? ? ? ? <groupId>org.apache.zookeeper</groupId>
? ? ? ? ? ? ? ? <artifactId>zookeeper</artifactId>
? ? ? ? ? ? ? ? <version>3.4.10</version>
? ? ? ? ? ? ? ? <exclusions>
? ? ? ? ? ? ? ? ? ? <exclusion>
? ? ? ? ? ? ? ? ? ? ? ? <groupId>org.slf4j</groupId>
? ? ? ? ? ? ? ? ? ? ? ? <artifactId>slf4j-log4j12</artifactId>
? ? ? ? ? ? ? ? ? ? </exclusion>
? ? ? ? ? ? ? ? ? ? <exclusion>
? ? ? ? ? ? ? ? ? ? ? ? <groupId>org.slf4j</groupId>
? ? ? ? ? ? ? ? ? ? ? ? <artifactId>slf4j-api</artifactId>
? ? ? ? ? ? ? ? ? ? </exclusion>
? ? ? ? ? ? ? ? ? ? <exclusion>
? ? ? ? ? ? ? ? ? ? ? ? <groupId>log4j</groupId>
? ? ? ? ? ? ? ? ? ? ? ? <artifactId>log4j</artifactId>
? ? ? ? ? ? ? ? ? ? </exclusion>
? ? ? ? ? ? ? ? </exclusions>
? ? ? ? ? ? </dependency>
?
? ? ? ? ? ? <dependency>
? ? ? ? ? ? ? ? <groupId>org.apache.curator</groupId>
? ? ? ? ? ? ? ? <artifactId>curator-framework</artifactId>
? ? ? ? ? ? ? ? <version>4.0.0</version>
? ? ? ? ? ? ? ? <exclusions>
? ? ? ? ? ? ? ? ? ? <exclusion>
? ? ? ? ? ? ? ? ? ? ? ? <groupId>org.slf4j</groupId>
? ? ? ? ? ? ? ? ? ? ? ? <artifactId>slf4j-api</artifactId>
? ? ? ? ? ? ? ? ? ? </exclusion>
? ? ? ? ? ? ? ? </exclusions>
? ? ? ? ? ? </dependency>
? ? ? ? ? ? <dependency>
? ? ? ? ? ? ? ? <groupId>org.apache.curator</groupId>
? ? ? ? ? ? ? ? <artifactId>curator-recipes</artifactId>
? ? ? ? ? ? ? ? <version>4.0.0</version>
? ? ? ? ? ? </dependency>

以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。

您可能感興趣的文章: