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>

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