SpringBoot3集成Zookeeper

标签：Zookeeper3.8 ，Curator5.5；

一、简介

ZooKeeper是一个集中的服务，用于维护配置信息、命名、提供分布式同步、提供组服务。分布式应用程序以某种形式使用所有这些类型的服务。
二、环境搭建

1、修改配置文件

1. # 1、拷贝一份样本配置文件
2. cp zookeeper-3.8.3/conf/zoo_sample.cfg zookeeper-3.8.3/conf/zoo.cfg
4. # 2、修改数据文件地址，注意这里用本地路径
5. dataDir=/local-path/zookeeper-3.8.3/data
7. # 3、添加一个配置，处理启动日志的提示：ZooKeeper audit is disabled.
8. audit.enable=true

复制代码

2、服务启动

1. # 1、启动服务端
2. zookeeper-3.8.3/bin/zkServer.sh start
4. # 2、停止服务端
5. zookeeper-3.8.3/bin/zkServer.sh stop
7. # 3、启动客户端
8. zookeeper-3.8.3/bin/zkCli.sh

复制代码

3、客户端测几个增删查的命令

1. [zk: localhost:2181(CONNECTED) 0] create /cicada smile1
2. Created /cicada
3. [zk: localhost:2181(CONNECTED) 1] get /cicada
4. smile1
5. [zk: localhost:2181(CONNECTED) 2] ls /
6. [cicada, zookeeper]
7. [zk: localhost:2181(CONNECTED) 3] delete /cicada

复制代码

三、工程搭建

1、工程结构


2、依赖管理

Curator是一组Java库，它让ZooKeeper的使用变得更加容易，这里的依赖实际是查询匹配版本的时候走了个捷径，也可以参考integration-redis包，熟悉下Spring的封装策略。

1. <dependency>
2.     <groupId>org.apache.zookeeper</groupId>
3.     <artifactId>zookeeper</artifactId>
4.     <version>${zookeeper.version}</version>
5. </dependency>
7. <dependency>
8.     <groupId>org.springframework.integration</groupId>
9.     <artifactId>spring-integration-zookeeper</artifactId>
10.     <version>${spring-integration.version}</version>
11. </dependency>

复制代码

3、配置文件

配置脚本

1. zookeeper:
2.   #服务器地址
3.   connectString: 127.0.0.1:2181
4.   #会话超时时间
5.   sessionTimeoutMs: 3000
6.   #连接超时时间
7.   connectionTimeoutMs: 60000
8.   #最大重试次数
9.   maxRetries: 3
10.   #初始休眠时间
11.   baseSleepTimeMs: 1000

复制代码

配置类

1. @Configuration
2. public class ZookeeperConfig {
4.     @Value("${zookeeper.connectString}")
5.     private String connectString;
6.    
7.     @Value("${zookeeper.baseSleepTimeMs}")
8.     private int baseSleepTimeMs;
10.     @Value("${zookeeper.maxRetries}")
11.     private int maxRetries ;
13.     @Value("${zookeeper.connectionTimeoutMs}")
14.     int connectionTimeoutMs ;
16.     @Value("${zookeeper.sessionTimeoutMs}")
17.     int sessionTimeoutMs ;
19.     private static CuratorFramework client = null ;
20.     /**
21.      * 初始化
22.      */
23.     @PostConstruct
24.     public void init (){
25.         // 重试策略
26.         RetryPolicy policy = new ExponentialBackoffRetry(baseSleepTimeMs, maxRetries);
27.         // 创建Curator
28.         client = CuratorFrameworkFactory.builder()
29.                 .connectString(connectString)
30.                 .connectionTimeoutMs(connectionTimeoutMs)
31.                 .sessionTimeoutMs(sessionTimeoutMs)
32.                 .retryPolicy(policy).build();
33.         //开启连接
34.         client.start();
35.     }
37.     @Bean
38.     public CuratorFramework getClient (){
39.         return client ;
40.     }
41. }

复制代码

四、ZooKeeper用法

测试几个API方法，节点创建和添加数据，以及判断和查询数据，还有就是基于ZooKeeper提供的读写锁能力。

1. public class ConfigTest {
3.     @Autowired
4.     private CuratorFramework client ;
6.     @Test
7.     public void testCreate () throws Exception {
8.         // 创建一个持久化节点，断开连接时不会自动删除
9.         client.create().creatingParentsIfNeeded().withMode(CreateMode.PERSISTENT).forPath("/path1");
10.     }
12.     @Test
13.     public void testExists () throws Exception {
14.         // 判断节点是否存在，path2不存在所以stat2是null
15.         Stat stat1 = client.checkExists().forPath("/path1");
16.         System.out.println(stat1);
17.         Stat stat2 = client.checkExists().forPath("/path2");
18.         System.out.println(stat2);
19.     }
21.     @Test
22.     public void testSetData () throws Exception {
23.         // 设置节点数据
24.         client.setData().forPath("/path1", "data1".getBytes(StandardCharsets.UTF_8));
25.     }
27.     @Test
28.     public void testCreateAndSet () throws Exception {
29.         // 创建一个持久化节点并设置节点数据
30.         client.create().creatingParentsIfNeeded().withMode(CreateMode.PERSISTENT)
31.                 .forPath("/path3","data3".getBytes(StandardCharsets.UTF_8));
32.     }
34.     @Test
35.     public void testGetData () throws Exception {
36.         // 查询节点数据
37.         byte[] data = client.getData().forPath("/path3");
38.         System.out.println(new String(data,StandardCharsets.UTF_8));
39.     }
41.     @Test
42.     public void testDelete () throws Exception {
43.         // 删除节点
44.         client.delete().guaranteed().deletingChildrenIfNeeded().forPath("/path3");
45.     }
47.     @Test
48.     public void testReadLock () throws Exception {
49.         // 读写锁-读
50.         InterProcessReadWriteLock lock = new InterProcessReadWriteLock(client,"/lock-read");
51.         lock.readLock().acquire();
52.         System.out.println("获取-ReadLock");
53.         lock.readLock().release();
54.     }
56.     @Test
57.     public void testWriteLock () throws Exception {
58.         // 读写锁-写
59.         InterProcessReadWriteLock lock = new InterProcessReadWriteLock(client,"/lock-write");
60.         lock.writeLock().acquire();
61.         System.out.println("获取-WriteLock");
62.         lock.writeLock().release();
63.     }
64. }

复制代码

五、参考源码

1. 文档仓库：
2. https://gitee.com/cicadasmile/butte-java-note
4. 源码仓库：
5. https://gitee.com/cicadasmile/butte-spring-parent

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！