共计 1877 个字符，预计需要花费 5 分钟才能阅读完成。
在应用分布式锁进行互斥资源拜访时候，咱们很多计划是采纳 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 客户端的封装。