阿超 > redisson实现分布式锁

redisson实现分布式锁

2021-07-02

java

性格左右命运，气度影响格局。——余世雅博士

代码如下

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
   public static int EXPIRE_SECONDS = 5 * 60;
   @Resource
   private RedissonClient redissonClient; 


/**
    * 加redisson分布式锁
    *
    * @param lockName 锁名
    * @param supplier 调用方法
    * @return T
    * @author <achao1441470436@gmail.com>
    * @since 2021/7/2 17:42
    */
   @Override
   @Transactional(rollbackFor = Throwable.class, isolation = Isolation.READ_UNCOMMITTED, propagation = Propagation.REQUIRED)
   public <T> T lockByName(String lockName, Supplier<T> supplier) {
       // 获取锁
       RLock lock = redissonClient.getLock(lockName);
       // 加锁并设置失效时间
       try {
           if (lock.tryLock(EXPIRE_SECONDS, TimeUnit.SECONDS)) {
               // 执行函数获取返回值
               return supplier.get();
           }
       } catch (Exception e) {
           log.error("Something Wrong with:", e);
       } finally {
           // 释放锁
           lock.unlock();
       }
       return null;
   }

如何使用就不再赘述了，和我之前写的redis防止缓存穿透击穿雪崩的那篇博客差不多的

不过以防万一还是写一个吧哈哈

1
2
3
4
redisManager.lockByName("achao"), () -> {
    // 执行逻辑，拿到返回值，不需要返回值可以任意返回
    return "";
});

在多线程场景下锁生效

如果我们需要集群下的RedLock

则可以如下实现

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
/**
 * 使用名字加一个redisson的分布式锁
 *
 * @param lockName 锁名
 * @param supplier 调用方法
 * @return T
 * @author <achao1441470436@gmail.com>
 * @since 2021/7/2 17:42
 */
@Override
@Transactional(rollbackFor = Throwable.class, isolation = Isolation.READ_UNCOMMITTED, propagation = Propagation.REQUIRED)
public <T> T lockByName(String lockName, Supplier<T> supplier) {
    // 获取锁
    RLock lock = redissonClientFirst.getLock(lockName);
    RLock second = redissonClientSecond.getLock(lockName);
    RLock third = redissonClientThird.getLock(lockName);
    RedissonRedLock redissonRedLock = new RedissonRedLock(lock,second,third);
    // 加锁并设置失效时间
    try {
        if (redissonRedLock.tryLock(EXPIRE_SECONDS, TimeUnit.SECONDS)) {
            // 执行函数获取返回值
            return supplier.get();
        }
    } catch (Exception e) {
        log.error("Something Wrong with:", e);
    } finally {
        // 释放锁
        redissonRedLock.unlock();
    }
    return null;
}