zookeeper学习(九)

版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/qq_27399407/article/details/86577173
  • zk实现分布式锁的原理
      利用zk的节点特性:临时有序节点。当zookeeper客户端需要抢夺某个资源时,会先在/locker节点下创建临时有序节点,通过监听比自己序号次小的节点的删除事件,来进行一些逻辑,判断自己的节点是否为/locker所有子节点中序号最小的,如果是那么就使用资源,使用完之后,再释放资源删除对应节点。如下图:
    在这里插入图片描述
      原理流程图:
    在这里插入图片描述
  • Curator实现分布式锁的实践
      使用curator来实现相对简单的多,代码如下:
 @Test
    public void client1() throws Exception {
        for (Integer i = 0; i < 10; i++) {
            new Thread(() -> {
                try {
                    testLock(Thread.currentThread().getName());
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }).start();
        }

        TimeUnit.MINUTES.sleep(5);
    }

    private void testLock(String clientId) throws Exception {
        //创建zookeeper的客户端
        RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 3);

        CuratorFramework client = CuratorFrameworkFactory.newClient(CONNECTION_STRING, retryPolicy);

        client.start();

        //创建分布式锁, 锁空间的根节点路径为/curator/lock
        InterProcessMutex mutex = new InterProcessMutex(client, "/curator/lock");

        mutex.acquire();

        //获得了锁, 进行业务流程
        System.out.println(clientId + "获取到锁,开始执行逻辑。。。");
        TimeUnit.SECONDS.sleep(10);

        //完成业务流程, 释放锁
        mutex.release();
        //关闭客户端

        client.close();
    }

执行结果:
在这里插入图片描述

猜你喜欢

转载自blog.csdn.net/qq_27399407/article/details/86577173