基于redis的分布式锁详解

在使用分布式锁进行互斥资源访问时候，咱们不少方案是采用redis的实现。
当然，redis的单节点锁在极端状况也是有问题的，假设你的业务容许偶尔的失效，使用单节点的redis锁方案就足够了，简单并且效率高。
redis锁失效的状况：php

客户端1从master节点获取了锁
master宕机了，存储锁的key还没来得及同步到slave节点上
slave升级为master
客户端2重新的master上获取到同一个资源的锁

因而，客户端1和客户端2同事持有了同一个资源的锁，锁的安全性被打破。
若是咱们不考虑这种极端状况，须要实现一个基于单节点redis锁的大体流程：laravel

set cache_key random_seed NX PX 30000

上面这个set命令拆解开就是：面试

setnx cache_key random_seed 
expire cache_key 30

虽然这两组命令执行的效果同样，可是第二个是非原子性操做，若是执行了setnx成功，可是expire失败的话，就会形成这个key一直存在了，没法释放的状况。redis

redis的做者也指出，在使用单节点redis锁的时候，设置一个随机种子做为key的值是颇有必要的，保证了一个客户端释放的锁必须是本身所持有的那个锁。假设获取锁时set的不是一个随机数，而是一个固定值，那么可能会出现下面的状况：sql

客户端1获取锁成功
客户端1在某个操做上阻塞了很长时间
过时时间到了，锁自动释放（可是在客户端1看来本身仍是持有锁中）
客户端2获取到了对应同一个资源的锁
客户端1从阻塞中恢复了，释放掉本身持有的锁，也就是释放掉了客户端2持有的锁

客户端2的锁被客户端1是否，失去安全性。
释放锁的操做，不少人直接用del命令，这会有很大的问题，保证不了这个key是被加锁人锁删。这时候须要用到随机数了。释放锁的操做有三步：shell

get 所持有锁
判断这个锁是否本身所持有
删除持有锁

因此，这三步要保证原子性。用lua脚原本执行，redis官方已经提供脚本文件。安全

if redis.call("get",KEYS[1]) == ARGV[1] then
    return redis.call("del",KEYS[1])
else
    return 0
end

这段脚本在执行的时候，须要把前面的随机数做为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客户端的封装。架构

以上内容但愿帮助到你们， 不少PHPer在进阶的时候总会遇到一些问题和瓶颈，业务代码写多了没有方向感，不知道该从那里入手去提高，对此我整理了一些资料，包括但不限于：分布式架构、高可扩展、高性能、高并发、服务器性能调优、TP6，laravel，Redis，Swoole、Swoft、Kafka、Mysql优化、shell脚本、Docker、微服务、Nginx等多个知识点高级进阶干货须要的能够免费分享给你们 ，须要戳这里 PHP进阶架构师>>>实战视频、大厂面试文档免费获取 并发