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> <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压测结果如下：
