zookeeper中怎么实现分布式锁，很多新手对此不是很清楚，为了帮助大家解决这个难题，下面小编将为大家详细讲解，有这方面需求的人可以来学习下，希望你能有所收获。
利用zk的临时有序节点机制实现分布式锁
zk节点的四种类型：持久节点、持久顺序节点、临时节点、临时顺序节点。
计算
安全
数据库
网络和加速
企业服务
package com.lau.distributed.lock;
/**
* @ClassName: FakeLimitedResource
* @Description: TODO
* @author Liu
* @date 2021年4月17日 下午9:30:14
*/
public class FakeLimitedResource {
private Integer ticket = 250;
public void use(){
System.out.println("分布式锁-线程：" + Thread.currentThread().getName() + "卖了1张票，火车票还剩：" + (--ticket) + "张");
}
}package com.lau.distributed.lock;
import java.util.concurrent.TimeUnit;
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.recipes.locks.InterProcessMutex;
/**
* @ClassName: ExampleClientThatLocks
* @Description: TODO
* @author Liu
* @date 2021年4月17日 下午9:56:32
*/
public class ExampleClientThatLocks {
//锁对象
private final InterProcessMutex lock;
//火车票共享资源
private final FakeLimitedResource resource;
//客户端名称
private final String clientName;
public ExampleClientThatLocks(CuratorFramework client, String lockPath, FakeLimitedResource resource, String clientName) {
this.resource = resource;
this.clientName = clientName;
lock = new InterProcessMutex(client, lockPath);
}
public void doWork(long time, TimeUnit unit) throws Exception{
//尝试获取锁，过时不候（超时机制）
if(!lock.acquire(time, unit)) {
throw new IllegalStateException(clientName + "could not acquire the lock!");
}
try {
System.out.println(clientName + " has acquired the lock!");
resource.use();
}
finally {
System.out.println(clientName + " has released the lock!");
lock.release();
}
}
}package com.lau.distributed.lock;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.retry.ExponentialBackoffRetry;
/**
* @ClassName: LockingExample
* @Description: TODO
* @author Liu
* @date 2021年4月17日 下午9:49:44
*/
public class LockingExample{
private static final int QTY = 5;
private static final int PERMISSIONS = 50;
private static final String CONNECTION_HOST = "192.168.1.106:2181";
private static final String PATH = "/lock";
public static void main(String[] args){
//模拟火车票一次只能由一个进程访问
final FakeLimitedResource resource = new FakeLimitedResource();
//定义默认初始化有5个线程的线程池
ExecutorService service = Executors.newFixedThreadPool(QTY);
try{
for(int i = 0; i < QTY; i++){
final int index = i;
Callable<Void> task = new Callable<Void>(){
public Void call() throws Exception{
//获取zk集群连接
CuratorFramework client = CuratorFrameworkFactory.newClient(CONNECTION_HOST,
new ExponentialBackoffRetry(1000, 3, Integer.MAX_VALUE));
try{
client.start();
ExampleClientThatLocks example = new ExampleClientThatLocks(client, PATH, resource, "client" + index);
//模拟一个线程卖50张票
for(int j = 0; j < PERMISSIONS; j++){
example.doWork(10, TimeUnit.SECONDS);
}
}
catch(Exception ex){
ex.printStackTrace();
}
finally{
// ClosableUtils.closeQuietly(client);
client.close();
}
return null;
}
};
service.submit(task);
}
service.shutdown();
service.awaitTermination(10, TimeUnit.MINUTES);
}
catch(Exception ex){
}
}
}<dependencies>
<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.zookeeper</groupId>
<artifactId>zookeeper</artifactId>
<version>3.4.10</version>
</dependency>
</dependencies>
client2 has acquired the lock!
分布式锁-线程：pool-1-thread-3卖了1张票，火车票还剩：50张
client2 has released the lock!
client3 has acquired the lock!
分布式锁-线程：pool-1-thread-4卖了1张票，火车票还剩：49张
client3 has released the lock!
client1 has acquired the lock!
分布式锁-线程：pool-1-thread-2卖了1张票，火车票还剩：48张
client1 has released the lock!
client4 has acquired the lock!
分布式锁-线程：pool-1-thread-5卖了1张票，火车票还剩：47张
client4 has released the lock!
client0 has acquired the lock!
分布式锁-线程：pool-1-thread-1卖了1张票，火车票还剩：46张
client0 has released the lock!
client2 has acquired the lock!
分布式锁-线程：pool-1-thread-3卖了1张票，火车票还剩：45张
client2 has released the lock!
client3 has acquired the lock!
分布式锁-线程：pool-1-thread-4卖了1张票，火车票还剩：44张
client3 has released the lock!
client1 has acquired the lock!
分布式锁-线程：pool-1-thread-2卖了1张票，火车票还剩：43张
client1 has released the lock!
client4 has acquired the lock!
分布式锁-线程：pool-1-thread-5卖了1张票，火车票还剩：42张
client4 has released the lock!
client0 has acquired the lock!
分布式锁-线程：pool-1-thread-1卖了1张票，火车票还剩：41张
client0 has released the lock!
client2 has acquired the lock!
分布式锁-线程：pool-1-thread-3卖了1张票，火车票还剩：40张
client2 has released the lock!
client3 has acquired the lock!
分布式锁-线程：pool-1-thread-4卖了1张票，火车票还剩：39张
client3 has released the lock!
client1 has acquired the lock!
分布式锁-线程：pool-1-thread-2卖了1张票，火车票还剩：38张
client1 has released the lock!
client4 has acquired the lock!
分布式锁-线程：pool-1-thread-5卖了1张票，火车票还剩：37张
client4 has released the lock!
client0 has acquired the lock!
分布式锁-线程：pool-1-thread-1卖了1张票，火车票还剩：36张
client0 has released the lock!
client2 has acquired the lock!
分布式锁-线程：pool-1-thread-3卖了1张票，火车票还剩：35张
client2 has released the lock!
client3 has acquired the lock!
分布式锁-线程：pool-1-thread-4卖了1张票，火车票还剩：34张
client3 has released the lock!
client1 has acquired the lock!
分布式锁-线程：pool-1-thread-2卖了1张票，火车票还剩：33张
client1 has released the lock!
client4 has acquired the lock!
分布式锁-线程：pool-1-thread-5卖了1张票，火车票还剩：32张
client4 has released the lock!
client0 has acquired the lock!
分布式锁-线程：pool-1-thread-1卖了1张票，火车票还剩：31张
client0 has released the lock!
client2 has acquired the lock!
分布式锁-线程：pool-1-thread-3卖了1张票，火车票还剩：30张
client2 has released the lock!
client3 has acquired the lock!
分布式锁-线程：pool-1-thread-4卖了1张票，火车票还剩：29张
client3 has released the lock!
client1 has acquired the lock!
分布式锁-线程：pool-1-thread-2卖了1张票，火车票还剩：28张
client1 has released the lock!
client4 has acquired the lock!
分布式锁-线程：pool-1-thread-5卖了1张票，火车票还剩：27张
client4 has released the lock!
client0 has acquired the lock!
分布式锁-线程：pool-1-thread-1卖了1张票，火车票还剩：26张
client0 has released the lock!
client2 has acquired the lock!
分布式锁-线程：pool-1-thread-3卖了1张票，火车票还剩：25张
client2 has released the lock!
client3 has acquired the lock!
分布式锁-线程：pool-1-thread-4卖了1张票，火车票还剩：24张
client3 has released the lock!
client1 has acquired the lock!
分布式锁-线程：pool-1-thread-2卖了1张票，火车票还剩：23张
client1 has released the lock!
client4 has acquired the lock!
分布式锁-线程：pool-1-thread-5卖了1张票，火车票还剩：22张
client4 has released the lock!
client0 has acquired the lock!
分布式锁-线程：pool-1-thread-1卖了1张票，火车票还剩：21张
client0 has released the lock!
client2 has acquired the lock!
分布式锁-线程：pool-1-thread-3卖了1张票，火车票还剩：20张
client2 has released the lock!
client3 has acquired the lock!
分布式锁-线程：pool-1-thread-4卖了1张票，火车票还剩：19张
client3 has released the lock!
client1 has acquired the lock!
分布式锁-线程：pool-1-thread-2卖了1张票，火车票还剩：18张
client1 has released the lock!
client4 has acquired the lock!
分布式锁-线程：pool-1-thread-5卖了1张票，火车票还剩：17张
client4 has released the lock!
client0 has acquired the lock!
分布式锁-线程：pool-1-thread-1卖了1张票，火车票还剩：16张
client0 has released the lock!
client2 has acquired the lock!
分布式锁-线程：pool-1-thread-3卖了1张票，火车票还剩：15张
client2 has released the lock!
client3 has acquired the lock!
分布式锁-线程：pool-1-thread-4卖了1张票，火车票还剩：14张
client3 has released the lock!
client1 has acquired the lock!
分布式锁-线程：pool-1-thread-2卖了1张票，火车票还剩：13张
client1 has released the lock!
client4 has acquired the lock!
分布式锁-线程：pool-1-thread-5卖了1张票，火车票还剩：12张
client4 has released the lock!
client0 has acquired the lock!
分布式锁-线程：pool-1-thread-1卖了1张票，火车票还剩：11张
client0 has released the lock!
client2 has acquired the lock!
分布式锁-线程：pool-1-thread-3卖了1张票，火车票还剩：10张
client2 has released the lock!
client3 has acquired the lock!
分布式锁-线程：pool-1-thread-4卖了1张票，火车票还剩：9张
client3 has released the lock!
client1 has acquired the lock!
分布式锁-线程：pool-1-thread-2卖了1张票，火车票还剩：8张
client1 has released the lock!
client4 has acquired the lock!
分布式锁-线程：pool-1-thread-5卖了1张票，火车票还剩：7张
client4 has released the lock!
client0 has acquired the lock!
分布式锁-线程：pool-1-thread-1卖了1张票，火车票还剩：6张
client0 has released the lock!
client2 has acquired the lock!
分布式锁-线程：pool-1-thread-3卖了1张票，火车票还剩：5张
client2 has released the lock!
client3 has acquired the lock!
分布式锁-线程：pool-1-thread-4卖了1张票，火车票还剩：4张
client3 has released the lock!
client1 has acquired the lock!
分布式锁-线程：pool-1-thread-2卖了1张票，火车票还剩：3张
client1 has released the lock!
client4 has acquired the lock!
分布式锁-线程：pool-1-thread-5卖了1张票，火车票还剩：2张
client4 has released the lock!
client0 has acquired the lock!
分布式锁-线程：pool-1-thread-1卖了1张票，火车票还剩：1张
client0 has released the lock!
client2 has acquired the lock!
分布式锁-线程：pool-1-thread-3卖了1张票，火车票还剩：0张
client2 has released the lock!看完上述内容是否对您有帮助呢？如果还想对相关知识有进一步的了解或阅读更多相关文章，请关注亿速云行业资讯频道，感谢您对亿速云的支持。
亿速云「云服务器」，即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘，价格低至29元/月。点击查看>>
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
原文链接：https://my.oschina.net/Howard2016/blog/5022947
