在应用分布式锁进行互斥资源拜访时候,咱们很多计划是采纳redis的实现。
诚然,redis的单节点锁在极其状况也是有问题的,假如你的业务容许偶然的生效,应用单节点的redis锁计划就足够了,简略而且效率高。
redis锁生效的状况:

客户端1从master节点获取了锁

master宕机了,存储锁的key还没来得及同步到slave节点上

slave降级为master

客户端2从新的master上获取到同一个资源的锁

于是,客户端1和客户端2共事持有了同一个资源的锁,锁的安全性被突破。
如果咱们不思考站长博客这种极其状况,须要实现一个基于单节点redis锁的大抵流程:

set cache_key random_seed NX PX 30000

下面这个set命令拆解开就是:

setnx cache_key random_seed expire cache_key 30

尽管这两组命令执行的成果一样,然而第二个是非原子性操作,如果执行了setnx胜利,然而expire失败的话,就会造成这个key始终存在了,无奈开释的状况。

redis的作者也指出,在应用单节点redis锁的时候,设置一个随机种子作为key的值是很有必要的,保障了一个客户端开释的锁必须是本人所持有的那个锁。假如获取锁时set的不是一个随机数,而是一个固定值,那么可能会呈现上面的状况:

客户端1获取锁胜利

客户端1在某个操作上阻塞了很长时间

过期工夫到了,锁主动开释(然而在客户端1看来本人还是持有锁中)

客户端2获取到了对应同一个资源的锁

客户端1从阻塞中复原了,开释掉本人持有的锁,也就是开释掉了客户端2持有的锁

客户端2的锁被客户端1是否,失去安全性。
开释锁的操作,很多人间接用del命令,这会有很大的问题,保障不了这个key是被加锁人锁删。这时候须要用到随机数了。开释锁的操作有三步:

get 所持有锁

判断这个锁是否本人所持有

删除持有锁

所以,这三步要保障原子性。用lua脚本来执行,redis官网曾经提供脚本文件。

if redis.call("get",KEYS[1]) == ARGV[1] then

return redis.call("del",KEYS[1])else

return 0end

这段脚本在执行的时候,须要把后面的随机数作为argv[1] 的值传进去,把cache_key作为keys[1]的值传进去。

public class RedisLockHelper {

@Resource

private R2mClusterClient r2mClusterClient;

/**

  • 相似于setNx的性能,同时设置过期工夫为expire毫秒

*

  • @param key    加锁key
  • @param value  确保在加锁工夫内的惟一因子
  • @param expire 过期工夫的毫秒数
  • @return

*/

private String setLock(String key, String value, long expire) {

return this.set(key, value, "NX", "PX", expire);

}

/**

  • 删除指定key value
  • 如果 r2m中 key 对应的value==value   返回 1
  • 如果 r2m中 key 对应的value!=value   返回 0

*

  • @param key
  • @return

*/

private boolean atomDelete(String key, String value) {

List<String> values = new ArrayList<>();

values.add(value);

String sb = "if redis.call('get',KEYS[1])==ARGV[1] then " +

" return redis.call('del',KEYS[1]) " +

" else " +

" return 0" +

" end";

if (this.eval(sb, key, values) == 1) {

return true;

}

return false;

}

private Long eval(String mobel, String key, List<String> value) {

return (Long) this.r2mClusterClient.eval(mobel, key, value);

}

private String set(String key, String value, String nxxx, String expx, long time) {

return this.r2mClusterClient.set(key, value, nxxx, expx, time);

}

}

r2mClusterClient 就是jedis客户端的封装。