Redis分布式鎖

原創轉載請注明出處：https://www.cnblogs.com/agilestyle/p/11605323.html

 

大部分開發人員利用Redis 實現分布式鎖的方式，都是使用SETNX+EXPIRE 組合來實現

這種方式實現的分布式鎖，是通過setnx 方法設置鎖，如果lockKey 存在，則返回失敗，否則返回成功。設置成功之后，為了能在完成同步代碼之后成功釋放鎖，方法中還需要使用expire 方法給lockKey 值設置一個過期時間，確認key值刪除，避免出現鎖無法釋放，導致下一個線程無法獲取到鎖，即死鎖問題。

如果程序在設置過期時間之前、設置鎖之后出現崩潰，此時如果lockKey 沒有設置過期時間，將會出現死鎖問題，這種問題的根源在於setnx 和expire 是兩條指令而不是原子指令。

在Redis2.8版本中，Redis的作者加入了set指令的擴展參數，使得setnx 和 expire 指令 可以一起執行。示例代碼如下：

RedisDistributedLock.java

package org.fool.spring.util;

import redis.clients.jedis.Jedis;

public class RedisDistributedLock {

    private static final String LOCK_DEFAULT_FLAG = "true";
    private static final String LOCK_SUCCESS = "OK";
    private static final String SET_IF_NOT_EXIST = "NX";
    private static final String SET_WITH_EXPIRE_TIME = "PX";

    private Jedis jedis;
    private String lockKey;

    RedisDistributedLock(Jedis jedis, String lockKey) {
        this.jedis = jedis;
        this.lockKey = lockKey;
    }

    /**
     * 嘗試獲取分布式鎖
     *
     * @param expireTime 超期時間(ms)
     * @return 是否獲取成功
     */
    public boolean tryLock(int expireTime) {
        String result = jedis.set(lockKey, LOCK_DEFAULT_FLAG, SET_IF_NOT_EXIST, SET_WITH_EXPIRE_TIME, expireTime);

        return LOCK_SUCCESS.equals(result);
    }

    public void unlock() throws Exception {
        jedis.del(lockKey);
    }

    public boolean isAcquiredInThisProcess() {
        String result = jedis.get(lockKey);

        return LOCK_DEFAULT_FLAG.equals(result);
    }

}

 

Test

執行第一次Test

在60s秒執行第二次Test，由於第一次Test還在執行中（即鎖還沒有釋放），導致沒有獲取到鎖

Note：

Redis的分布式鎖不能解決超時問題，如果在加鎖和釋放鎖之間的邏輯執行的時間太長，以至於超出了鎖的超時限制，就會出現超時問題。

因為這時候第一個線程持有的鎖過期了，臨界區的邏輯還沒有執行完，而同時第二個線程就提前重新持有了這把鎖，導致臨界區代碼不能得到嚴格串行執行。

為了避免這個問題，Redis分布式鎖不要用於較長時間的任務。

這個方案是目前最優的分布式鎖方案，但如果是在Redis集群環境下，依然存在問題。由於Redis集群數據同步到各個節點時是異步的，如果在Master節點獲取到鎖后，在沒有同步到其它節點時，Master節點崩潰了，此時新的Master節點依然可以獲取鎖，所以多個應用服務可以同時獲取到鎖。集群模式下推薦使用 Redisson

 

Reference

https://time.geekbang.org/column/article/125983

https://www.redis.net.cn/order/3552.html