学习spring事务与消息队列
在开发过程中，遇到一个bug，产生bug的原因是spring事务提交晚于消息队列的生产消息，导致消息队列消费消息时获取到的数据不正确。这篇文章介绍问题的产生和一步步的解决过程。
一.问题的产生：
场景还原：接口中的一个方法，首先修改订单状态，然后向消息队列中生产消息，消息队列的消费者获取到消息检测订单状态，发现订单状态未更改。
代码：
@Service(orderApi)
public class OrderApiImpl implements OrderApi {
@Resource MqService mqService;
@OrderDao orderDao;
public void push(String orderId) {
// 更新订单状态，之前的状态是1
updateStatus(orderId, 3);
// 产生消息
mqService.produce(orderId);
}
public viod updateStatus(String orderId, Integer status) {
orderDao.updateStatus(orderId, status);
}
}
问题产生原因：orderApi中的所有方法都有事务，事务类型PROPAGATION_REQUIRED，所以push方法对数据的操作会在push代码全部执行之后提交，而在事务提交之前消息队列的消息已经产生所以消息队列中消费到的订单从数据库查询出的状态可能还为1。为了让bug现象更明显，可以在push方法最后添加：
try {
Thread.sleep(10000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
这样就会发现消费消息时，订单状态一定是未修改的。
二.问题的解决：
解决方案：在更新数据时，新建一个事物，保证更新代码执行完成后，更新数据库的事务已被提交。（确保消息产生前数据库操作已提交）
按照上述方案，我首先想到的是直接修改updateStatus方法的事务类型；我将此方法的事务类型改为PROPAGATION_REQUIRES_NEW（新建事务，如果当前存在事务，把当前事务挂起）。
但是这么做有两点不合适：
1.强制修改了updateStaus的事务类型，可能影响其他流程。
2.未起到作用，updateStaus方法中没有新建事务。
关于第二点的解释：spring添加事务是通过BeanNameAutoProxyCreator实现的动态代理，只是给bean对象添加了事务，现在在类内部调用方法，是不会触发新事物的创建的。
所以在经过以上尝试后，我创建了一个新的类：
@Service("orderExtApi")
public class OrderExtApiImpl {
@Resource OrderApi orderApi;
public void updateStatusNewPropagation(String orderId) {
orderApi.updateStatus(orderId);
}
}
并为updateStatusNewPropagation方法添加事务PROPAGATION_REQUIRES_NEW
这个类就只是为了给orderApi中的updateStaus方法新起一个事务。
ok，到此为止bug已经解决了。
但是代码中还是存在问题：对数据库的操作已经提交，如果生产消息出现异常对业务逻辑来说还是错误的。所以需要检测消息的产生是否完成。
最终orderApi中的代码如下：
@Service(orderApi)
public class OrderApiImpl implements OrderApi {
@Resource MqService mqService;
@Resource OrderDao orderDao;
@Resource OrderExtApiImpl orderExtApi;
public void push(String orderId) {
// 更新订单状态，之前的状态是1
orderExtApi.updateStatusNewPropagation(orderId, 3);
// 产生消息--produce会检测是否出现异常 当返回1时表示生产消息成功
Response response = mqService.produce(orderId);
if (response.getCode() != 1) {
log.info("消息队列生产消息异常：" + response.getErrorMsg())
// 生产消息异常，重置状态 等待下次重新执行
orderExtApi.updateStatusNewPropagation(orderId, 1);
}
}
public viod updateStatus(String orderId, Integer status) {
orderDao.updateStatus(orderId, status);
}
}
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。
相关文章
Spring核心容器之ApplicationContext上下文启动准备详解
这篇文章主要介绍了Spring核心容器之ApplicationContext上下文启动准备详解,ApplicationContext 继承自 BeanFactory ,其不仅包含 BeanFactory 所有功能,还扩展了容器功能,需要的朋友可以参考下2023-11-11
这篇文章主要介绍了Java中的动态和静态编译实例详解的相关资料,需要的朋友可以参考下2017-04-04
这篇文章主要介绍了SpringBoot开发之拦截器实例,Spring Boot简介Spring Boot发展史SpringBoot的魅力SpringBoot的优点总结Spring Boot是一个基于Spring框架的快速开发脚手架,它简化了Spring应用的初始化和搭建过程,需要的朋友可以参考下2023-09-09
这篇文章主要介绍了springboot中@Async默认线程池导致OOM问题，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2020-06-06
本文主要讲解了Zookeeper的基础知识，ZooKeeper提供了一个通用协调模式实现方法的开源共享库，使程序员免于写这类通用的协议。关于Zookeeper更多相关知识，感兴趣的小伙伴参考一下这篇文章2021-09-09
这篇文章主要为大家介绍了MyBatis中的占位符全面详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪2023-03-03
这篇文章主要为大家详细介绍了Java如何轻松实现在Excel中添加超链接功能,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下2024-01-01
这篇文章主要介绍了详解Java中Math.round()的取整规则，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2020-05-05
基础掌握怎么样，用实战检验就知道了，本篇文章手把手带你用java+SpringBoot+Maven+Vue+mysql实现一个在线服装销售商城系统,大家可以在过程中查缺补漏，提升水平2022-01-01
elasticsearch源码分析index action实现方式
这篇文章主要为大家介绍了elasticsearch源码分析index action实现方式，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪2022-04-04
最新评论