Spring Boot 3 集成 ZooKeeper：从环境搭建到实战应用 1. ZooKeeper 简介与 Spring Boot 集成价值ZooKeeper 是一个分布式的、开源的分布式应用程序协调服务它主要用于维护配置信息、命名、提供分布式同步和提供组服务。许多分布式应用如 Hadoop、Kafka、HBase 等都依赖 ZooKeeper 来实现核心的协调功能。Spring Boot 3 通过 Spring Integration Zookeeper 模块或 Apache Curator 客户端可以方便地与 ZooKeeper 集成实现配置中心、分布式锁、服务注册与发现等常见场景。2. ZooKeeper 环境搭建与配置1. 修改配置文件# 1、拷贝一份样本配置文件 cp zookeeper-3.8.3/conf/zoo_sample.cfg zookeeper-3.8.3/conf/zoo.cfg 2、修改数据文件地址注意这里用本地路径 dataDir/local-path/zookeeper-3.8.3/data 3、添加一个配置处理启动日志的提示ZooKeeper audit is disabled. audit.enabletrue2. 服务启动# 1、启动服务端 zookeeper-3.8.3/bin/zkServer.sh start 2、停止服务端 zookeeper-3.8.3/bin/zkServer.sh stop 3、启动客户端 zookeeper-3.8.3/bin/zkCli.sh3. 客户端测几个增删查的命令[zk: localhost:2181(CONNECTED) 0] create /cicada smile1 Created /cicada [zk: localhost:2181(CONNECTED) 1] get /cicada smile1 [zk: localhost:2181(CONNECTED) 2] ls / [cicada, zookeeper] [zk: localhost:2181(CONNECTED) 3] delete /cicada3. Spring Boot 3 工程集成 ZooKeeper1. 工程结构一个典型的 Spring Boot 3 项目结构如下src/main/java └── com └── example └── zkdemo ├── ZookeeperDemoApplication.java ├── config │ └── ZookeeperConfig.java └── service └── ZookeeperService.java src/main/resources ├── application.yml └── logback-spring.xml2. 依赖管理在pom.xml中添加以下依赖!-- Zookeeper 客户端 -- dependency groupIdorg.apache.zookeeper/groupId artifactIdzookeeper/artifactId version3.8.3/version /dependency !-- Curator 客户端Spring Integration Zookeeper 内部已包含 -- dependency groupIdorg.springframework.integration/groupId artifactIdspring-integration-zookeeper/artifactId version6.1.0/version /dependency !-- Spring Boot Starter Test -- dependency groupIdorg.springframework.boot/groupId artifactIdspring-boot-starter-test/artifactId scopetest/scope /dependency注意Curator 是一组让 ZooKeeper 使用更简单的 Java 库。这里使用spring-integration-zookeeper依赖它内部已经封装了 Curator 客户端并提供了与 Spring 生态更好的集成方式。3. 配置文件application.ymlzookeeper: # 服务器地址 connectString: 127.0.0.1:2181 # 会话超时时间毫秒 sessionTimeoutMs: 3000 # 连接超时时间毫秒 connectionTimeoutMs: 60000 # 最大重试次数 maxRetries: 3 # 初始休眠时间毫秒 baseSleepTimeMs: 1000配置类 ZookeeperConfig.javaimport org.apache.curator.RetryPolicy; import org.apache.curator.framework.CuratorFramework; import org.apache.curator.framework.CuratorFrameworkFactory; import org.apache.curator.retry.ExponentialBackoffRetry; import org.springframework.beans.factory.annotation.Value; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import javax.annotation.PostConstruct; Configuration public class ZookeeperConfig { Value(${zookeeper.connectString}) private String connectString; Value(${zookeeper.baseSleepTimeMs}) private int baseSleepTimeMs; Value(${zookeeper.maxRetries}) private int maxRetries; Value(${zookeeper.connectionTimeoutMs}) private int connectionTimeoutMs; Value(${zookeeper.sessionTimeoutMs}) private int sessionTimeoutMs; private CuratorFramework client; /** 初始化 Curator 客户端 */ PostConstruct public void init() { // 重试策略基础休眠时间 1000ms最大重试 3 次 RetryPolicy retryPolicy new ExponentialBackoffRetry(baseSleepTimeMs, maxRetries); // 创建 CuratorFramework 实例 client CuratorFrameworkFactory.builder() .connectString(connectString) .connectionTimeoutMs(connectionTimeoutMs) .sessionTimeoutMs(sessionTimeoutMs) .retryPolicy(retryPolicy) .build(); // 开启连接 client.start(); } Bean public CuratorFramework curatorFramework() { return client; } }4. ZooKeeper 核心 API 实战示例下面通过单元测试演示常见的 ZooKeeper API 操作包括节点创建、数据读写、节点删除以及分布式读写锁的使用。import org.apache.curator.framework.CuratorFramework; import org.apache.curator.framework.recipes.locks.InterProcessReadWriteLock; import org.apache.zookeeper.CreateMode; import org.apache.zookeeper.data.Stat; import org.junit.jupiter.api.Test; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.context.SpringBootTest; import java.nio.charset.StandardCharsets; SpringBootTest public class ZookeeperApiTest { Autowired private CuratorFramework client; Test public void testCreate() throws Exception { // 创建一个持久化节点断开连接时不会自动删除 client.create() .creatingParentsIfNeeded() .withMode(CreateMode.PERSISTENT) .forPath(/path1); System.out.println(持久化节点 /path1 创建成功); } Test public void testExists() throws Exception { // 判断节点是否存在 Stat stat1 client.checkExists().forPath(/path1); System.out.println(/path1 是否存在: (stat1 ! null)); Stat stat2 client.checkExists().forPath(/path2); System.out.println(/path2 是否存在: (stat2 ! null)); } Test public void testSetData() throws Exception { // 设置节点数据 client.setData() .forPath(/path1, data1.getBytes(StandardCharsets.UTF_8)); System.out.println(节点 /path1 数据设置成功); } Test public void testCreateAndSet() throws Exception { // 创建一个持久化节点并设置节点数据 client.create() .creatingParentsIfNeeded() .withMode(CreateMode.PERSISTENT) .forPath(/path3, data3.getBytes(StandardCharsets.UTF_8)); System.out.println(持久化节点 /path3 创建并设置数据成功); } Test public void testGetData() throws Exception { // 查询节点数据 byte[] data client.getData().forPath(/path3); String dataStr new String(data, StandardCharsets.UTF_8); System.out.println(节点 /path3 的数据: dataStr); } Test public void testDelete() throws Exception { // 删除节点同时删除子节点 client.delete() .guaranteed() .deletingChildrenIfNeeded() .forPath(/path3); System.out.println(节点 /path3 删除成功); } Test public void testReadLock() throws Exception { // 读写锁 - 读锁 InterProcessReadWriteLock lock new InterProcessReadWriteLock(client, /lock-read); lock.readLock().acquire(); System.out.println(获取 ReadLock 成功); // 模拟读操作 Thread.sleep(1000); lock.readLock().release(); System.out.println(释放 ReadLock); } Test public void testWriteLock() throws Exception { // 读写锁 - 写锁 InterProcessReadWriteLock lock new InterProcessReadWriteLock(client, /lock-write); lock.writeLock().acquire(); System.out.println(获取 WriteLock 成功); // 模拟写操作 Thread.sleep(1000); lock.writeLock().release(); System.out.println(释放 WriteLock); } }5. 总结与最佳实践本文介绍了 Spring Boot 3 集成 ZooKeeper 的完整流程环境搭建ZooKeeper 服务端的配置、启动与基本命令操作。工程搭建Maven 依赖、配置文件与 Curator 客户端的初始化。API 使用通过单元测试演示了节点的增删改查以及分布式读写锁的应用。在实际项目中ZooKeeper 常用于实现分布式配置中心、分布式锁、服务注册与发现如 Dubbo、集群选主等场景。结合 Spring Boot 3 的自动配置与 Curator 的高级封装可以大大降低分布式协调的编码复杂度。注意事项生产环境建议使用 ZooKeeper 集群并配置合理的超时与重试参数。注意节点数据的序列化与反序列化方式避免中文乱码。使用分布式锁时务必在 finally 块中释放锁防止死锁。