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);
}
}
最新文章
- .NET 基础一步步一幕幕[方法、结构、枚举]
- Ueditor上传图片后自定义样式类名
- 十一个行为模式之命令模式(Command Pattern)
- linux 文件管理以及其相关指令
- RHCE实验环境|rhel7-lab
- linux服务之tuned
- Phpcms V9网站从本地上传到服务器需要修改的地方
- web页面的适配问题
- DOS攻击之详解--转载
- SQL游标
- Java——(五)Collection之List集合、ArrayList和Vector实现类
- Nginx Http模块开发
- php 下载保存文件保存到本地的两种实现方法
- MySQL与MongoDB
- java 中数据的强制转换 和计算的补码运算
- 色彩空间-- RGB\HSV
- I18nUtils
- jquery查找筛选器
- MathType中输入破折号的教程
- BZOJ1568: [JSOI2008]Blue Mary开公司【李超树】
热门文章
- 关于Domino数据库的软删除
- linux部署war包方案
- 第六章 - 图像变换 - 图像拉伸、收缩、扭曲、旋转[1] - 仿射变换(cvWarpAffine)
- android实现自动升级并安装打开
- 一台服务器部署多个tomcat
- distri.lua重写开源手游服务器框架Survive
- javascript方法 call()和apply()的用法
- 使用Javascript来创建一个响应式的超酷360度全景图片查看幻灯效果
- ZooKeeper与Curator注册和监控
- 安卓开发笔记——探索EventBus