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

下面是“spring/springboot整合curator遇到的坑及解决”的完整攻略：

环境准备

首先，需要在本地或服务器上安装一个ZooKeeper集群，并开启相关端口。其次，根据具体的开发需求，在Spring或Spring Boot项目中集成Curator。

Spring/Spring Boot整合Curator

1. 添加Curator依赖

在Maven或Gradle中添加Curator的依赖，具体版本号可以根据项目需要进行调整。

Maven:

<dependency>
    <groupId>org.apache.curator</groupId>
    <artifactId>curator-framework</artifactId> 
    <version>4.2.0</version>
</dependency>

Gradle:

implementation 'org.apache.curator:curator-framework:4.2.0'

2. 创建Curator连接

在Spring/Spring Boot项目中创建一个Curator连接：

@Configuration
public class CuratorConfig {

    @Bean
    public CuratorFramework curatorFramework() {
        String connectString = "127.0.0.1:2181";
        int sessionTimeoutMs = 5000;
        int connectionTimeoutMs = 5000;
        RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 3);
        return CuratorFrameworkFactory.newClient(connectString, sessionTimeoutMs, connectionTimeoutMs, retryPolicy);
    }

    @Bean
    public InitializingBean curatorConnection() {
        return () -> {
            CuratorFramework curatorFramework = curatorFramework();
            curatorFramework.start();
            curatorFramework.blockUntilConnected();
        };
    }

}

这里使用了@Configuration注解来创建一个Curator连接的Bean，并在开始时启动并等待连接。

3. Curator客户端操作

对于Curator的客户端操作，一般需要在Spring/Spring Boot项目中定义相应的Service层或Repository层。下面是一个示例：

@Service
public class CuratorService {

    @Autowired
    private CuratorFramework curatorFramework;

    public void createNode(String path, byte[] data) throws Exception {
        curatorFramework.create()
            .creatingParentsIfNeeded()
            .withMode(CreateMode.EPHEMERAL)
            .forPath(path, data);
    }

    public byte[] getData(String path) throws Exception {
        return curatorFramework.getData().forPath(path);
    }

    public void setData(String path, byte[] data) throws Exception {
        curatorFramework.setData().forPath(path, data);
    }

    public void deleteNode(String path) throws Exception {
        curatorFramework.delete().deletingChildrenIfNeeded().forPath(path);
    }

}

这里定义了一个Curator的Service类，在其中使用Autowired注解引入了之前创建的Curator连接，然后定义了一些常用的节点操作方法。

遇到的坑及解决

坑一：Curator客户端启动报错

在启动Curator客户端时，有可能会报错。比如：

org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = ConnectionLoss

这种情况一般是由于ZooKeeper未正常启动，或者网络问题导致的。需要检查ZooKeeper服务的状态和网络连接是否正常。

坑二：Curator命名空间与节点路径冲突

使用Curator创建节点时，如果与Curator命名空间所设定的路径相同，会出现异常：

org.apache.zookeeper.KeeperException$InvalidPathException: Invalid path /curator/test: Path cannot be empty

解决方法是在创建节点时，使用相对路径而非绝对路径。在Curator中，相对路径的根节点为命名空间所设定的路径。

示例

下面是两个使用Curator操作ZooKeeper的示例。

示例一：创建ZooKeeper节点

@RestController
public class CuratorController {

    @Autowired
    private CuratorService curatorService;

    @GetMapping("/createNode")
    public String createNode() {
        try {
            String path = "/curator/test";
            String data = "hello zookeeper";
            curatorService.createNode(path, data.getBytes());
            return "Create node successfully";
        } catch (Exception e) {
            e.printStackTrace();
            return e.getMessage();
        }
    }

}

这里定义了一个Spring Boot的RestController，并在其中创建了一个ZooKeeper节点。

示例二：获取ZooKeeper节点数据

@RestController
public class CuratorController {

    @Autowired
    private CuratorService curatorService;

    @GetMapping("/getData")
    public String getData() {
        try {
            String path = "/curator/test";
            byte[] data = curatorService.getData(path);
            return new String(data);
        } catch (Exception e) {
            e.printStackTrace();
            return e.getMessage();
        }
    }

}

这里定义了一个Spring Boot的RestController，并在其中获取了一个ZooKeeper节点的数据。