spring/springboot整合curator遇到的坑及解决
更新时间：2022年05月07日 09:48:00 作者：lishentao_1122
这篇文章主要介绍了spring/springboot整合curator遇到的坑及解决方案，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
近期本人在搭建自己的调度平台项目使用到了zookeeper做执行器自动注册中心时，使用到了springboot2.0+curator4.0版本整合
整个代码
pom.xml
<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("==================关闭成功==================");
}
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;
}
}可项目遇到了两个问题
1）、项目运行控制台会报Log4j日志警告，原因是我的项目使用的springboot整合的log4j模块而curator包含slf4j的日志包，zookeeper包含log4j的日志包，所以log4j的版本冲突导致。
2）、curator可以查看节点信息，但创建节点会导致程序进程阻塞，根据zookeeper版本不同报出不同的问题，我使用的是默认的curator4.0.0自带的zookeeper版本，3.5.+-beta版，添加节点报，并且程序阻塞：
Unable to read additional data from server sessionid 0x1002fd7768a015f
解决办法
修改pom依赖，第一解决log4j和slaf4j依赖版本冲突问题，第二curator依赖的zookeeper版本修改成你服务器安装的zookeeper服务的版本，完美解决。
<!-- 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>
以上为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。
相关文章
这篇文章主要介绍了什么是SSM框架，SSM框架是spring、spring MVC 、和mybatis框架的整合，是标准的MVC模式。想进一步了解的同学可以详细参考本文2023-03-03
这篇文章主要为大家分享了最有价值的三道关于分布式的面试题，涵盖内容全面，包括数据结构和算法相关的题目、经典面试编程题等，感兴趣的小伙伴们可以参考一下2021-08-08
Spring MVC中使用Controller如何进行重定向
这篇文章主要介绍了Spring MVC中使用Controller如何进行重定向操作，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2021-09-09
MyEclipse+Tomcat+MAVEN+SVN项目完整环境搭建(图文教程)
这篇文章主要介绍了MyEclipse+Tomcat+MAVEN+SVN项目完整环境搭建(图文教程)，非常具有实用价值，需要的朋友可以参考下2017-12-12
Android的水波纹效果只有高版本才有，我们希望自己的应用在低版本用低版本的阴影，而高版本用水波纹，这怎么做呢？下面一起来学习学习。2016-08-08
今天给大家整理了如何在MyBatis中实现DataSource,文中有非常详细的代码示例,对正在学习java的小伙伴们很有帮助,需要的朋友可以参考下2021-06-06
这篇文章主要介绍了SpringBoot接收数组参数和集合参数方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2025-03-03
一文搞懂Java ScheduledExecutorService的使用
JUC包(java.util.concurrent)中提供了对定时任务的支持，即ScheduledExecutorService接口。本文主要对ScheduledExecutorService的使用进行简单的介绍，需要的可以参考一下2022-11-11
本篇文章介绍了我看到的一个趣味小题目，怎么求得两个日期之间相隔的天数，以及解决该题目的过程及思路，通读本篇对大家的学习或工作具有一定的价值，需要的朋友可以参考下2021-10-10
这篇文章主要为大家详细介绍了java生成验证码的步骤总结，需要的朋友可以参考下2017-04-04
最新评论