Redisson框架十分強大，基于Redisson框架可以實現(xiàn)幾乎你能想到的所有類型的分布式鎖。這里，我就列舉幾個類型的分布式鎖，并各自給出一個示例程序來加深大家的理解。有關(guān)分布式鎖的原理細(xì)節(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 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 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();

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

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

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

總結(jié)

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

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