2. 程式人生 > >redisLock redis分布式鎖

redisLock redis分布式鎖

阿新 • • 發佈：2017-06-22
服務器 java status

redis setnx 命令

redis setnx 命令特性

當指定key不存在時才設置。也就是說，如果返回1說明你的命令被執行成功了，redis服務器中的key是你之前設置的值。如果返回0，說明你設置的key在redis服務器裏已經存在。

            status = jedis.setnx(lockKey, redisIdentityKey);/**設置 lock key.*/
            if (status > 0) {
                expire = jedis.expire(lockKey, lockKeyExpireSecond);/**set  redis key expire time.*/
            }

如果設置成功了，才進行過期時間設置，防止你的retry lock重復設置這個過期時間，導致永遠不過期。

java object condition queue 條件隊列

這裏有一個小竅門，可以盡可能的最大化cpu利用率又可以解決公平性問題。

當你頻繁retry的時候，要麽while(true)死循環，然後加個Thread.sleep，或者CAS。前者存在一定線程上下文切換開銷（Thread.sleep是不會釋放出當前內置鎖），而CAS在不清楚遠程鎖被占用多久的情況會浪費很多CPU計算周期，有可能一個任務計算個十幾分鐘，CPU不可能空轉這麽久。

這裏我嘗試使用condition queue條件隊列特性來實現（當然肯定還有其他更優的方法）。

if (isWait && retryCounts < RetryCount) {
                    retryCounts++;
                    synchronized (this) {//借助object condition queue 來提高CPU利用率
                        logger.info(String.                                format("t:%s,當前節點：%s,嘗試等待獲取鎖：%s", Thread.currentThread().getId(), getRedisIdentityKey(), lockKey));
                        this.wait(WaitLockTimeSecond); //未能獲取到lock，進行指定時間的wait再重試.
                    }
                } else if (retryCounts == RetryCount) {
                    logger.info(String.                            format("t:%s,當前節點：%s,指定時間內獲取鎖失敗：%s", Thread.currentThread().getId(), getRedisIdentityKey(), lockKey));                    return false;
                } else {                    return false;//不需要等待，直接退出。
                }

使用條件隊列的好處就是，它雖然釋放出了CPU但是也不會持有當前synchronized，這樣就可以讓其他並發進來的線程也可以獲取到當前內置鎖，然後形成隊列。當wait時間到了被調度喚醒之後才會重新來申請synchronized鎖。
簡單講就是不會再鎖上等待而是在隊列裏等待。java object每一個對象都持有一個條件隊列，與當前內置鎖配合使用。

retrycount 帶有重試次數限制

等待遠程redis lock肯定是需要一定重試機制，但是這種重試是需要一定的限制。

    /**
     * 重試獲取鎖的次數,可以根據當前任務的執行時間來設置。
     * 需要時間=RetryCount*(WaitLockTimeSecond/1000)
     */
    private static final int RetryCount = 10;

這種等待是需要用戶指定的， if (isWait && retryCounts < RetryCount) ，當isWait為true才會進行重試。

object wait time 帶有超時時間的wait

object.wait(timeout),條件隊列中的方法wait是需要一個waittime。

    /**
     * 等待獲取鎖的時間，可以根據當前任務的執行時間來設置。
     * 設置的太短，浪費CPU，設置的太長鎖就不太公平。
     */
    private static final long WaitLockTimeSecond = 2000;

默認2000毫秒。

this.wait(WaitLockTimeSecond); //未能獲取到lock，進行指定時間的wait再重試.

註意：this.wait雖然會blocking住，但是這裏的內置鎖是會立即釋放出來的。所以，有時候我們可以借助這種特性來優化特殊場景。

delete lock 刪除遠程鎖

釋放redis lock比較簡單，直接del key就好了

long status = jedis.del(lockKey);        if (status > 0) {
            logger.info(String.                    format("t:%s,當前節點：%s,釋放鎖：%s 成功。", Thread.currentThread().getId(), getRedisIdentityKey(), lockKey));            return true;
        }

一旦delete 之後，首先wait喚醒的線程將會獲得鎖。

acquire lock 申請lock

/**
     * 帶超時時間的redis lock.
     *
     * @param lockKeyExpireSecond 鎖key在redis中的過去時間
     * @param lockKey             lock key
     * @param isWait              當獲取不到鎖時是否需要等待
     * @throws Exception lockKey is empty throw exception.
     */
    public Boolean acquireLockWithTimeout(int lockKeyExpireSecond, String lockKey, Boolean isWait) throws Exception {        if (StringUtils.isEmpty(lockKey)) throw new Exception("lockKey is empty.");

        int retryCounts = 0;        while (true) {
            Long status, expire = 0L;
            status = jedis.setnx(lockKey, redisIdentityKey);/**設置 lock key.*/
            if (status > 0) {
                expire = jedis.expire(lockKey, lockKeyExpireSecond);/**set  redis key expire time.*/
            }            if (status > 0 && expire > 0) {
                logger.info(String.
                        format("t:%s,當前節點：%s,獲取到鎖：%s", Thread.currentThread().getId(), getRedisIdentityKey(), lockKey));                return true;/**獲取到lock*/
            }            try {                if (isWait && retryCounts < RetryCount) {
                    retryCounts++;
                    synchronized (this) {//借助object condition queue 來提高CPU利用率
                        logger.info(String.
                                format("t:%s,當前節點：%s,嘗試等待獲取鎖：%s", Thread.currentThread().getId(), getRedisIdentityKey(), lockKey));                        this.wait(WaitLockTimeSecond); //未能獲取到lock，進行指定時間的wait再重試.
                    }
                } else if (retryCounts == RetryCount) {
                    logger.info(String.
                            format("t:%s,當前節點：%s,指定時間內獲取鎖失敗：%s", Thread.currentThread().getId(), getRedisIdentityKey(), lockKey));                    return false;
                } else {                    return false;//不需要等待，直接退出。
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
## release lock 釋放lock/**
     * 釋放redis lock。
     *
     * @param lockKey lock key
     * @throws Exception lockKey is empty throw exception.
     */
    public Boolean releaseLockWithTimeout(String lockKey) throws Exception {        if (StringUtils.isEmpty(lockKey)) throw new Exception("lockKey is empty.");

        long status = jedis.del(lockKey);        if (status > 0) {
            logger.info(String.format("當前節點：%s,釋放鎖：%s 成功。", getRedisIdentityKey(), lockKey));            return true;
        }
        logger.info(String.format("當前節點：%s,釋放鎖：%s 失敗。", getRedisIdentityKey(), lockKey));        return false;
    }

demo 演示

2017-06-18 13:57:43.867 INFO 1444 --- [nio-8080-exec-1] c.plen.opensource.implement.RedisLocker : t:23,當前節點：5f81f482-295a-4394-b8cb-d7282e51dd6e,獲取到鎖：product:10100101:shopping
2017-06-18 13:57:47.062 INFO 1444 --- [nio-8080-exec-3] c.plen.opensource.implement.RedisLocker : t:25,當前節點：5f81f482-295a-4394-b8cb-d7282e51dd6e,嘗試等待獲取鎖：product:10100101:shopping
2017-06-18 13:57:49.063 INFO 1444 --- [nio-8080-exec-3] c.plen.opensource.implement.RedisLocker : t:25,當前節點：5f81f482-295a-4394-b8cb-d7282e51dd6e,嘗試等待獲取鎖：product:10100101:shopping
2017-06-18 13:57:51.064 INFO 1444 --- [nio-8080-exec-3] c.plen.opensource.implement.RedisLocker : t:25,當前節點：5f81f482-295a-4394-b8cb-d7282e51dd6e,嘗試等待獲取鎖：product:10100101:shopping
2017-06-18 13:57:53.066 INFO 1444 --- [nio-8080-exec-3] c.plen.opensource.implement.RedisLocker : t:25,當前節點：5f81f482-295a-4394-b8cb-d7282e51dd6e,嘗試等待獲取鎖：product:10100101:shopping
2017-06-18 13:57:55.068 INFO 1444 --- [nio-8080-exec-3] c.plen.opensource.implement.RedisLocker : t:25,當前節點：5f81f482-295a-4394-b8cb-d7282e51dd6e,嘗試等待獲取鎖：product:10100101:shopping
2017-06-18 13:57:57.069 INFO 1444 --- [nio-8080-exec-3] c.plen.opensource.implement.RedisLocker : t:25,當前節點：5f81f482-295a-4394-b8cb-d7282e51dd6e,嘗試等待獲取鎖：product:10100101:shopping
2017-06-18 13:57:59.070 INFO 1444 --- [nio-8080-exec-3] c.plen.opensource.implement.RedisLocker : t:25,當前節點：5f81f482-295a-4394-b8cb-d7282e51dd6e,嘗試等待獲取鎖：product:10100101:shopping
2017-06-18 13:58:01.071 INFO 1444 --- [nio-8080-exec-3] c.plen.opensource.implement.RedisLocker : t:25,當前節點：5f81f482-295a-4394-b8cb-d7282e51dd6e,嘗試等待獲取鎖：product:10100101:shopping
2017-06-18 13:58:03.072 INFO 1444 --- [nio-8080-exec-3] c.plen.opensource.implement.RedisLocker : t:25,當前節點：5f81f482-295a-4394-b8cb-d7282e51dd6e,嘗試等待獲取鎖：product:10100101:shopping
2017-06-18 13:58:05.073 INFO 1444 --- [nio-8080-exec-3] c.plen.opensource.implement.RedisLocker : t:25,當前節點：5f81f482-295a-4394-b8cb-d7282e51dd6e,嘗試等待獲取鎖：product:10100101:shopping
2017-06-18 13:58:07.074 INFO 1444 --- [nio-8080-exec-3] c.plen.opensource.implement.RedisLocker : t:25,當前節點：5f81f482-295a-4394-b8cb-d7282e51dd6e,指定時間內獲取鎖失敗：product:10100101:shopping
2017-06-18 13:58:23.768 INFO 1444 --- [nio-8080-exec-6] c.plen.opensource.implement.RedisLocker : t:28,當前節點：5f81f482-295a-4394-b8cb-d7282e51dd6e,嘗試等待獲取鎖：product:10100101:shopping
2017-06-18 13:58:25.769 INFO 1444 --- [nio-8080-exec-6] c.plen.opensource.implement.RedisLocker : t:28,當前節點：5f81f482-295a-4394-b8cb-d7282e51dd6e,嘗試等待獲取鎖：product:10100101:shopping
2017-06-18 13:58:27.770 INFO 1444 --- [nio-8080-exec-6] c.plen.opensource.implement.RedisLocker : t:28,當前節點：5f81f482-295a-4394-b8cb-d7282e51dd6e,嘗試等待獲取鎖：product:10100101:shopping
2017-06-18 13:58:29.772 INFO 1444 --- [nio-8080-exec-6] c.plen.opensource.implement.RedisLocker : t:28,當前節點：5f81f482-295a-4394-b8cb-d7282e51dd6e,嘗試等待獲取鎖：product:10100101:shopping
2017-06-18 13:58:31.773 INFO 1444 --- [nio-8080-exec-6] c.plen.opensource.implement.RedisLocker : t:28,當前節點：5f81f482-295a-4394-b8cb-d7282e51dd6e,嘗試等待獲取鎖：product:10100101:shopping
2017-06-18 13:58:33.774 INFO 1444 --- [nio-8080-exec-6] c.plen.opensource.implement.RedisLocker : t:28,當前節點：5f81f482-295a-4394-b8cb-d7282e51dd6e,嘗試等待獲取鎖：product:10100101:shopping
2017-06-18 13:58:35.774 INFO 1444 --- [nio-8080-exec-6] c.plen.opensource.implement.RedisLocker : t:28,當前節點：5f81f482-295a-4394-b8cb-d7282e51dd6e,獲取到鎖：product:10100101:shopping

thread 23 優先獲取到對商品ID 10100101 進行修改，所以先鎖住當前商品。

t:23,當前節點：843d3ec0-9c22-4d8a-bcaa-745dba35b8a4,獲取到鎖：product:10100101:shopping

緊接著，thread 25也來對當前商品 10100101進行修改，所以在嘗試獲取鎖。

2017-06-18 13:50:11.021 INFO 4616 --- [nio-8080-exec-3] c.plen.opensource.implement.RedisLocker : t:25,當前節點：946b7250-29f3-459b-8320-62d31e6f1fc4,嘗試等待獲取鎖：product:10100101:shopping
2017-06-18 13:50:13.023 INFO 4616 --- [nio-8080-exec-3] c.plen.opensource.implement.RedisLocker : t:25,當前節點：946b7250-29f3-459b-8320-62d31e6f1fc4,嘗試等待獲取鎖：product:10100101:shopping
2017-06-18 13:50:15.026 INFO 4616 --- [nio-8080-exec-3] c.plen.opensource.implement.RedisLocker : t:25,當前節點：946b7250-29f3-459b-8320-62d31e6f1fc4,嘗試等待獲取鎖：product:10100101:shopping
2017-06-18 13:50:17.028 INFO 4616 --- [nio-8080-exec-3] c.plen.opensource.implement.RedisLocker : t:25,當前節點：946b7250-29f3-459b-8320-62d31e6f1fc4,嘗試等待獲取鎖：product:10100101:shopping
2017-06-18 13:50:19.030 INFO 4616 --- [nio-8080-exec-3] c.plen.opensource.implement.RedisLocker : t:25,當前節點：946b7250-29f3-459b-8320-62d31e6f1fc4,嘗試等待獲取鎖：product:10100101:shopping
2017-06-18 13:50:21.031 INFO 4616 --- [nio-8080-exec-3] c.plen.opensource.implement.RedisLocker : t:25,當前節點：946b7250-29f3-459b-8320-62d31e6f1fc4,嘗試等待獲取鎖：product:10100101:shopping
2017-06-18 13:50:23.035 INFO 4616 --- [nio-8080-exec-3] c.plen.opensource.implement.RedisLocker : t:25,當前節點：946b7250-29f3-459b-8320-62d31e6f1fc4,嘗試等待獲取鎖：product:10100101:shopping
2017-06-18 13:50:25.037 INFO 4616 --- [nio-8080-exec-3] c.plen.opensource.implement.RedisLocker : t:25,當前節點：946b7250-29f3-459b-8320-62d31e6f1fc4,嘗試等待獲取鎖：product:10100101:shopping
2017-06-18 13:50:27.041 INFO 4616 --- [nio-8080-exec-3] c.plen.opensource.implement.RedisLocker : t:25,當前節點：946b7250-29f3-459b-8320-62d31e6f1fc4,嘗試等待獲取鎖：product:10100101:shopping
2017-06-18 13:50:29.042 INFO 4616 --- [nio-8080-exec-3] c.plen.opensource.implement.RedisLocker : t:25,當前節點：946b7250-29f3-459b-8320-62d31e6f1fc4,嘗試等待獲取鎖：product:10100101:shopping
2017-06-18 13:50:35.289 INFO 4616 --- [nio-8080-exec-3] c.plen.opensource.implement.RedisLocker : t:25,當前節點：946b7250-29f3-459b-8320-62d31e6f1fc4,指定時間內獲取鎖失敗：product:10100101:shopping

在進行了retry10次（2000毫秒，2秒）之後，獲取失敗，直接返回，等待下次任務調度開始。

2017-06-18 13:58:07.074 INFO 1444 --- [nio-8080-exec-3] c.plen.opensource.implement.RedisLocker : t:25,當前節點：5f81f482-295a-4394-b8cb-d7282e51dd6e,指定時間內獲取鎖失敗：product:10100101:shopping
2017-06-18 13:58:23.768 INFO 1444 --- [nio-8080-exec-6] c.plen.opensource.implement.RedisLocker : t:28,當前節點：5f81f482-295a-4394-b8cb-d7282e51dd6e,嘗試等待獲取鎖：product:10100101:shopping
2017-06-18 13:58:25.769 INFO 1444 --- [nio-8080-exec-6] c.plen.opensource.implement.RedisLocker : t:28,當前節點：5f81f482-295a-4394-b8cb-d7282e51dd6e,嘗試等待獲取鎖：product:10100101:shopping
2017-06-18 13:58:27.770 INFO 1444 --- [nio-8080-exec-6] c.plen.opensource.implement.RedisLocker : t:28,當前節點：5f81f482-295a-4394-b8cb-d7282e51dd6e,嘗試等待獲取鎖：product:10100101:shopping
2017-06-18 13:58:29.772 INFO 1444 --- [nio-8080-exec-6] c.plen.opensource.implement.RedisLocker : t:28,當前節點：5f81f482-295a-4394-b8cb-d7282e51dd6e,嘗試等待獲取鎖：product:10100101:shopping
2017-06-18 13:58:31.773 INFO 1444 --- [nio-8080-exec-6] c.plen.opensource.implement.RedisLocker : t:28,當前節點：5f81f482-295a-4394-b8cb-d7282e51dd6e,嘗試等待獲取鎖：product:10100101:shopping
2017-06-18 13:58:33.774 INFO 1444 --- [nio-8080-exec-6] c.plen.opensource.implement.RedisLocker : t:28,當前節點：5f81f482-295a-4394-b8cb-d7282e51dd6e,嘗試等待獲取鎖：product:10100101:shopping
2017-06-18 13:58:35.774 INFO 1444 --- [nio-8080-exec-6] c.plen.opensource.implement.RedisLocker : t:28,當前節點：5f81f482-295a-4394-b8cb-d7282e51dd6e,獲取到鎖：product:10100101:shopping

thread 28 發起對商品 10100101 進行修改，retry6次之後獲取到lock。


redisLock redis分布式鎖

相關推薦

redisLock redis分布式鎖

服務器 java status redis setnx 命令redis setnx 命令特性當指定key不存在時才設置。也就是說，如果返回1說明你的命令被執行成功了，redis服務器中的key是你之前設置的值。如果返回0，說明你設置的key在redis服務器裏已經存在。 st

redis分布式鎖和消息隊列

chan 不能 包括 監聽 插入 目前 ren ret clas 最近博主在看redis的時候發現了兩種redis使用方式，與之前redis作為緩存不同，利用的是redis可設置key的有效時間和redis的BRPOP命令。 分布式鎖 由於目前一些編程語言，如PHP等，不能

C#操作Redis,C#實現Redis分布式鎖

ges mage c# png http 字符串 images red -s 功能描述 字符串常規操作 hashset操作 set操作 keys操作 分布式鎖操作 代碼截圖 購買詳詢：QQ 506023315，只要10元（屌絲籌房中） C#操作Red

關於redis分布式鎖的實現方式（轉載）

iss tree red org 實現 方式 分布式 uda master 這個是在網上找到的一個大神寫的（http://wudashan.cn/2017/10/23/Redis-Distributed-Lock-Implement/），對於分布式redis部署的，可以參考

spring boot redis分布式鎖

supported 分布式架構 tsig utils ali 成了 down eva -- 隨著現在分布式架構越來越盛行，在很多場景下需要使用到分布式鎖。分布式鎖的實現有很多種，比如基於數據庫、 zookeeper 等，本文主要介紹使用 Redis 做分布式鎖的方式，並封

Redis分布式鎖解決搶購問題

業務 ret target 執行 線程 top 進行 出了 數據庫 首先分享一個業務場景-搶購。一個典型的高並發問題，所需的最關鍵字段就是庫存，在高並發的情況下每次都去數據庫查詢顯然是不合適的，因此把庫存信息存入Redis中，利用redis的鎖機制來控制並發訪問，是一個不錯

redis分布式鎖原理

clas 並且 例子 允許 要去 否則 先後 個人 nbsp 舉例子：秒殺方式看醫生，一個人看5min 1.第一次只允許一個人直接進行來，X10:00:00進去了，setNX（roomid,now+5min），出來時間假如是10:05:00 2.時間到了10:05:00，3

Redis分布式鎖及分區

多個進程 clas 存儲 crc32 可用 處理 核心 數字 由於 以下內容是翻譯的官網文檔RedLock和分區部分，可以簡單了解分布式鎖在redis如何實現及其方式 redis分區的方法 redis實現的分布式鎖RedLock算法，分布式鎖，即在多個master上獲取同一

redis分布式鎖-SETNX實現

超時值 大於 cep sel 誤差 exists rap sim 理解 Redis有一系列的命令，特點是以NX結尾，NX是Not eXists的縮寫，如SETNX命令就應該理解為：SET if Not eXists。這系列的命令非常有用，這裏講使用SETNX來實現分布式

Redis分布式鎖的try-with-resources實現

故障 rgs 是不是 str .exe stat 等於 通過 except Redis分布式鎖的try-with-resources實現 一、簡介 在當今這個時代，單體應用（standalone）已經很少了，java提供的synchronized已經不能滿足需求，大家自然

Redis分布式鎖的正確實現方式

想要 argv 只有一個 AD redis單機 lease 兩條命令 bject 支持 前言 分布式鎖一般有三種實現方式：1. 數據庫樂觀鎖；2. 基於Redis的分布式鎖；3. 基於ZooKeeper的分布式鎖。本篇博客將介紹第二種方式，基於Redis實現分布式鎖。雖

redis分布式鎖實現

一點 src 如果 只有一個 util 會有 取值 刪除 自己的 一、使用分布式鎖要滿足的幾個條件： 系統是一個分布式系統（關鍵是分布式，單機的可以使用ReentrantLock或者synchronized代碼塊來實現） 共享資源（各個系統訪問同一個資源，資源的載體可能是

Redis分布式鎖

res 哪裏 pan not domu 而且 jedis 校驗 else 轉自：https://www.cnblogs.com/linjiqin/p/8003838.html 前言 分布式鎖一般有三種實現方式：1. 數據庫樂觀鎖；2. 基於Redis的分布式鎖；3. 基

Redis 分布式鎖的正確實現方式

單機 滿足 AR 執行 發現 命令 dom 為什麽 tdi 前言 分布式鎖一般有三種實現方式：1. 數據庫樂觀鎖；2. 基於Redis的分布式鎖；3. 基於ZooKeeper的分布式鎖。本篇博客將介紹第二種方式，基於Redis實現分布式鎖。 可靠性 首先，為了確保分布式

redis分布式鎖和lua腳本

out disco sha1 標準 sign OS .get 浮點數 ins 業務背景：存儲請求參數token ，token唯一 ，且新的生成舊的失效 思路：因為是多臺機器，獲取token存入redis，保持唯一，考慮使用redis來加鎖，其實就是在redis中存一個key

redis 分布式鎖

runnable dom @param set tostring 執行 時間 integer oid 在分布式系統中，之前單一的用synchronized或lock已經不適用了。分布式鎖一般有三種實現方式：1. 數據庫樂觀鎖；2. 基於Redis的分布式鎖；3. 基於Zoo

基於redis分布式鎖實現“秒殺”

購物車 串行 and 本質 希望 ide stack 失敗 業務場景 最近在項目中遇到了類似“秒殺”的業務場景，在本篇博客中，我將用一個非常簡單的demo，闡述實現所謂“秒殺”的基本思路。 業務場景 所謂秒殺，從業務角度看，是短時間內多個用戶“爭搶”資源，這裏的資源在大部分

Redis 分布式鎖的實現

xdebug .com 其中 deb process 可能 pro 但是 test 0X00 測試環境 CentOS 6.6 + Redis 3.2.10 + PHP 7.0.7（+ phpredis 4.1.0） [root@localhost ~]# cat /

Redis 分布式鎖的正確實現方式（ Java 版 ）

想要 uda 就是 tex implement 代碼實現 key eval() attach 前言 分布式鎖一般有三種實現方式：1. 數據庫樂觀鎖；2. 基於Redis的分布式鎖；3. 基於ZooKeeper的分布式鎖。本篇博客將介紹第二種方式，基於Redis實現分布式鎖。

SpringBoot集成Redis分布式鎖以及Redis緩存

ofo 當前 csdn bean system ext pid 註解 fin https://blog.csdn.net/qq_26525215/article/details/79182687 集成Redis 首先在pom.xml中加入需要的redis依賴和緩存依賴 &l