Java編程redisson實(shí)現(xiàn)分布式鎖代碼示例

更新時(shí)間：2017年10月16日 16:24:59 作者：liuyazhuang

這篇文章主要介紹了Java編程redisson實(shí)現(xiàn)分布式鎖代碼示例，小編覺得還是比較不錯(cuò)的，這里給大家分享下，供需要的朋友參考。

最近由于工作很忙，很長時(shí)間沒有更新博客了，今天為大家?guī)硪黄嘘P(guān)Redisson實(shí)現(xiàn)分布式鎖的文章，好了，不多說了，直接進(jìn)入主題。

1. 可重入鎖（Reentrant Lock）

Redisson的分布式可重入鎖RLock Java對象實(shí)現(xiàn)了java.util.concurrent.locks.Lock接口，同時(shí)還支持自動(dòng)過期解鎖。

public void testReentrantLock(RedissonClient redisson){ 
  RLock lock = redisson.getLock("anyLock"); 
  try{ 
    // 1. 最常見的使用方法 
    //lock.lock(); 
    // 2. 支持過期解鎖功能,10秒鐘以后自動(dòng)解鎖, 無需調(diào)用unlock方法手動(dòng)解鎖 
    //lock.lock(10, TimeUnit.SECONDS); 
    // 3. 嘗試加鎖，最多等待3秒，上鎖以后10秒自動(dòng)解鎖 
    boolean res = lock.tryLock(3, 10, TimeUnit.SECONDS); 
    if(res){ //成功 
    // do your business 
    } 
  } catch (InterruptedException e) { 
    e.printStackTrace(); 
  } finally { 
    lock.unlock(); 
  } 
}

Redisson同時(shí)還為分布式鎖提供了異步執(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分布式可重入公平鎖也是實(shí)現(xiàn)了java.util.concurrent.locks.Lock接口的一種RLock對象。在提供了自動(dòng)過期解鎖功能的同時(shí)，保證了當(dāng)多個(gè)Redisson客戶端線程同時(shí)請求加鎖時(shí)，優(yōu)先分配給先發(fā)出請求的線程。

public void testFairLock(RedissonClient redisson){ 
  RLock fairLock = redisson.getFairLock("anyLock"); 
  try{ 
    // 最常見的使用方法 
    fairLock.lock(); 
    // 支持過期解鎖功能, 10秒鐘以后自動(dòng)解鎖,無需調(diào)用unlock方法手動(dòng)解鎖 
    fairLock.lock(10, TimeUnit.SECONDS); 
    // 嘗試加鎖，最多等待100秒，上鎖以后10秒自動(dòng)解鎖 
    boolean res = fairLock.tryLock(100, 10, TimeUnit.SECONDS); 
  } catch (InterruptedException e) { 
    e.printStackTrace(); 
  } finally { 
    fairLock.unlock(); 
  } 
}

Redisson同時(shí)還為分布式可重入公平鎖提供了異步執(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對象可以將多個(gè)RLock對象關(guān)聯(lián)為一個(gè)聯(lián)鎖，每個(gè)RLock對象實(shí)例可以來自于不同的Redisson實(shí)例。

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 { 
    // 同時(shí)加鎖：lock1 lock2 lock3, 所有的鎖都上鎖成功才算成功。 
    lock.lock(); 
    // 嘗試加鎖，最多等待100秒，上鎖以后10秒自動(dòng)解鎖 
    boolean res = lock.tryLock(100, 10, TimeUnit.SECONDS); 
  } catch (InterruptedException e) { 
    e.printStackTrace(); 
  } finally { 
    lock.unlock(); 
  } 
}

4. 紅鎖（RedLock）

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

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 { 
    // 同時(shí)加鎖：lock1 lock2 lock3, 紅鎖在大部分節(jié)點(diǎn)上加鎖成功就算成功。 
    lock.lock(); 
    // 嘗試加鎖，最多等待100秒，上鎖以后10秒自動(dòng)解鎖 
    boolean res = lock.tryLock(100, 10, TimeUnit.SECONDS); 
  } catch (InterruptedException e) { 
    e.printStackTrace(); 
  } finally { 
    lock.unlock(); 
  } 
}

5. 讀寫鎖（ReadWriteLock）

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

RReadWriteLock rwlock = redisson.getLock("anyRWLock"); 
// 最常見的使用方法 
rwlock.readLock().lock(); 
// 或 
rwlock.writeLock().lock(); 
// 支持過期解鎖功能 
// 10秒鐘以后自動(dòng)解鎖 
// 無需調(diào)用unlock方法手動(dòng)解鎖 
rwlock.readLock().lock(10, TimeUnit.SECONDS); 
// 或 
rwlock.writeLock().lock(10, TimeUnit.SECONDS); 
// 嘗試加鎖，最多等待100秒，上鎖以后10秒自動(dòng)解鎖 
boolean res = rwlock.readLock().tryLock(100, 10, TimeUnit.SECONDS); 
// 或 
boolean res = rwlock.writeLock().tryLock(100, 10, TimeUnit.SECONDS); 
... 
lock.unlock();

6. 信號(hào)量（Semaphore）

Redisson的分布式信號(hào)量（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. 可過期性信號(hào)量（PermitExpirableSemaphore）

Redisson的可過期性信號(hào)量（PermitExpirableSemaphore）實(shí)在RSemaphore對象的基礎(chǔ)上，為每個(gè)信號(hào)增加了一個(gè)過期時(shí)間。每個(gè)信號(hào)可以通過獨(dú)立的ID來辨識(shí)，釋放時(shí)只能通過提交這個(gè)ID才能釋放。

RPermitExpirableSemaphore semaphore = redisson.getPermitExpirableSemaphore("mySemaphore"); 
String permitId = semaphore.acquire(); 
// 獲取一個(gè)信號(hào)，有效期只有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();

總結(jié)

以上就是本文關(guān)于Java編程redisson實(shí)現(xiàn)分布式鎖代碼示例的全部內(nèi)容，感興趣的朋友可以參閱：詳細(xì)解讀分布式鎖原理及三種實(shí)現(xiàn)方式、淺談oracle rac和分布式數(shù)據(jù)庫的區(qū)別、Spring Cloud與分布式系統(tǒng)簡析以及本站其他相關(guān)專題，希望對大家有所幫助。如有不足之處，歡迎留言指出。感謝朋友們對本站的支持！

您可能感興趣的文章: