【高并發(fā)】你知道嗎？大家都在使用Redisson實現(xiàn)分布式鎖了??！

寫在前面


忘記之前在哪個群里有朋友在問：有出分布式鎖的文章嗎～@冰河？我的回答是：這周會有，也是【高并發(fā)】專題的。想了想，還是先發(fā)一個如何使用Redisson實現(xiàn)分布式鎖的文章吧？為啥？因為使用Redisson實現(xiàn)分布式鎖簡單?。edisson框架是基于Redis實現(xiàn)的分布式鎖，非常強大，只需要拿來使用就行了，至于分布式鎖的原理啥的，后面再擼一篇文章就是了。


Redisson框架十分強大，基于Redisson框架可以實現(xiàn)幾乎你能想到的所有類型的分布式鎖。這里，我就列舉幾個類型的分布式鎖，并各自給出一個示例程序來加深大家的理解。有關(guān)分布式鎖的原理細節(jié)，后續(xù)專門擼一篇文章咱們慢慢聊！

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對象。在提供了自動過期解鎖功能的同時，保證了當多個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();
寫在最后

如果覺得文章對你有點幫助，請微信搜索并關(guān)注「 冰河技術(shù) 」微信公眾號，跟冰河學習高并發(fā)編程技術(shù)。

最后，附上并發(fā)編程需要掌握的核心技能知識圖，祝大家在學習并發(fā)編程時，少走彎路。

• ? 上一篇： SM2算法對比RSA算法，有哪些優(yōu)勢？
• ? 下一篇：復盤|怎樣做好一次復盤