基于ZooKeeper实现分布式锁（Spring Boot接入）及与Kafka实现的对比分析

在分布式系统中，多节点对共享资源的并发访问往往会引发数据一致性问题，分布式锁正是解决这一问题的核心组件。本文将从原理出发，详细讲解基于ZooKeeper实现分布式锁的完整流程，提供Spring Boot接入的可运行代码，并深入对比其与Kafka实现分布式锁的异同点及优缺点，帮助开发者根据业务场景做出合适选择。

一、ZooKeeper分布式锁的实现原理

ZooKeeper能实现分布式锁，核心依赖其树形节点结构、Watcher监听机制和临时顺序节点特性，这三大特性共同保证了锁的安全性、可用性和自动释放能力。

1.1 核心特性依赖

• 临时节点（Ephemeral Node）：客户端与ZooKeeper集群建立的会话（Session）断开时，临时节点会被自动删除。这一特性从根本上避免了“客户端崩溃后锁无法释放”的死锁问题——即使持有锁的服务宕机，会话失效后锁节点也会自动清理。
• 顺序节点（Sequential Node）：当客户端创建顺序节点时，ZooKeeper会在节点名称后自动追加一个全局唯一的递增序号（如lock-0000000001、lock-0000000002）。通过序号大小，可天然实现“排队抢锁”的逻辑，避免多个客户端同时争抢锁。
• Watcher监听机制：客户端可对指定节点注册监听，当节点发生“创建/删除/数据修改”等事件时，ZooKeeper会主动通知客户端。基于此，未抢到锁的客户端无需轮询等待，只需监听前一个顺序节点的删除事件，实现“按需唤醒”，减少资源浪费。

1.2 锁的核心流程（公平锁实现）

基于上述特性，ZooKeeper分布式锁的实现遵循“创建节点→判断排序→监听等待→释放锁”的闭环流程，具体步骤如下：

1. 初始化锁节点：提前在ZooKeeper中创建一个持久化的根节点（如/distributed-lock），作为所有分布式锁的父节点（持久化节点确保服务重启后父节点不丢失）。
2. 客户端抢锁：当客户端需要获取锁时，在根节点下创建一个临时顺序子节点（如/distributed-lock/lock-），ZooKeeper会自动为其追加序号，最终节点名称如/distributed-lock/lock-0000000003。
3. 判断是否获锁：客户端创建节点后，查询根节点下所有的临时顺序子节点，并按序号从小到大排序。若当前客户端创建的节点是序号最小的节点，则直接获取锁；若不是，则说明有其他客户端正在持有锁。
4. 监听前序节点：未获锁的客户端，找到当前节点的“前一个序号节点”（如当前节点是lock-0000000003，则前序节点是lock-0000000002），并为前序节点注册“节点删除”的Watcher监听。之后客户端进入等待状态，直到监听到前序节点被删除。
5. 唤醒与重试：当持有锁的客户端释放锁（主动删除自身节点或会话断开导致节点自动删除）时，前序节点被删除，ZooKeeper会通知监听该节点的客户端。客户端被唤醒后，重复步骤3（重新查询所有子节点并判断自身是否为最小节点），直至获取锁。
6. 释放锁：客户端完成业务逻辑后，主动删除自身创建的临时顺序节点，释放锁；若客户端宕机或会话超时，ZooKeeper会自动删除节点，实现锁的“被动释放”。

二、Spring Boot接入ZooKeeper分布式锁的完整代码

在Spring Boot项目中，我们通常使用curator-framework（Apache Curator）作为ZooKeeper的客户端框架——Curator已封装了分布式锁的核心逻辑（如InterProcessMutex类），避免重复造轮子，同时解决了原生ZooKeeper客户端的“Watcher一次性触发”“会话重连”等问题。

2.1 步骤1：引入依赖

在pom.xml中添加Spring Boot Starter和Curator依赖（Curator需匹配ZooKeeper版本，此处以ZooKeeper 3.8.x为例）：

<!-- Spring Boot基础依赖 -->
<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>2.7.10</version>
    <relativePath/>
</parent>

<dependencies>
    <!-- Spring Boot Web（用于模拟业务接口） -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>

    <!-- Curator（ZooKeeper客户端框架，含分布式锁实现） -->
    <dependency>
        <groupId>org.apache.curator</groupId>
        <artifactId>curator-recipes</artifactId>
        <version>5.4.0</version>
        <!-- 排除自带的ZooKeeper依赖，避免版本冲突 -->
        <exclusions>
            <exclusion>
                <groupId>org.apache.zookeeper</groupId>
                <artifactId>zookeeper</artifactId>
            </exclusion>
        </exclusions>
    </dependency>

    <!-- ZooKeeper客户端核心依赖 -->
    <dependency>
        <groupId>org.apache.zookeeper</groupId>
        <artifactId>zookeeper</artifactId>
        <version>3.8.1</version>
        <!-- 解决ZooKeeper 3.8.x的SLF4J日志冲突 -->
        <exclusions>
            <exclusion>
                <groupId>org.slf4j</groupId>
                <artifactId>slf4j-log4j12</artifactId>
            </exclusion>
        </exclusions>
    </dependency>

    <!-- 工具类依赖（用于日志和JSON处理） -->
    <dependency>
        <groupId>cn.hutool</groupId>
        <artifactId>hutool-all</artifactId>
        <version>5.8.20</version>
    </dependency>
</dependencies>

2.2 步骤2：配置ZooKeeper客户端

通过Spring Boot配置类，初始化Curator的CuratorFramework客户端（单例模式，避免重复创建连接）：

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;

@Configuration
public class ZkConfig {
   
   

    // 从配置文件读取ZooKeeper集群地址（如127.0.0.1:2181,127.0.0.1:2182）