spring/springboot整合curator遇到的坑及解决

2024-04-02 19:04:59 844人浏览八月长安

Python 官方文档：入门教程 => 点击学习

摘要

目录整个代码可项目遇到了两个问题解决办法近期本人在搭建自己的调度平台项目使用到了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)
                        
//                        .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>

以上为个人经验，希望能给大家一个参考，也希望大家多多支持编程网。

您可能感兴趣的文档:

点击免费下载>>软考高级考试备考技巧/历年真题/备考精华资料

--结束END--

本文标题: spring/springboot整合curator遇到的坑及解决

本文链接: https://www.lsjlt.com/news/148121.html(转载时请注明来源链接)

有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341