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

1.可重入鎖(Reentrant Lock)

Redisson的分布式可重入鎖RLock Java對(duì)象實(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 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對(duì)象。在提供了自動(dòng)過期解鎖功能的同時(shí)，保證了當(dāng)多個(gè)Redisson客戶端線程同時(shí)請(qǐng)求加鎖時(shí)，優(yōu)先分配給先發(fā)出請(qǐng)求的線程。

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 res = fairLock.tryLockAsync(100, 10, TimeUnit.SECONDS);

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

Redisson的RedissonMultiLock對(duì)象可以將多個(gè)RLock對(duì)象關(guān)聯(lián)為一個(gè)聯(lián)鎖，每個(gè)RLock對(duì)象實(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對(duì)象實(shí)現(xiàn)了Redlock介紹的加鎖算法。該對(duì)象也可以用來將多個(gè)RLock對(duì)象關(guān)聯(lián)為一個(gè)紅鎖，每個(gè)RLock對(duì)象實(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對(duì)象實(shí)現(xiàn)了java.util.concurrent.locks.ReadWriteLock接口。同時(shí)還支持自動(dòng)過期解鎖。該對(duì)象允許同時(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對(duì)象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對(duì)象的基礎(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對(duì)象RCountDownLatch采用了與java.util.concurrent.CountDownLatch相似的接口和用法。

RCountDownLatch latch = redisson.getCountDownLatch("anyCountDownLatch");

latch.trySetCount(1);

latch.await();

// 在其他線程或其他JVM里

RCountDownLatch latch = redisson.getCountDownLatch("anyCountDownLatch");

latch.countDown();

寫在最后如果覺得文章對(duì)你有點(diǎn)幫助，請(qǐng)給小編一個(gè)轉(zhuǎn)發(fā)+關(guān)注，后續(xù)會(huì)更新更多精彩的內(nèi)容。

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

創(chuàng)作挑戰(zhàn)賽新人創(chuàng)作獎(jiǎng)勵(lì)來咯，堅(jiān)持創(chuàng)作打卡瓜分現(xiàn)金大獎(jiǎng)

總結(jié)

以上是生活随笔為你收集整理的redisson的锁的类型_你知道吗？大家都在使用Redisson实现分布式锁了！！的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。