Zookeeper+Curator 分布式锁
2024-10-18 21:22:14
本来想着基于zk临时节点，实现一下分布式锁，结果发现有curator框架。PS：原声API真的难用，连递归创建path都没有？
配置curator maven的时候，md配置了好几个小时，最后发现集中定义依赖版本号 我本来都是写数字的，结果到了zookeeper.version ，我竟然写了 <zookeeper.version>zookeeper-3.4.7</zookeeper.version> 把英文也写上去了 可能是从maven-repository copy过来的 很郁闷。
curator提供的可重入分布式锁看起来也没什么可封装的，因为它和ReentrantLock确实很。在需要的地方，new一个，再调用对象的方法就好了。
这个锁就是 InterProcessMutex 类，其构造方法需要我们传入当前CuratorFramework对象，还有要锁定的节点。对了 这个节点是临时节点，再客户端断开连接后，锁不会一直存在，但也不会立即就失去锁，因为ZK需要根据缺省的时间判断你是真的断开了还是某种网络原因。
首先说明它是一把可重入锁。注意在当前线程的for循环中，他们都是用的是同一把锁，同把锁才可重入。
public void fun() {
ApplicationContext context = new ClassPathXmlApplicationContext("classpath:spring/applicationContext-curator.xml");
CuratorFramework curatorFramework = (CuratorFramework) context.getBean("curatorFramework");
InterProcessMutex lock = new InterProcessMutex(curatorFramework, "/test/ws");
for (int i = 0; i < 10; i++) {
try {
lock.acquire();
System.out.println("yes");
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
//lock.release();
} catch (Exception e) {
e.printStackTrace();
}
}
}
}
其次模拟分布式环境，在十个线程中各获取锁（锁相同的path），并执行1s的任务，可以发现，多线程被锁同步。
public void fun() throws Exception {
ApplicationContext context = new ClassPathXmlApplicationContext("classpath:spring/applicationContext-curator.xml");
CuratorFramework curatorFramework = (CuratorFramework) context.getBean("curatorFramework");
InterProcessMutex lock = new InterProcessMutex(curatorFramework, "/test/ws");
for (int i = 0; i < 10; i++) {
new Thread(new Runnable() {
@Override
public void run() {
try {
lock.acquire();
System.out.println("yes");
Thread.sleep(1000);
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
lock.release();
} catch (Exception e) {
e.printStackTrace();
}
}
}
}).start();
}
System.in.read();
}
acquire支持传递等待超时时间，返回值是boolean类型。代表超时时间内是否成功获取到锁。
public void fun() throws Exception {
ApplicationContext context = new ClassPathXmlApplicationContext("classpath:spring/applicationContext-curator.xml");
CuratorFramework curatorFramework = (CuratorFramework) context.getBean("curatorFramework");
System.out.println(curatorFramework);
InterProcessMutex lock = new InterProcessMutex(curatorFramework, "/test/ws");
for (int i = 0; i < 10; i++) {
new Thread(new Runnable() {
@Override
public void run() {
try {
if (lock.acquire(1000, TimeUnit.MILLISECONDS)) {
System.out.println("yes");
Thread.sleep(1000);
} else {
System.out.println("no");
}
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
lock.release();
} catch (Exception e) {
e.printStackTrace();
}
}
}
}).start();
}
System.in.read();
}
最后附上spring配置：
<!-- 重连配置 -->
<bean id="retryPolicy" class="org.apache.curator.retry.ExponentialBackoffRetry">
<constructor-arg index="0" value="1000"/>
<constructor-arg index="1" value="3"/>
</bean> <bean id="curatorFramework" class="org.apache.curator.framework.CuratorFrameworkFactory" factory-method="newClient"
init-method="start">
<constructor-arg index="0" value="server:port,server:port,server:port"/>
<constructor-arg index="1" ref="retryPolicy"/>
</bean>
最新文章
- C#测试题
- Mac/IOS/linux获取当前时间包含微秒毫秒的代码
- 项目在vs中打开后识别不出来ashx页面的解决方法
- TortoiseSVN文件夹及文件图标不显示解决方法
- 【转】windows消息和消息队列详解
- Rhel6-torque作业调度系统配置文档
- linux下配置环境变量【原创】
- 伪类选择器:root的妙用
- 【查找结构4】红黑树 [RBT]
- Mysql数据库的索引原理
- SVM(支持向量机)（二）—Lagrange Duality（拉格朗日对偶问题）
- AS中layout_gravity与gravity的区别
- TCP 详解
- Nginx - 配置 SSL证书
- Linux系统管理常用命令用法总结（1）
- browsersync
- Mybatis源码分析之Cache一级缓存原理（四）
- JAVA中使用Apache HttpComponents Client的进行GET/POST请求使用案例
- 1009 Product of Polynomials （25 分）
- android如何改变应用程序安装后显示的图标