@Transactional用法详解与事务避坑指南
- 需求：业务单位需要观测订单动态，所以要在订单的各个状态节点上传状态至状态池系统
- 方案：又是Easy的需求，不就是在每个订单状态改变时触发上传状态，为了不影响订单正常流转，增加一个消息中间件MQ
前言
在Java中，@Transactional是一个非常重要的注解，用于声明事务管理的行为。
它可以被应用在类级别或方法级别上，并且提供了多种选项来控制事务的传播行为、隔离级别、超时设置和回滚条件等。
一、Java的@Transactional解释
@Transactional 注解在 Java 中用于声明式事务管理，它可以应用于接口、接口方法、类以及类的方法上。在默认配置下，Spring 中的 @Transactional 注解会使得方法在事务的上下文中执行，其事务边界默认为方法开始执行时开始，方法正常结束时提交事务，方法执行过程中抛出异常时回滚事务。
但是，你可以通过在 @Transactional 注解中设置 propagation 属性来改变事务的传播行为，例如可以设置为Propagation.MANDATORY，这意味着该方法必须在一个已经存在的事务中执行，否则就会抛出异常。
另外，你可以通过设置 phase 属性来改变事务的提交时机，例如可以设置为Phase.AFTER_COMPLETION，这样事务就会在整个事务完成后提交，不论事务是正常结束还是异常结束。
以下是一个使用 @Transactional 注解的示例，其中 propagation 设置为Propagation.REQUIRED（默认值），表示如果当前存在事务，则加入该事务；如果不存在，则创建一个新的事务。
import org.springframework.transaction.annotation.Transactional;
import org.springframework.stereotype.Service;
@Service
public class MyService {
@Transactional
public void someTransactionalMethod() {
// 方法执行的代码
}
}
二、踩坑
接到的需求中：每个订单状态改变时触发上传状态，为了不影响订单正常流转，增加一个消息中间件MQ
流程图如下：
二、状态统一入口：推送
private SendResult sendStatusToMq(SendStatusPoolMsgVo sendStatusPoolMsgVo) {
String msg = JSON.toJSONString(sendStatusPoolMsgVo, SerializerFeature.PrettyFormat,
SerializerFeature.WriteMapNullValue);
LOGGER.info("sendStatusPoolMsgToMq,发送的消息{}", msg);
Message<String> message = MessageBuilder.withPayload(msg).build();
SendResult sendResult = new SendResult();
try {
sendResult = rocketMQTemplate.syncSend(statusPoolTopic, message, 3000, 2);
} catch (Exception e) {
e.printStackTrace();
log.error("sendStatusToMq err", e);
TaskMqModel taskMqModel = new TaskMqModel();
taskMqModel.setTopic(statusPoolTopic);
taskMqModel.setMessageType(MessageTypeConstant.MQ_SUPPLE_STATUSPOOL);
taskMqModel.setDisposeFlag(RequestConstant.REQUEST_ORIGINAL);
taskMqModel.setRawMessage(msg);
taskMqModel.setCreateTime(new Date());
taskMqService.save(taskMqModel);
}
return sendResult;
}
我这里做了个状态统一入口，同时为了避免推送MQ服务失败，做了个异常捕获保存推送消息，方便重推。
三、MQ消费
// ... 其他业务逻辑 ...
// 获取订单信息
String orderNo = msgVo.getOrderNo();
orderModel orderModel = orderService.getOrderByOrderNo(orderNo);
//如果是客户下单再去待处理订单查询
if (Objects.isNull(fmOrderModel)) {
LOGGER.err("未查到信息，初始化失败！");
return;
}
//
然后我的日志全是：
[2024-08-8 08:36:50.161][ERROR][ConsumeMessageThread_2] 未查到信息，初始化失败！ [2024-08-8 08:37:57.015][ERROR][ConsumeMessageThread_2] 未查到信息，初始化失败！ [2024-08-8 08:42:45.536][ERROR][ConsumeMessageThread_2] 未查到信息，初始化失败！
我查看数据库是完全能查到的，有点奇怪❗❗❗❗❓❓❓❓
四、问题与解决
在Java中，@Transactional 注解通常用于声明方法执行的事务边界，确保方法内的一系列操作要么全部成功，要么全部失败。它通常与Spring框架的事务管理器一起使用，以提供声明式的事务管理。
如果你的订单数据保存操作使用了 @Transactional，并且在保存数据之后立即推送消息到消息队列（MQ），那么消费者可能查不到数据的原因可能与事务的隔离级别有关。
下面是我搜到的一些可能导致该问题的原因：
- 事务隔离级别：如果你的数据库事务使用了较高的隔离级别（如可重复读或串行化），那么在事务提交之前，其他事务（包括MQ消费者）可能看不到该事务所做的更改。
- 事务传播行为：如果MQ消费者也运行在Spring管理的事务中，并且事务的传播行为设置为不支持当前事务（例如，
Propagation.NOT_SUPPORTED），那么消费者可能会在不同的事务上下文中运行，从而看不到未提交的更改。 - 延迟提交：如果事务在消息发送之后才提交，MQ消费者可能会在事务提交之前读取数据库，因此看不到新数据。
- MQ消息延迟：如果消息队列本身存在延迟，消费者可能会在数据还未写入数据库时就接收到消息。
- 数据库缓存：某些数据库实现可能会缓存数据，这可能导致即使数据已经写入，消费者也无法立即看到更新。
- MQ消费者处理逻辑：如果MQ消费者在处理消息时没有正确地处理事务或数据库查询，也可能导致查不到数据。
解决方式
在Spring框架中，我通过实现TransactionSynchronization接口来在事务提交后执行回调操作。
以下是实现事务提交回调发送消息的方法：
@Component
public class TransactionalMessageSender implements TransactionSynchronization {
@Autowired
private SomeMessageService messageService; // 消息发送服务
@Override
public void beforeCommit(boolean readOnly) {
// 这里可以执行一些操作，但事务还未提交
}
@Override
public void beforeCompletion() {
// 事务即将提交，可以在这里准备发送消息
}
@Override
public void afterCommit() {
// 事务已经提交，可以在这里发送消息
sendResult = rocketMQTemplate.syncSend(statusPoolTopic, message, 3000, 2);
}
@Override
public void afterCompletion(TransactionStatus status) {
// 事务已经完成，无论是提交还是回滚
if (status == TransactionStatus.COMMITTED) {
// 这里可以执行一些事务提交后的清理工作
}
}
}
五、总结
在 Spring 框架中使用 @Transactional 注解时，事务管理器会在事务边界内管理数据库操作。
当你在一个事务中执行数据库操作后立即发送消息到消息队列（MQ），可能会遇到一个问题：MQ 消费者在接收到消息并尝试查询数据库时，发现数据库中并没有预期的数据。
这个问题的根本原因在于事务的隔离级别和事务提交的时间点。
当事务尚未提交时，其他事务（包括 MQ 消费者的查询操作）是无法看到该事务内的修改的。
即使你在事务中已经执行了数据库操作（如插入或更新），这些修改对其他事务来说仍然是不可见的，直到当前事务提交。
以上为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。
相关文章
Java matches类，Pattern类及matcher类用法示例
这篇文章主要介绍了Java matches类，Pattern类及matcher类用法,结合实例形式分析了java matches类，Pattern类及matcher类针对字符串常见操作技巧与相关注意事项,需要的朋友可以参考下2019-03-03
SpringBoot中缓存@Cacheable出错的问题解决
本文主要介绍了SpringBoot中缓存@Cacheable出错的问题解决,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧2025-10-10
这篇文章主要介绍了mybatisPlus批量插入优化加快性能,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下2023-12-12
Jackson是一个用于处理Json数据的Java库，它提供了一系列功能，包括Json序列化和反序列化，所以本文就来讲讲如何利用利用Jackson解决Json序列化和反序列化的问题吧2023-05-05
下面小编就为大家带来一篇Java程序实现导出Excel的方法(支持IE低版本)。小编觉得挺不错的，现在就分享给大家，也给大家做个参考。一起跟随小编过来看看吧2016-07-07
JVM的启动参数是在启动JVM时可以设置的一些命令行参数,本文详细的介绍了深入理解jvm启动参数,具有一定的参考价值,感兴趣的可以了解一下2023-08-08
这篇文章主要介绍了利用java读取resource目录下文件的方法，文中给出了详细的示例代码，相信对大家具有一定的参考借鉴，需要的朋友们下面来一起看看吧。2017-02-02
这篇文章主要介绍了Java中断线程的方法,非常不错，具有参考借鉴价值，需要的朋友可以参考下2017-05-05
本文介绍了如何使用MybatisMetaObject类和FieldUtil工具类来简化Java类嵌套获取属性值的过程,通过这种方式,可以避免逐层检查和判空操作,直接从实例对象中获取深层嵌套的属性值,并且在任意一层为空时自动返回null,不会报错2025-11-11
这篇文章主要介绍了java判断两个时间是不是同一天的方法,需要的朋友可以参考下2014-02-02
最新评论