Redisson分布式锁实战

实战来源

此问题基于电商

这周遇见这么一个问题，简略的说一下

由MQ发布了两个消息，一个是订单新增，一个是订单状态变更

由于直接付款之后，这两个消息的发布时间不分先后，可能会造成两种情况，1、订单状态变更在订单新增之前；2、订单新增在订单状态变更之前

逻辑二没有问题，有问题的是逻辑一，如果订单状态变更在订单新增之前，那么连新建订单都没有入库，怎么能改变订单的状态呢

为了完成这个逻辑就需要使用锁来让两个业务同步，必须让新建订单在订单状态变更之前，我这里使用的是基于Redisson的分布式Redis锁

前提，需要了解Redisson分布式锁、redis

redisson：Redis实现分布式锁原理和Redisson框架实现分布式锁，全网最详细讲解_

redis工具类：Redis工具类（redisTemplate）以及 redisTemplate 的用法

代码如下，从MQ取消息的的逻辑我就不写了

这里的代码还是有问题的，但在生产中95%可能遇不见，要么服务器炸了，要么redis挂了，要么其他人的接口被人发现漏洞随意调用，导致MQ传递参数有误，那么都是别人的问题，跟我们没关系

因为同一订单，订单新建和订单状态变更的订单号就是一样的，我用Redis做了以下三个K-V键值对

1、redis的key="前缀_STATUS_SYNCHRONIZATION_" + json.getString("订单号")

这个是，redis锁的key，保证新建订单和订单状态变更的主要逻辑能同步，value由redisson生成我们不用管，只用管超时时间就好了

2、redis的key="前缀_NEW_ORDER_" + json.getString("订单号")

这个是，判断是否新建订单在订单状态变更之前，有下述两种情况

• 如果新建订单在订单状态变更之前，那么新建订单时会存入这个2中的redis的K-V值，在订单状态变更的时候会用redis访问2中的key发现不为空（redis存在2中的K-V关系），就直接走入库操作
• 如果订单状态变更在新建之前，访问redis2的这个key发现为空（redis不存在2中的K-V关系），就用下述3中的K-V把需要入库的订单状态变更的实体类存起来，由新建订单时候调用时。新建订单时发现下述3中的K-V存在就说明订单状态变更在新建订单之前，就需要把下述3中的V取出来做入库处理，否则就认为新建订单在订单状态变更之前，就不需要做处理

value无所谓是什么，不重要，我这里就写的value=等待付款 没什么特殊含义。设置了两个小时的超时时间，因为订单超过两个小时了就不让付款了

3、redis的key="前缀_STATUS_PUSH_" + json.getString("订单号")

这个是，如果订单状态变更在新建订单之前，那么我就存进去，由新建的时候判断是否存在这个值，如果存在就说明订单在状态变更之前，就取出这个key对应的value（因为我们存的就是订单状态变更时需要的数据）做入库处理，不存在说明新建订单在订单状态变更之前就不需要做处理

	/**
	 * 我的redis工具类，在前提中有
	 */
	@Autowired
	private RedisUtil redisUtil;

	/**
	 * redisson，只需要配置一个配置类就可以使用了，可以看前提中redisson的文章
	 */
	@Resource
	private Redisson redisson;

	/**
	 * 订单状态变更
	 * @param json
	 * @return
	 */
	public boolean orderStatusChange(JSONObject json){
		try {
			// ...
			// 上面拼接需要入库的逻辑得到订单状态变更的实体类信息，不可能把源码展示出来，我仅放关键代码，order 就相当于从 MQ 获取的内容封装成了实体类 order
			Order order = new Order();

			// 主要看下面的代码
			// 只有付款的时候走此逻辑，因为可能出现，直接付款，状态推送和新建订单一起发过来且付款先执行的操作
			if (json.getString("code").equals("付款的code")){
				// 如果已付款是先执行就先缓存由新建调用
				RLock lock = redisson.getLock("前缀_STATUS_SYNCHRONIZATION_" + json.getString("订单号"));
				// 60秒自旋拿锁，拿到锁之后持有60秒 （如果后面的值 <0 的话会使用开门狗机制，一直持有锁，除非项目挂掉了）
				boolean success = lock.tryLock(60L, 60L, TimeUnit.SECONDS);
				try {
					// 没拿到锁就报错,终止任务,RedisLockFailureException 是自定义的
					if (!success){
						throw new RedisLockFailureException("同步锁失效");
					}
					// 判断新建订单执行了吗，因为我的逻辑是如果新建订单执行后会执行下述注解中的代码，存一个两小时的 redis 缓存，因为新建订单之后两个小时不付款就取消订单了
					// 这是新建订单后设置的值： redisUtil.set("前缀_NEW_ORDER_" + json.getString("订单号"),"已经新建订单",7200);
					if (redisUtil.get("前缀_NEW_ORDER_" + json.getString("订单号")) == null){
						// 如果为上诉为空，说明订单状态变更在订单新增之前，我们就缓存一下300秒，至于多少秒看着办吧，300就太多了，但不影响
						redisUtil.set("前缀_STATUS_PUSH_" + json.getString("订单号"),JSON.toJSONString(order),300);
						// 因为在之前就不需要执行之后的代码了，返回就行
						return true;
					}
                    // 删除redis多余的key
					redisUtil.delete("前缀_ORDER_" + json.getString("订单号"));
				} catch (RedisLockFailureException e){
					logger.error("订单状态推送同步锁失效",e);
					throw e;
				} catch (Exception e) {
					logger.error("订单状态推送业务逻辑报错",e);
					throw e;
				}finally {
					// 判断当前线程是否持有锁
					if (lock.isLocked()) {
						lock.unlock();
					}
				}
			}
            // 如果新增在订单状态变更之前就可以直接入库了，如果订单状态变更在新建之前的话，上面有return操作，就不会执行入库操作
			statusChangeReceiptOperation(order);
			return true;
		} catch (Exception e) {
			logger.error("订单状态变更 报错：",e);
			return false;
		}
	}

	/**
	 * 订单状态变更入库操作
	 * @param order
	 */
	private void statusChangeReceiptOperation(Order order){
		try {
			// 订单状态变更入库操作。。。
		} catch (Exception e) {
			logger.error("订单状态变更报错：",e);
		}
	}


	/**
	 * 新建订单
	 */
	public boolean newOrder(JSONObject json){
		try {
			// 入库操作，因为订单新增肯定是最开始的，所以根据json的参数直接入库就行了，我就不写了
			// 。。。

			// 加和上述相同的锁，因为订单号是一样的
			RLock lock = redisson.getLock("前缀_STATUS_SYNCHRONIZATION_" + json.getString("订单号"));
			// 60秒自旋拿锁，拿到锁之后持有60秒 （如果后面的值 <0 的话会使用开门狗机制，一直持有锁，除非项目挂掉了）
			boolean success = lock.tryLock(60L, 60L, TimeUnit.SECONDS);
			try {
				// 没拿到锁就报错,终止任务,RedisLockFailureException 是自定义的
				if (!success){
					throw new RedisLockFailureException("同步锁失效");
				}
				// 设置两个小时缓存，超时就认为不付款了
				redisUtil.set("前缀_NEW_ORDER_" + json.getString("订单号"),"等待付款",7200);
				// 去拿订单状态变更设置的redis的k-v键值对
				Object o = redisUtil.get("前缀_STATUS_PUSH_" + json.getString("订单号"));
                // 判断这里为不为空，因为加了锁，为空说明新增在订单状态变更之前，不需要多余操作
				if (o != null){
					// 如果不为空，说明状况变更在新增之前，取值然后入库
					JSONObject out2 = JSON.parseObject(o.toString());
                    // json转为实体类
					Order order = JSONObject.toJavaObject(out2,Order.class);
                    // 入库
					statusChangeReceiptOperation(order);
                    // 删除redis多余的key
					redisUtil.delete("前缀_STATUS_PUSH_" + json.getString("订单号"));
				}
			} catch (RedisLockFailureException e){
				logger.error("订单新建推送同步锁失效",e);
				throw e;
			} catch (Exception e) {
				logger.error("订单新建业务逻辑报错",e);
				throw e;
			}finally {// 判断当前线程是否持有锁
				if (lock.isLocked()) {
					lock.unlock();
				}
			}
			return true;
		} catch (Exception e) {
			logger.error("新建导购商户订单：",e);
			return false;
		}
	}
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
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129

我遇见的问题

Factory method 'redisson' threw exception; nested exception is java.lang.NoSuchMethodError: io.netty.util.NetUtil.isIpV4StackPreferred()Z

猜测原因：NetUtil没有redisson需要的isIpV4StackPreferred()方法

排查：发现两个相同的class文件，那么肯定是jar包冲突了

查看依赖：

发现是这个包有问题：

去pom文件中排除：

总结

这只是我的思路和解决方法，如果有大佬有更好的办法，希望可以劳烦跟我探讨一下，共同成长，万分感谢