使用Redisson實現(xiàn)分布式鎖

1. 可重入鎖(Reentrant Lock)

Redisson的分布式可重入鎖RLock Java對象實現(xiàn)了java.util.concurrent.locks.Lock接口糕篇,同時還支持自動過期解鎖呐粘。

public void testReentrantLock(RedissonClient redisson){

        RLock lock = redisson.getLock("anyLock");
        try{
            // 1. 最常見的使用方法
            //lock.lock();

            // 2. 支持過期解鎖功能,10秒鐘以后自動解鎖, 無需調(diào)用unlock方法手動解鎖
            //lock.lock(10, TimeUnit.SECONDS);

            // 3. 嘗試加鎖术吝,最多等待3秒勾效,上鎖以后10秒自動解鎖
            boolean res = lock.tryLock(3, 10, TimeUnit.SECONDS);
            if(res){    //成功
                // do your business

            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            lock.unlock();
        }

    }

Redisson同時還為分布式鎖提供了異步執(zhí)行的相關(guān)方法:

public void testAsyncReentrantLock(RedissonClient redisson){
        RLock lock = redisson.getLock("anyLock");
        try{
            lock.lockAsync();
            lock.lockAsync(10, TimeUnit.SECONDS);
            Future<Boolean> res = lock.tryLockAsync(3, 10, TimeUnit.SECONDS);

            if(res.get()){
                // do your business

            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        } catch (ExecutionException e) {
            e.printStackTrace();
        } finally {
            lock.unlock();
        }

    }

2. 公平鎖(Fair Lock)

Redisson分布式可重入公平鎖也是實現(xiàn)了java.util.concurrent.locks.Lock接口的一種RLock對象。在提供了自動過期解鎖功能的同時嵌器,保證了當(dāng)多個Redisson客戶端線程同時請求加鎖時肛真,優(yōu)先分配給先發(fā)出請求的線程。

public void testFairLock(RedissonClient redisson){

        RLock fairLock = redisson.getFairLock("anyLock");
        try{
            // 最常見的使用方法
            fairLock.lock();

            // 支持過期解鎖功能, 10秒鐘以后自動解鎖,無需調(diào)用unlock方法手動解鎖
            fairLock.lock(10, TimeUnit.SECONDS);

            // 嘗試加鎖爽航,最多等待100秒蚓让,上鎖以后10秒自動解鎖
            boolean res = fairLock.tryLock(100, 10, TimeUnit.SECONDS);
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            fairLock.unlock();
        }

    }

Redisson同時還為分布式可重入公平鎖提供了異步執(zhí)行的相關(guān)方法:

RLock fairLock = redisson.getFairLock("anyLock");
fairLock.lockAsync();
fairLock.lockAsync(10, TimeUnit.SECONDS);
Future<Boolean> res = fairLock.tryLockAsync(100, 10, TimeUnit.SECONDS);

3. 聯(lián)鎖(MultiLock)

Redisson的RedissonMultiLock對象可以將多個RLock對象關(guān)聯(lián)為一個聯(lián)鎖,每個RLock對象實例可以來自于不同的Redisson實例讥珍。

public void testMultiLock(RedissonClient redisson1,
                              RedissonClient redisson2, RedissonClient redisson3){

        RLock lock1 = redisson1.getLock("lock1");
        RLock lock2 = redisson2.getLock("lock2");
        RLock lock3 = redisson3.getLock("lock3");

        RedissonMultiLock lock = new RedissonMultiLock(lock1, lock2, lock3);

        try {
            // 同時加鎖:lock1 lock2 lock3, 所有的鎖都上鎖成功才算成功历极。
            lock.lock();

            // 嘗試加鎖,最多等待100秒衷佃,上鎖以后10秒自動解鎖
            boolean res = lock.tryLock(100, 10, TimeUnit.SECONDS);

        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            lock.unlock();
        }

    }

4. 紅鎖(RedLock)

Redisson的RedissonRedLock對象實現(xiàn)了Redlock介紹的加鎖算法趟卸。該對象也可以用來將多個RLock
對象關(guān)聯(lián)為一個紅鎖,每個RLock對象實例可以來自于不同的Redisson實例。


    public void testRedLock(RedissonClient redisson1,
                              RedissonClient redisson2, RedissonClient redisson3){

        RLock lock1 = redisson1.getLock("lock1");
        RLock lock2 = redisson2.getLock("lock2");
        RLock lock3 = redisson3.getLock("lock3");

        RedissonRedLock lock = new RedissonRedLock(lock1, lock2, lock3);
      try {
            // 同時加鎖:lock1 lock2 lock3, 紅鎖在大部分節(jié)點上加鎖成功就算成功锄列。
            lock.lock();

            // 嘗試加鎖新蟆,最多等待100秒,上鎖以后10秒自動解鎖
            boolean res = lock.tryLock(100, 10, TimeUnit.SECONDS);

        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            lock.unlock();
        }

    }

5. 讀寫鎖(ReadWriteLock)

Redisson的分布式可重入讀寫鎖RReadWriteLock Java對象實現(xiàn)了java.util.concurrent.locks.ReadWriteLock接口右蕊。同時還支持自動過期解鎖。該對象允許同時有多個讀取鎖吮螺,但是最多只能有一個寫入鎖饶囚。

RReadWriteLock rwlock = redisson.getLock("anyRWLock");
// 最常見的使用方法
rwlock.readLock().lock();
// 或
rwlock.writeLock().lock();

// 支持過期解鎖功能
// 10秒鐘以后自動解鎖
// 無需調(diào)用unlock方法手動解鎖
rwlock.readLock().lock(10, TimeUnit.SECONDS);
// 或
rwlock.writeLock().lock(10, TimeUnit.SECONDS);

// 嘗試加鎖,最多等待100秒鸠补,上鎖以后10秒自動解鎖
boolean res = rwlock.readLock().tryLock(100, 10, TimeUnit.SECONDS);
// 或
boolean res = rwlock.writeLock().tryLock(100, 10, TimeUnit.SECONDS);
...
lock.unlock();

6. 信號量(Semaphore)

Redisson的分布式信號量(Semaphore)Java對象RSemaphore采用了與java.util.concurrent.Semaphore相似的接口和用法萝风。

RSemaphore semaphore = redisson.getSemaphore("semaphore");
semaphore.acquire();
//或
semaphore.acquireAsync();
semaphore.acquire(23);
semaphore.tryAcquire();
//或
semaphore.tryAcquireAsync();
semaphore.tryAcquire(23, TimeUnit.SECONDS);
//或
semaphore.tryAcquireAsync(23, TimeUnit.SECONDS);
semaphore.release(10);
semaphore.release();
//或
semaphore.releaseAsync();

7. 可過期性信號量(PermitExpirableSemaphore)

Redisson的可過期性信號量(PermitExpirableSemaphore)實在RSemaphore對象的基礎(chǔ)上,為每個信號增加了一個過期時間紫岩。每個信號可以通過獨立的ID來辨識规惰,釋放時只能通過提交這個ID才能釋放。

RPermitExpirableSemaphore semaphore = redisson.getPermitExpirableSemaphore("mySemaphore");
String permitId = semaphore.acquire();
// 獲取一個信號泉蝌,有效期只有2秒鐘歇万。
String permitId = semaphore.acquire(2, TimeUnit.SECONDS);
// ...
semaphore.release(permitId);

8. 閉鎖(CountDownLatch)

Redisson的分布式閉鎖(CountDownLatch)Java對象RCountDownLatch采用了與java.util.concurrent.CountDownLatch相似的接口和用法。

RCountDownLatch latch = redisson.getCountDownLatch("anyCountDownLatch");
latch.trySetCount(1);
latch.await();

// 在其他線程或其他JVM里
RCountDownLatch latch = redisson.getCountDownLatch("anyCountDownLatch");
latch.countDown();

參考資料

Redisson 分布式鎖和同步器

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末勋陪,一起剝皮案震驚了整個濱河市贪磺,隨后出現(xiàn)的幾起案子,更是在濱河造成了極大的恐慌诅愚,老刑警劉巖寒锚,帶你破解...
    沈念sama閱讀 206,968評論 6 482
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件,死亡現(xiàn)場離奇詭異违孝,居然都是意外死亡刹前,警方通過查閱死者的電腦和手機(jī),發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 88,601評論 2 382
  • 文/潘曉璐 我一進(jìn)店門雌桑,熙熙樓的掌柜王于貴愁眉苦臉地迎上來喇喉,“玉大人,你說我怎么就攤上這事筹燕≡桑” “怎么了?”我有些...
    開封第一講書人閱讀 153,220評論 0 344
  • 文/不壞的土叔 我叫張陵撒踪,是天一觀的道長过咬。 經(jīng)常有香客問我,道長制妄,這世上最難降的妖魔是什么掸绞? 我笑而不...
    開封第一講書人閱讀 55,416評論 1 279
  • 正文 為了忘掉前任,我火速辦了婚禮,結(jié)果婚禮上衔掸,老公的妹妹穿的比我還像新娘烫幕。我一直安慰自己,他們只是感情好敞映,可當(dāng)我...
    茶點故事閱讀 64,425評論 5 374
  • 文/花漫 我一把揭開白布较曼。 她就那樣靜靜地躺著,像睡著了一般振愿。 火紅的嫁衣襯著肌膚如雪捷犹。 梳的紋絲不亂的頭發(fā)上,一...
    開封第一講書人閱讀 49,144評論 1 285
  • 那天冕末,我揣著相機(jī)與錄音萍歉,去河邊找鬼。 笑死档桃,一個胖子當(dāng)著我的面吹牛枪孩,可吹牛的內(nèi)容都是我干的。 我是一名探鬼主播藻肄,決...
    沈念sama閱讀 38,432評論 3 401
  • 文/蒼蘭香墨 我猛地睜開眼蔑舞,長吁一口氣:“原來是場噩夢啊……” “哼!你這毒婦竟也來了嘹屯?” 一聲冷哼從身側(cè)響起斗幼,我...
    開封第一講書人閱讀 37,088評論 0 261
  • 序言:老撾萬榮一對情侶失蹤,失蹤者是張志新(化名)和其女友劉穎抚垄,沒想到半個月后蜕窿,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體,經(jīng)...
    沈念sama閱讀 43,586評論 1 300
  • 正文 獨居荒郊野嶺守林人離奇死亡呆馁,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 36,028評論 2 325
  • 正文 我和宋清朗相戀三年桐经,在試婚紗的時候發(fā)現(xiàn)自己被綠了。 大學(xué)時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片浙滤。...
    茶點故事閱讀 38,137評論 1 334
  • 序言:一個原本活蹦亂跳的男人離奇死亡阴挣,死狀恐怖,靈堂內(nèi)的尸體忽然破棺而出纺腊,到底是詐尸還是另有隱情畔咧,我是刑警寧澤,帶...
    沈念sama閱讀 33,783評論 4 324
  • 正文 年R本政府宣布揖膜,位于F島的核電站誓沸,受9級特大地震影響,放射性物質(zhì)發(fā)生泄漏壹粟。R本人自食惡果不足惜拜隧,卻給世界環(huán)境...
    茶點故事閱讀 39,343評論 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一處隱蔽的房頂上張望。 院中可真熱鬧洪添,春花似錦垦页、人聲如沸。這莊子的主人今日做“春日...
    開封第一講書人閱讀 30,333評論 0 19
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽。三九已至忿峻,卻和暖如春宋光,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背炭菌。 一陣腳步聲響...
    開封第一講書人閱讀 31,559評論 1 262
  • 我被黑心中介騙來泰國打工, 沒想到剛下飛機(jī)就差點兒被人妖公主榨干…… 1. 我叫王不留逛漫,地道東北人黑低。 一個月前我還...
    沈念sama閱讀 45,595評論 2 355
  • 正文 我出身青樓,卻偏偏與公主長得像酌毡,于是被迫代替她去往敵國和親克握。 傳聞我的和親對象是個殘疾皇子,可洞房花燭夜當(dāng)晚...
    茶點故事閱讀 42,901評論 2 345

推薦閱讀更多精彩內(nèi)容