一、引入redisson的依赖

<dependency>
    <groupId>org.redisson</groupId>
    <artifactId>redisson</artifactId>
    <version>3.17.0</version>
</dependency>

配置Redisson客户端bean

@Component
public class RedisConfig {

    @Bean
    public RedissonClient redisson() throws Exception {
        Config config = new Config();
        config.useSingleServer().setAddress("redis://127.0.0.1:6379");
        config.useSingleServer().setPassword("xxxx");
        return Redisson.create(config);
    }
}

注入redisson客户端

@Autowired
RedissonClient redissonClient;

二、RLock方法使用

	public void testLock() {
        RLock lock = getLock("testLock");
        try{
            if (lock == null) {
                System.out.println("获取到锁了!");
            }else{
                System.out.println("没有获取到锁!");
            }
        }catch (Exception e){
            e.printStackTrace();
        }finally {
        	assert lock != null;
            if (lock.isHeldByCurrentThread()) {
                lock.unlock();
            }
        }
    }
    
	public RLock getLock(String key) {
        // 获取锁
        RLock lock = redissonClient.getLock(key);
        try {
            // 如果锁定成功,则返回true,如果锁定已设置,则返回false。
            if (!lock.tryLock(30, 30, TimeUnit.SECONDS)) {
                return null;
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
            return null;
        }
        return lock;
    }

上述代码用到的方法解释:

  • redissonClient.getLock(key): 通过key名称返回 Lock 的实例,要注意的getLock()是实现非公平锁定,因此不保证线程的获取顺序
  • lock.tryLock(long 最长等待时间, long 等待时间, TimeUnit 时间单位): 尝试使用定义的等待时间获取锁。如有必要会等待定义的最长等待时间,直到锁可用。锁定将在定义的等待时间间隔后自动释放。会抛出 InterruptedException 异常
  • lock.isHeldByCurrentThread(): 检查此锁是否由当前线程持有,如果持有,返回 true,否则为 false
  • lock.unlock(): 释放锁。Lock 实现通常会对哪个线程可以释放锁施加限制(通常只有锁的持有者可以释放它)并且如果违反限制可能会抛出 unchecked 异常。该 Lock 实现必须记录任何限制和异常类型。

RLock还有其他的方法解释:

  • lock(): 获得锁,如果锁不可用,则当前线程将被禁用以用于线程调度目的并处于休眠状态,直到获得锁为止。此操作可能会导致死锁发生,所以我们可以使用以下的lock()方法。
  • lock(long 等待时间, TimeUnit 时间单位): 使用定义的等待时间获取锁。如有必要,等待锁定可用。锁定将在定义的等待时间间隔后自动释放。如果等待时间为-1,则保持锁定直到被解锁。和lockInterruptibly() 方法差不多
  • forceUnlock(): 如果锁存在并且现在已解锁,则返回 true,否则返回 false
  • isLocked(): 检查锁是否被任何线程锁定,如果锁定返回true,否则返回 false
  • getHoldCount(): 获取当前线程持有此锁的次数,如果当前线程未持有此锁,则为 0
  • remainTimeToLive(): 获取锁的剩余时间,以毫秒为单位的时间,如果锁不存在返回-2;如果锁存在但没有关联的过期时间则返回-1。
  • getName(): 获取锁的名称

此外,RLock继承了Lock类和RLockAsync类,所以他也拥有他们的所有方法


2023-09-13
更新了一篇Redis分布式锁配置成注解使用,相对于以上手动上锁的可读性和维护性更加高,点击跳转

Logo

为开发者提供学习成长、分享交流、生态实践、资源工具等服务,帮助开发者快速成长。

更多推荐