0


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


本文转载自: https://blog.csdn.net/qq_43649937/article/details/135537055
版权归原作者 山河亦问安 所有, 如有侵权,请联系我们删除。

“Zookeeper实现分布式锁”的评论:

还没有评论