7.21 杭州源创会火热报名中,一起来看看移动开发如何紧跟浪潮?
Watch Star Fork

程序猿DD / consul-distributed-lockJavaApache-2.0

加入码云
与超过 300 万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
基于consul的分布式锁工具,包含:互斥锁、信号量等工具
取消
提示: 由于 Git 不支持空文件夾,创建文件夹后会生成空的 .keep 文件
Loading...
README.md 2.55 KB

#基于Consul的分布式锁工具

在构建分布式系统的时候,我们经常需要控制对共享资源的访问。这个时候我们就涉及到分布式锁(也称为全局锁)的实现,本项目将基于Consul的KV存储来实现一套Java的分布式锁小工具,以帮助简化分布式环境下的同步操作。

基本原理

本工具实现的基本原理可以参见下面两篇博客:

注意:这两篇博文仅描述了基本的实现流程,但未实现针对一些异常情况的锁和信号量清理,以解决出现死锁的情况,同时也为锁操作增加了一些其他情况的使用设置。

使用方法

目前该工具实现了两个小功能:分布式互斥锁和信号量。

分布式互斥锁

ConsulClient consulClient = new ConsulClient("localhost", 8500);	// 创建与Consul的连接
CheckTtl checkTtl = new CheckTtl("checkId", consulClient); // session的健康检查,用来清理失效session占用的锁
Lock lock = new Lock(consulClient, "lockKey", checkTtl);
try {
	// 获取分布式互斥锁
  	// 参数含义:是否使用阻塞模式、每次尝试获取锁的间隔500ms、尝试n次
    if (lock.lock(true, 500L, null)) {     	
        // TODO 处理业务逻辑
    } 
catch (Exception e) {
    e.printStackTrace();
} finally {
    lock.unlock();
}

分布式信号量

ConsulClient consulClient = new ConsulClient("localhost", 8500);	// 创建与Consul的连接
CheckTtl checkTtl = new CheckTtl("checkId", consulClient); // session的健康检查,用来清理失效session占用的锁
Semaphore semaphore = new Semaphore(consulClient, 3, "lockKey", checkTtl); // 3为信号量的值
try {
	if (semaphore.acquired(true)) {
    	// TODO 获取到信号量,执行业务逻辑
	}
} catch (Exception e) {
    e.printStackTrace();
} finally {
    try {
		// 信号量释放
		semaphore.release();
	} catch (IOException e) {
    	e.printStackTrace();
    }
}

持续优化ing

我的博客:http://blog.didispace.com

我的公众号:

输入图片说明

我的新书:

输入图片说明

项目点评 ( 1 )

你可以在登录后,发表评论

11_float_left_people 11_float_left_close