案例实战-SpringBoot整合Redisson实现RedLock分布式锁同步

package com.lixiang.controller; import org.redisson.RedissonRedLock; import org.redisson.api.RLock; import org.redisson.api.RedissonClient; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; import java.util.concurrent.TimeUnit; /** * @author lixiang * @date 2023/6/25 11:04 */ @RestController @RequestMapping("/") public class RedLockController { /** * 定义锁的名字 */ public static final String CACHE_KEY_REDLOCK = "redlock"; @Autowired private RedissonClient redissonClient1; @Autowired private RedissonClient redissonClient2; @Autowired private RedissonClient redissonClient3; @RequestMapping("getRedLock") public String getRedLock(){ //每个客户端分别获取锁资源 RLock lock1 = redissonClient1.getLock(CACHE_KEY_REDLOCK); RLock lock2 = redissonClient2.getLock(CACHE_KEY_REDLOCK); RLock lock3 = redissonClient3.getLock(CACHE_KEY_REDLOCK); //创建红锁 客户端 RedissonRedLock redLock = new RedissonRedLock(lock1, lock2, lock3); //定义获取锁标志位,默认是获取失败 boolean isLockBoolean = false; try { /** * waitTime：等待获取锁的最长时间。如果在等待时间内无法获取锁，并且没有其他锁释放，则返回 false。如果 waitTime < 0，则无限期等待，直到获得锁定。 * leaseTime：就是redis key的过期时间，锁的持有时间，可以使用 ttl 查看过期时间。 * 如果在持有时间结束前锁未被释放，则锁将自动过期，没有进行key续期，并且其他线程可以获得此锁。如果 leaseTime = 0，则锁将永久存在，直到被显式释放。 */ isLockBoolean = redLock.tryLock(1, 20, TimeUnit.SECONDS); System.out.printf("线程:"+Thread.currentThread().getId()+",是否拿到锁:" +isLockBoolean +"\n"); if (isLockBoolean) { System.out.println("线程:"+Thread.currentThread().getId() + ",加锁成功，进入业务操作"); try { //业务逻辑，40s模拟，超过了key的过期时间 TimeUnit.SECONDS.sleep(40); } catch (InterruptedException e) { e.printStackTrace(); } } } catch (Exception e) { System.err.printf("线程:"+Thread.currentThread().getId()+"发生异常,加锁失败"); e.printStackTrace(); } finally { // 无论如何，最后都要解锁 redLock.unlock(); } return isLockBoolean?"success":"fail"; } }