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工具类，在前提中有*/@Autowiredprivate RedisUtil redisUtil;/*** redisson，只需要配置一个配置类就可以使用了，可以看前提中redisson的文章*/@Resourceprivate Redisson redisson;/*** 订单状态变更* @param json* @return*/public boolean orderStatusChange(JSONObject json){try {// ...// 上面拼接需要入库的逻辑得到订单状态变更的实体类信息，不可能把源码展示出来，我仅放关键代码，order 就相当于从 MQ 获取的内容封装成了实体类 orderOrder 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 {// 判断新建订单执行了吗，因为我的逻辑是如果新建订单执行后会执行下述注解中的代码，存一个两小时的 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多余的keyredisUtil.delete("前缀_ORDER_" + json.getString("订单号"));} catch (Exception e) {logger.error("订单状态推送同步锁失效",e);}finally {// 判断当前线程是否持有锁if (success && lock.isHeldByCurrentThread()) {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 {// 设置两个小时缓存，超时就认为不付款了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多余的keyredisUtil.delete("前缀_STATUS_PUSH_" + json.getString("订单号"));}} catch (Exception e) {logger.error("订单新建推送同步锁失效",e);}finally {// 判断当前线程是否持有锁if (success && lock.isHeldByCurrentThread()) {lock.unlock();}}return true;} catch (Exception e) {logger.error("新建导购商户订单：",e);return false;}}