利用redis来实现分布式锁。一般就用setnx和getset两个命令。
>* `NX`是`Not eXists`的缩写,如`SETNX`命令就应该理解为:`SET if Not eXists`.
>* `getset`是同步的
java之jedis实现
`expireMsecs` 锁持有超时,防止线程在入锁以后,无限的执行下去,让锁无法释放
`timeoutMsecs` 锁等待超时,防止线程饥饿,永远没有入锁执行代码的机会
代码如下:
```
private int timeoutMsecs
private String lockKey
private static long expireMsecs = 1000 * 60 * 5 // min 锁持有超时
// timeoutMsecs 表示锁等待超时
public JedisLock(Integer timeoutMsecs, String lockKey) {
this.timeoutMsecs = timeoutMsecs
this.lockKey = lockKey
}
public synchronized boolean acquire(Jedis jedis) throws InterruptedException {
int timeout = timeoutMsecs
while (timeout >= 0) {
long expires = System.currentTimeMillis() + expireMsecs + 1
String expiresStr = String.valueOf(expires) //锁到期时间
if (jedis.setnx(lockKey, expiresStr) == 1) {
return true
}
String currentValueStr = jedis.get(lockKey); //redis里的时间
// 表示已经锁失效,要重新设置锁
if (currentValueStr != null && Long.parseLong(currentValueStr) < System.currentTimeMillis()) {
//判断是否为空,不为空的情况下,如果被其他线程设置了值,则第二个条件判断是过不去的
// lock is expired
String oldValueStr = jedis.getSet(lockKey, expiresStr)
//获取上一个锁到期时间,并设置现在的锁到期时间,
//只有一个线程才能获取上一个线上的设置时间,因为jedis.getSet是同步的
if (oldValueStr != null && oldValueStr.equals(currentValueStr)) {
//如过这个时候,多个线程恰好都到了这里,但是只有一个线程的设置值和当前值相同,他才有权利获取锁
return true
}
}
timeout -= 100
Thread.sleep(100)
}
return false
}
```
所以大致的思路就是
>* 先定义好一个锁等待时间和锁超时时间,我们使用中分别设置了300ms和5min,
>* 线程执行进方法后,设置锁到期时间为当前时间加5分钟,就是`System.currentTimeMillis() + 1000*60*5 + 1`
>* 执行setnx,执行完返回1就是获取锁成功。返回0时,表示未获取到锁,执行下面一步
>* 判断是否已经锁到期,`currentValueStr`和当前时间比较,如果未过期,锁等待时间减100ms,sleep一下继续重复这个动作。如果已经到期,执行下面一步。
>* 通过`getSet`把redis中的锁超时时间设为自己的时间(因此自己要获取锁),这个方法是同步的。保证只能有个线程能拿到锁。执行这步返回的值是旧值,
>* 判断旧值和之前的锁超时的值是否一致。一致则获取锁成功。失败的话锁等待时间减1,sleep一下继续重复之前的逻辑。
再总结一下:
> 用最简单的办法就是,多个进程执行以下Redis命令:SETNX lock.foo
如果 SETNX 返回1,说明该进程获得锁,SETNX将键 lock.foo 的值设置为锁的超时时间(当前时间 + 锁的有效时间)。
如果 SETNX 返回0,说明其他进程已经获得了锁,进程不能进入临界区。进程可以在一个循环中不断地尝试 SETNX 操作,以获得锁。
但是这里有个问题,如何解决死锁,
> 考虑一种情况,如果进程获得锁后,断开了与 Redis 的连接(可能是进程挂掉,或者网络中断),如果没有有效的释放锁的机制,那么其他进程都会处于一直等待的状态,即出现“死锁”。
锁超时时,我们不能简单地使用 DEL 命令删除键 lock.foo 以释放锁。因为这样可能同时会有多个线程获得锁。
比如就是p2,p3两个进程同时发现锁已经超时。p2执行删除操作,添加自己的key,返回1,获取锁成功。接着p3又删除p2设置的值,自己获取锁。这样子显然是不行的。
为了解决上述算法可能出现的多个进程同时获得锁的问题,我们再来看以下的算法。
> 超时时我们可以这样处理。比如p4,p5发现超时之后,通过getset去更新key值,这个是同步的,能保证线程安全。然后根据getset返回的值是否大于当前时间来判断获取锁是否成功。如果小于当前时间,那获取成功。如果大于当前时间,说明已经有线程修改过了。再继续等待。
近期热议
推荐标签 标签
-
OpenStack
10 引用 • 5 关注
OpenStack 是一个云操作系统,通过数据中心可控制大型的计算、存储、网络等资源池。所有的管理通过前端界面管理员就可以完成,同样也可以通过 Web 接口让最终用户部署资源。
-
CentOS
238 引用 • 224 回帖 • 2 关注
CentOS(Community Enterprise Operating System)是 Linux 发行版之一,它是来自于 Red Hat Enterprise Linux 依照开放源代码规定释出的源代码所编译而成。由于出自同样的源代码,因此有些要求高度稳定的服务器以 CentOS 替代商业版的 Red Hat Enterprise Linux 使用。两者的不同在于 CentOS 并不包含封闭源代码软件。
-
导航
40 引用 • 173 回帖 • 1 关注
各种网址链接、内容导航。
-
RYMCU
4 引用 • 6 回帖 • 52 关注
RYMCU 致力于打造一个即严谨又活泼、专业又不失有趣,为数百万人服务的开源嵌入式知识学习交流平台。
-
开源中国
7 引用 • 86 回帖 • 1 关注
开源中国是目前中国最大的开源技术社区。传播开源的理念,推广开源项目,为 IT 开发者提供了一个发现、使用、并交流开源技术的平台。目前开源中国社区已收录超过两万款开源软件。
-
Markdown
167 引用 • 1513 回帖
Markdown 是一种轻量级标记语言,用户可使用纯文本编辑器来排版文档,最终通过 Markdown 引擎将文档转换为所需格式(比如 HTML、PDF 等)。
-
以太坊
34 引用 • 367 回帖 • 1 关注
以太坊(Ethereum)并不是一个机构,而是一款能够在区块链上实现智能合约、开源的底层系统。以太坊是一个平台和一种编程语言 Solidity,使开发人员能够建立和发布下一代去中心化应用。 以太坊可以用来编程、分散、担保和交易任何事物:投票、域名、金融交易所、众筹、公司管理、合同和知识产权等等。
- B3log
-
etcd
5 引用 • 26 回帖 • 530 关注
etcd 是一个分布式、高可用的 key-value 数据存储,专门用于在分布式系统中保存关键数据。
-
Java
3187 引用 • 8213 回帖
Java 是一种可以撰写跨平台应用软件的面向对象的程序设计语言,是由 Sun Microsystems 公司于 1995 年 5 月推出的。Java 技术具有卓越的通用性、高效性、平台移植性和安全性。
-
开源
408 引用 • 3575 回帖 • 1 关注
Open Source, Open Mind, Open Sight, Open Future!
-
Latke
71 引用 • 535 回帖 • 787 关注
Latke 是一款以 JSON 为主的 Java Web 框架。
-
ActiveMQ
19 引用 • 13 回帖 • 673 关注
ActiveMQ 是 Apache 旗下的一款开源消息总线系统,它完整实现了 JMS 规范,是一个企业级的消息中间件。
-
爬虫
106 引用 • 275 回帖 • 1 关注
网络爬虫(Spider、Crawler),是一种按照一定的规则,自动地抓取万维网信息的程序。
-
SendCloud
2 引用 • 8 回帖 • 483 关注
SendCloud 由搜狐武汉研发中心孵化的项目,是致力于为开发者提供高质量的触发邮件服务的云端邮件发送平台,为开发者提供便利的 API 接口来调用服务,让邮件准确迅速到达用户收件箱并获得强大的追踪数据。
-
LeetCode
209 引用 • 72 回帖 • 1 关注
LeetCode(力扣)是一个全球极客挚爱的高质量技术成长平台,想要学习和提升专业能力从这里开始,充足技术干货等你来啃,轻松拿下 Dream Offer!
-
RabbitMQ
49 引用 • 60 回帖 • 362 关注
RabbitMQ 是一个开源的 AMQP 实现,服务器端用 Erlang 语言编写,支持多种语言客户端,如:Python、Ruby、.NET、Java、C、PHP、ActionScript 等。用于在分布式系统中存储转发消息,在易用性、扩展性、高可用性等方面表现不俗。
-
Scala
13 引用 • 11 回帖 • 134 关注
Scala 是一门多范式的编程语言,集成面向对象编程和函数式编程的各种特性。
-
分享
248 引用 • 1794 回帖
有什么新发现就分享给大家吧!
-
OnlyOffice
4 引用 • 3 关注
-
DNSPod
6 引用 • 26 回帖 • 511 关注
DNSPod 建立于 2006 年 3 月份,是一款免费智能 DNS 产品。 DNSPod 可以为同时有电信、网通、教育网服务器的网站提供智能的解析,让电信用户访问电信的服务器,网通的用户访问网通的服务器,教育网的用户访问教育网的服务器,达到互联互通的效果。
-
OkHttp
16 引用 • 6 回帖 • 65 关注
OkHttp 是一款 HTTP & HTTP/2 客户端库,专为 Android 和 Java 应用打造。
-
OpenResty
17 引用 • 41 关注
OpenResty 是一个基于 NGINX 与 Lua 的高性能 Web 平台,其内部集成了大量精良的 Lua 库、第三方模块以及大多数的依赖项。用于方便地搭建能够处理超高并发、扩展性极高的动态 Web 应用、Web 服务和动态网关。
-
链滴
153 引用 • 3783 回帖 • 1 关注
链滴是一个记录生活的地方。
记录生活,连接点滴
-
GAE
14 引用 • 42 回帖 • 764 关注
Google App Engine(GAE)是 Google 管理的数据中心中用于 WEB 应用程序的开发和托管的平台。2008 年 4 月 发布第一个测试版本。目前支持 Python、Java 和 Go 开发部署。全球已有数十万的开发者在其上开发了众多的应用。
-
Maven
186 引用 • 318 回帖 • 304 关注
Maven 是基于项目对象模型(POM)、通过一小段描述信息来管理项目的构建、报告和文档的软件项目管理工具。
-
JVM
180 引用 • 120 回帖 • 2 关注
JVM(Java Virtual Machine)Java 虚拟机是一个微型操作系统,有自己的硬件构架体系,还有相应的指令系统。能够识别 Java 独特的 .class 文件(字节码),能够将这些文件中的信息读取出来,使得 Java 程序只需要生成 Java 虚拟机上的字节码后就能在不同操作系统平台上进行运行。
欢迎来到这里!
我们正在构建一个小众社区,大家在这里相互信任,以平等 • 自由 • 奔放的价值观进行分享交流。最终,希望大家能够找到与自己志同道合的伙伴,共同成长。
注册 关于