java中redissonClient 分布式锁的使用

<!-- redis 分布式锁框架 -->
		<dependency>
			<groupId>org.redisson</groupId>
			<artifactId>redisson</artifactId>
			<version>3.12.5</version>
		</dependency>

Config config = new Config();
//存放在哪个服务器的redisIP地址加redis端口号
config. useSingleServer().setAddress("127.0.0.1:6379");
RedissonClient redisson = Redisson.create(config);

redisson.getConfig().toJSON().toString()

public class LockExamples {
    public static void main(String[] args) throws InterruptedException {
        // 默认连接上127.0.0.1:6379
        RedissonClient client = Redisson.create();
        // RLock 继承了 java.util.concurrent.locks.Lock 接口
        RLock lock = client.getLock("lock");

        lock.lock();
        System.out.println("lock acquired");

        Thread t = new Thread(() -> {
            //获取锁，传入要锁的key
            RLock lock1 = client.getLock("lock");
            //获取锁
            lock1.lock();
            System.out.println("lock acquired by thread");
            //解锁
            lock1.unlock();
            System.out.println("lock released by thread");
        });

        t.start();
        t.join(1000);
        
        lock.unlock();
        System.out.println("lock released");

        t.join();

        client.shutdown();
    }
}

    @Override
    @Transactional(rollbackFor = Exception.class)
    public FlyingFlowerV1Vo insert(FlyingFlowerReq flyingFlowerReq, String userId) throws Exception {
        //对进来的用户加锁
        RLock userLock = redissonClient.getLock(RedissonKey.USER_ID + userId);
        try{
            //尝试加锁, 最多等待1秒, 1000秒后自动解锁
            boolean getUserLock = userLock.tryLock(1, 1000, TimeUnit.MILLISECONDS);
            if (getUserLock) {
                //业务逻辑的代码，通常在插入修改的操作方法上进行加锁
        }catch (Exception e){
            //提示
            System.out.println("接令频繁"+ userId);
            throw new ResultInfo(ResultUtils.error("接令频繁，请稍后再试"));
        }finally {
            //解锁
            if (userLock.isLocked()) {
                if (userLock.isHeldByCurrentThread()) {
                    userLock.unlock();
                }
            }
        }
        return null;
    }