使用ZooKeeper回调函数实现分布式锁_回调可以加锁吗

本文只是实现了一种最基本的分布式锁，用于学习和理解。具体使用时，各框架都有相应的实现，直接使用即可。

代码结构

pom.xml中的依赖和下面util包下的两个类，可以从另一篇文章中获取（https://editor.csdn.net/md/?articleId=114507459）

废话不多说，直接上代码

package com.myspringboot.zookeeper.lock;


import com.myspringboot.zookeeper.util.ZKUtils;
import org.apache.zookeeper.ZooKeeper;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;

/**
 * 测试类
 */
public class LockTest {
   
    ZooKeeper zooKeeper;

    @Before
    public void conn() {
   
        zooKeeper = ZKUtils.getZK();
    }

    @After
    public void close() {
   
        try {
   
            zooKeeper.close();
        } catch (InterruptedException e) {
   
            e.printStackTrace();
        }
    }

    @Test
    public void testLock() {
   
        for (int i = 0; i < 10; i++) {
   
            new Thread() {
   
                @Override
                public void run() {
   
                    String threadName = Thread.currentThread().getName();
                    WatcherCallback watcherCallback = new WatcherCallback();
                    watcherCallback.setZooKeeper(zooKeeper
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46