保存更新失败，事务回滚，但是MQ消息发送成功。

系统上线后，偶尔出现一些小的问题，逻辑处理是先更新数据，在发MQ消息，正常情况下，只要没有网络问题或者超时等问题，数据都能保存成功，紧接着就是发送消息，但是偶尔会出现数据保存失败，事务回滚，但是消息却发出去了！！（或者更新之后事务没提交，mq就已经发送出去了）
所以鉴于代码不完善，需要对发消息做逻辑处理，

解决方案：

1、在开发时为了方便就直接让查询业务延迟查询，不过这种方法不太可能在实际部署时用到，影响性能
2、在事务提交后再去执行发送消息

   TransactionSynchronizationManager.registerSynchronization(new AbstractAfterCommitTransactionSynchronization() {@Overridepublic void afterCommit() {WsAdminInspectionRecord wsAdminInspectionRecord1 = wsAdminInspectionRecordMapper.selectById(merchantOrderId1);mqService.sendUtils(merchantOrderId1,wsAdminInspectionRecord1.getDetectType(),wsAdminInspectionRecord1.getOssName(),wsAdminInspectionRecord1.getTemplateId(),wsAdminInspectionRecord1.getFileName());}});

逻辑中增加了AbstractAfterCommitTransactionSynchronization抽象类，用于事务成功提交后，在执行发送消息，代码如下：

package com.ws.common.config.activemq;
import org.springframework.transaction.support.TransactionSynchronization;/*** 用于事务成功提交后，在执行发送消息** @author zc* @mail zhangcongovo@163.com* @date 2022/4/15.*/public abstract class AbstractAfterCommitTransactionSynchronization implements TransactionSynchronization {@Overridepublic void suspend() {}@Overridepublic void resume() {}@Overridepublic void flush() {}@Overridepublic void beforeCommit(boolean readOnly) {}@Overridepublic void beforeCompletion() {}@Overridepublic void afterCompletion(int status) {}}

保存更新失败，事务回滚，但是MQ消息发送成功。相关推荐

spring注解事务及事务回滚失败的原因
背景 spring支持编程式事务管理和声明式事务管理两种方式. 编程式事务管理使用TransactionTemplate或者直接使用底层的PlatformTransactionManager.对于编程 ...
Spring事务回滚失败
下面是一个回滚事务的案例需求是:转账失败后转账的事务会回滚,日志事务不会回滚出现的问题是: 日志事务开启了@Transactional(propagation = Propagation.REQ ...
spring mysql 事务回滚失败_Spring事务回滚失败
我在Service层里面调用两个Dao层的方法.一个方法用于储存一行Investor数据,一个方法用于储存和有Investor主键的Address数据.service层方法如下,注意Investor继 ...
mysql 主键冲突多个事务回滚_MySQL实战45讲Day38----自增主键不是连续的原因
一.自增主键不连续的原因: 对于表: CREATE TABLE `t` ( `id` int(11) NOT NULL AUTO_INCREMENT, `c` int(11) DEFAULT NULL ...
Mysql事务回滚机制与原理
Mysql事务回滚机制与原理文章目录 Mysql事务回滚机制与原理一.事务回滚机制二.使用到的技术讨论三.redo log和undo log介绍 3.1 redo log 3.2 undo l ...
什么是事务和事务回滚？
数据库理解事务: 为什么要有事务? 事务应用于各种场景,订单系统.银行系统例如: 小明去某银行取钱,首先有以下几个步骤: 银行卡放入ATM机.,输入密码连接数据库,验证账户密码验证成功,获得用户 ...
mysql分类和事务回滚
主要内容: ***数据定义语言DDL重点 ***数据操纵语言DML重点数据查询语言DQL重点 ---事务控制语言TCL ---数据库控制语言DCL ---主键(primary key) ---数据冗 ...
事务回滚什么意思 try_分布式事务 TCC-Transaction 源码分析——事务恢复
1. 概述本文分享 TCC 恢复.主要涉及如下二个 package 路径下的类: org.mengyun.tcctransaction.recover RecoverConfig,事务恢复配置接口 ...
Spring事务—方法调用事务回滚
转自:https://blog.csdn.net/m0_38027656/article/details/84190949 写这篇文章的初衷呢就是最近遇到了一个spring事务的大坑.与其说是坑,还不 ...
mysql的回滚机制_mysql事务回滚机制概述
应用场景: 银行取钱,从ATM机取钱,分为以下几个步骤 1 登陆ATM机,输入密码: 2 连接数据库,验证密码: 3 验证成功,获得用户信息,比如存款余额等: 4 用户输入需要取款的金额,按下确认键: ...

保存更新失败，事务回滚，但是MQ消息发送成功。

解决方案：

保存更新失败，事务回滚，但是MQ消息发送成功。相关推荐

最新文章

热门文章