(11)Redis------分布式锁的实现方式之一（基于Springboot项目搭建）

1
2
3
4
5
<dependency>
 <groupId>org.redisson</groupId>
 <artifactId>redisson</artifactId>
 <version>3.1.0</version>
</dependency>

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
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
/**
 * 基于redisson的实现的redis分布式锁
 * com.bjrhxq.platform.application.distributedlock.redis
 **/
public class RedisDistributedLock {
 
 private final static Logger logger = LoggerFactory.getLogger(RedisDistributedLock.class);
 
 /**
 * 加锁等待时间
 */
 private Long lockWaitTime;
 
 /**
 *自动解锁时间
 */
 private Long autoReLockTime;
 
 /**
 * 时间单位 1 秒，2 分钟,3小时，4天
 */
 private Integer timeUnit;
 
 
 /**
 * rediss客户端
 */
 private RedissonClient redissonClient;
 
     private final static Long LOCKWAITTIME_NUM = 0L;//默认加锁等待时间（0秒）
     private final static Long AUTORELOCKTIME_NUM = 5L;//默认释放锁时间（5秒）
     private final static Integer TIMEUNIT_VALUE = 1;//单位默认值（秒）
     private RedisDistributedLock(){
 
 }
 
 public RedisDistributedLock(String redisServices,Long _lockWaitTime,Long _autoReLockTime){
     if (StringUtils.isBlank(redisServices)){
         logger.error("redisServices为空！请上传");
         throw new BzException("redisServices为空");
     }
     this.autoReLockTime = _autoReLockTime == null?AUTORELOCKTIME_NUM:_autoReLockTime;
     this.lockWaitTime = _lockWaitTime == null?LOCKWAITTIME_NUM:_lockWaitTime;
     this.timeUnit =TIMEUNIT_VALUE;
     redissonClient = RedissonUtils.getInstance().getRedisson(redisServices);
 }

 public RedisDistributedLock(String redisServices,Long _lockWaitTime,Long _autoReLockTime,Integer _timeUnit){
     if (StringUtils.isBlank(redisServices)){
     logger.error("redisServices为空！请上传");
     throw new BzException("redisServices为空");
 }
     this.autoReLockTime = _autoReLockTime == null?AUTORELOCKTIME_NUM:_autoReLockTime;
     this.lockWaitTime = _lockWaitTime == null?LOCKWAITTIME_NUM:_lockWaitTime;
     this.timeUnit =_timeUnit;
     redissonClient = RedissonUtils.getInstance().getRedisson(redisServices);
 }
 //程序一旦启用不能关闭redissonClient否则会报cannot be started once stopped 导致程序中断无法启动，该方法只用于测试使用关闭客户端与服务端连接
 public void closeReddisson(){
     redissonClient.shutdown();
 }
 /**
 * 获取锁
 * @param lockName
 */
 public boolean getLock(String lockName){
     RLock rlock = redissonClient.getLock(lockName);
     try {
         return rlock.tryLock(lockWaitTime,autoReLockTime,exchangeTimeUnit(timeUnit));
     } catch (InterruptedException e) {
         return false;
     }
 }
 
 /**
 * 释放锁
 * @param lockName
 */
 public void releaseLock(String lockName){
     RLock rlock = redissonClient.getLock(lockName);
     rlock.unlock();
 }
 
 private TimeUnit exchangeTimeUnit(int _timeUnit){
     switch (_timeUnit) {
     case 1:
         return TimeUnit.SECONDS;
     case 2:
         return TimeUnit.MINUTES;
     case 3:
         return TimeUnit.HOURS;
     case 4:
         return TimeUnit.DAYS;
     }
     return TimeUnit.SECONDS;
 }
}

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
34
35
36
/**
 * src.test
 **/
public class TestRedissionShan {
 final String LOCK_KEY="TEST_123";
 
 public static void main(String[] args) {
 TestRedissionShan test1 = new TestRedissionShan();
 test1.testLock("test1");
 TestRedissionShan test2 = new TestRedissionShan();
 test2.testLock("test2");
 }
 
 public void testLock(String name){
//下面的三个地址以及端口可以参照上一篇文章redis集群，写入你配好的集群地址
 RedisDistributedLock redisDistributedLock = new RedisDistributedLock("192.168.122.32:9210,192.168.122.33:9211,192.168.122.34:9212",null,5L,1);
//第二个测试再将此段代码解除注释
// if ("test2".equals(name)){
// try {
// System.err.println(name+"准备睡眠6秒");
// Thread.sleep(6000);
// } catch (InterruptedException e) {
// e.printStackTrace();
// }
// }
 boolean lock = redisDistributedLock.getLock(LOCK_KEY);
 System.out.println(name+"拿到锁了吗？"+lock+"---线程名字："+Thread.currentThread().getName());
 if (lock){
 System.out.println(name+"拿到锁了准备操作。。。。。");
 System.out.println(name+"我自己测试还能不能加锁<"+redisDistributedLock.getLock(LOCK_KEY)+">");
 }else{
 System.err.println(name+"未拿到锁不操作。。。。。");
 }
 }
 
}