分布式锁是控制分布式系统之间同步访问共享资源的一种方式。在分布式系统中,常常需要协调他们的动作。如果不同的系统或是同一个系统的不同主机之间共享了一个或一组资源,那么访问这些资源的时候,往往需要互斥来防止彼此干扰来保证一致性,在这种情况下,便需要使用到分布式锁。
分布式锁一般有三种实现方式:
1,数据库乐观锁;
2,基于复述的分布式锁;
3,基于管理员的分布式锁。
本文将介绍第二种方式,基于复述,实现分布式锁。虽然网上已经有各种介绍复述分布式锁实现的博客,然而他们的实现却有着各种各样的问题,为了避免误人子弟,本篇博客将详细介绍如何正确地实现复述分布式锁。
首先,为了确保分布式锁可用,我们至少要确保锁的实现同时满足以下四个条件:
1,互斥性。在任意时刻,只有一个客户端能持有锁。
2,不会发生死锁。即使有一个客户端在持有锁的期间崩溃而没有主动解锁,也能保证后续其他客户端能加锁。
3,具有容错性。只要大部分的复述,节点正常运行,客户端就可以加锁和解锁。
4,解铃还须系铃人。加锁和解锁必须是同一个客户端,客户端自己不能把别人加的锁给解了。
公共类RedisTool { 私有静态最终字符串LOCK_SUCCESS=癘K"; 私有静态最终字符串SET_IF_NOT_EXIST=癗X"; 私有静态最终字符串SET_WITH_EXPIRE_TIME=癙X";/* * *尝试获取分布式锁 * @param能复述,客户端 * @param lockKey锁 * @param requestId请求标识 * @param expireTime超期时间 * @return是否获取成功 */lockKey公共静态布尔tryGetDistributedLock(能能,字符串,字符串requestId, int expireTime) {=能字符串结果。集(lockKey、requestId SET_IF_NOT_EXIST、SET_WITH_EXPIRE_TIME expireTime); 如果(LOCK_SUCCESS.equals(结果)){ 返回true; } 返回错误; } }
可以看的到,我们加锁就一行代码:能。集(nxxx字符串键,字符串值,字符串,字符串expx, int),这个组()方法一共有五个形参:
第一个为关键,我们使用键来当锁,因为关键是唯一的。
第二个为价值,我们传的是requestId,很多童鞋可能不明白,有关键作为锁不就够了吗,为什么还要用到价值?原因就是我们在上面讲到可靠性时,分布式锁要满足第四个条件解铃还须系铃人,通过给值赋值为requestId,我们就知道这把锁是哪个请求加的了,在解锁的时候就可以有依据.requestId可以使用UUID.randomUUID () .toString()方法生成。
第三个为nxxx,这个参数我们填的是NX,意思是如果不存在,即当关键不存在时,我们进行设置操作,若钥匙已经存在,则不做任何操作,
第四个为expx,这个参数我们传的是PX,意思是我们要给这个键加一个过期的设置,具体时间由第五个参数决定。
第五个为一次,与第四个参数相呼应,代表关键的过期时间。
总的来说,执行上面组的()方法就只会导致两种结果:1。当前没有锁(关键不存在),那么就进行加锁操作,并对锁设置个有效期,同时价值表示加锁的客户端。2。已有锁存在,不做任何操作。
心细的童鞋就会发现了,我们的加锁代码满足我们可靠性里描述的三个条件:
1,首先,设置()加入了NX参数,可以保证如果已有关键存在,则函数不会调用成功,也就是只有一个客户端能持有锁,满足互斥性。
2,其次,由于我们对锁设置了过期时间,即使锁的持有者后续发生崩溃而没有解锁,锁也会因为到了过期时间而自动解锁(即键被删除),不会发生死锁。
3,最后,因为我们将值赋值为requestId,代表加锁的客户端请求标识,那么在客户端在解锁的时候就可以进行校验是否是同一个客户端。由于我们只考虑复述,单机部署的场景,所以容错性我们暂不考虑。
<强>错误示例1
比较常见的错误示例就是使用jedis.setnx()和jedis.expire()组合实现加锁,代码如下:
