Zookeeper实现分布式锁

ZooKeeper是一个分布式协调服务，其中提供的序列化、持久化、有层次的目录结构使得它非常适合用于实现分布式锁。在ZooKeeper中，分布式锁通常通过临时有序节点实现。以下是ZooKeeper分布式锁的详细介绍：

?实现方式：

• 临时有序节点：

  • 当一个客户端需要获取锁时，它在ZooKeeper上创建一个临时有序节点，节点的名称包含一个自增的序列号。
  • 客户端创建节点的过程相当于尝试获取锁。

• 锁竞争：

  • 客户端创建节点后，检查它是否是当前目录中最小的节点，如果是，则表示它获取了锁。
  • 如果不是最小的节点，客户端监听上一个节点，等待上一个节点释放锁。

• 锁释放：

  • 当客户端不再需要锁时，它删除相应的节点，其他等待的客户端会收到通知，重新尝试获取锁。

本篇文章基于Redis之高并发超卖问题解决方案_redis解决超卖 高并发-CSDN博客，在尝试使用redisson实现分布式锁后，这里尝试使用zookeeper实现分布式锁。

?代码如下：

导入依赖：

        <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>

秒杀接口测试：

在redis中设计product_1:200

@RestController
public class MyController {
  

    private static InterProcessMutex lock; //可重入锁

    @PostConstruct
    public void init(){
        RetryPolicy retry = new ExponentialBackoffRetry(3000,10);
        CuratorFramework curatorFramework = CuratorFrameworkFactory.builder()
                .connectString("localhost:2181")
                .retryPolicy(retry)
                .build();
        curatorFramework.start();
         lock= new InterProcessMutex(curatorFramework, "/lock");

    }

    @RequestMapping("/buy/{id}")
    public String buy(@PathVariable("id") Long id){
        String message="error";
        String key="product_" + id;
        //try catch 设计是为了防止在执行业务的时候出现异常导致redis锁一直无法释放
        try {
            //加锁
            lock.acquire();
            int count = Integer.parseInt(stringRedisTemplate.opsForValue().get(key));
            if (count > 0) {
                stringRedisTemplate.opsForValue().set(key, String.valueOf(--count));
                System.out.println(key + "商品购买成功，剩余库存" + count);
                message="success";
            }
        }catch (Throwable e){
            e.printStackTrace();
        }finally {
            try {
                //解锁
                lock.release();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
        if(message.equals("error"))
            System.out.println(key+"商品库存不足");
        return message;
    }
}

jmeter压测结果如下：

?