Redisson 分散ロックを実装する Java の例

この記事では主に、分散ロックを実装するための Java プログラミング redisson のコード例を紹介します。編集者は、必要な友人の参考のためにここで共有します。

最近仕事がとても忙しいため、長い間ブログを更新していませんでしたが、今日は Redisson の分散ロックの実装に関する記事をお届けします。

1. リエントラント ロック

Redisson の分散リエントラント ロック RLock Java オブジェクトは、java.util.concurrent.locks.Lock インターフェイスを実装し、自動有効期限ロック解除もサポートします。

public void testReentrantLock(RedissonClient redisson){ 
  RLock lock = redisson.getLock("anyLock"); 
  try{ 
    // 1. 最常见的使用方法 
    //lock.lock(); 
    // 2. 支持过期解锁功能,10秒钟以后自动解锁, 无需调用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 は、分散ロックの非同期実行関連メソッドも提供します:

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 の分散再入可能フェア ロックも実装されています java.util.concurrent を持つ RLock オブジェクト.locks.ロックインターフェイス。自動有効期限ロック解除機能を提供すると同時に、複数の Redisson クライアント スレッドが同時にロックを要求した場合、最初に要求を行ったスレッドが優先されるようにします。

public void testFairLock(RedissonClient redisson){ 
  RLock fairLock = redisson.getFairLock("anyLock"); 
  try{ 
    // 最常见的使用方法 
    fairLock.lock(); 
    // 支持过期解锁功能, 10秒钟以后自动解锁,无需调用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 は、分散リエントラント フェア ロックの非同期実行関連メソッドも提供します:

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

3. インターロック (MultiLock)

Redisson の RedissonMultiLock オブジェクトは、複数の各 RLock オブジェクトを結合できます。インターロックとして、各 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. Red Lock (RedLock)

Redisson の RedissonRedLock オブジェクトは、Redlock によって導入されたロック アルゴリズムを実装します。このオブジェクトを使用して、複数の RLock オブジェクトをレッド ロックとして関連付けることもできます。各 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, 红锁在大部分节点上加锁成功就算成功。 
    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 オブジェクトは java.util.concurrent.locks.ReadWriteLock インターフェイスを実装します。自動有効期限ロック解除にも対応しています。このオブジェクトは同時に複数の読み取りロックを許可しますが、最大 1 つの書き込みロックを持つことができます。

RReadWriteLock rwlock = redisson.getLock("anyRWLock"); 
// 最常见的使用方法 
rwlock.readLock().lock(); 
// 或 
rwlock.writeLock().lock(); 
// 支持过期解锁功能 
// 10秒钟以后自动解锁 
// 无需调用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. セマフォ

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 オブジェクトに基づいており、各信号に有効期限を追加します。各シグナルは独立した 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 と同様のインターフェイスと使用法を採用しています。

りー

概要

以上がRedisson 分散ロックを実装する Java の例の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。