当前位置：首页 > news >正文

穿透 MQ 专栏 (五)：【终局之战】MySQL 和 MQ 的世纪联姻：扒开“分布式事务”的遮羞布

news 2026/5/12 23:56:51

读到这篇大结局，你已经陪我走过了 MQ 架构中最泥泞的沼泽。我们用“削峰”保住了服务器的命，用“ACK与落盘”防住了消息丢失，用“状态机”杀死了重复扣款，甚至在百万积压的灾难中完成了一场教科书般的救火。

可以说，在单节点系统和纯 MQ 领域，你已经是无敌的存在了。

但是，当你回到工位，看着自己写下的那段最核心的“支付回调”代码时，你的背后突然感到一丝凉意。

Java

@Transactional public void paySuccess(String orderId) { // 1. 本地数据库扣减余额 accountDB.decreaseBalance(orderId); // 2. 发送 MQ 消息，通知物流系统发货 mqTemplate.send("Fahuo_Topic", orderId); }

你以为加上了@Transactional这个神圣的注解，就能保证这两行代码“要么全成功，要么全失败”。

大错特错！在真实的分布式物理世界里，Spring 的@Transactional就是一张一捅就破的窗户纸！

今天，作为本专栏的压轴大戏，我们将直击整个后端架构的深水区：扒开“分布式事务”的遮羞布，看看大厂是如何解决本地 MySQL 与外部 MQ 之间，那令人绝望的“数据一致性”难题的。

一、噩梦场景：无解的“双写难题（Dual-Write）”

为什么说上面的代码是车祸现场？我们来做极其残酷的物理推演。

@Transactional的底层逻辑是：等你的业务代码全部执行完，Spring 才会去向 MySQL 发起Commit（提交）。而外部的网络环境是极度不可靠的。

车祸现场 1：先写 DB，后发 MQ

推演：余额扣减成功了，正准备发 MQ 时，服务器所在的机柜突然停电！代码没走完，Spring 的事务跟着服务器一起死了（未提交），MySQL 数据回滚。结果是：钱没扣，货没发。这很完美。
致命的变数：余额扣减成功了。MQ 也发送成功了！就在 Spring 准备向 MySQL 发送终极Commit指令的那一秒，数据库死锁报错了！或者主键冲突报错了！
结局：数据库悲愤地回滚了扣款操作。但是！你的 MQ 消息已经像泼出去的水一样，顺着网线飞到了物流系统。
客诉：客户一分钱没花，你们公司把价值一万块的货给他发出去了。老板立刻让你卷铺盖走人。

车祸现场 2：那我先发 MQ，后写 DB 行不行？

推演：先把“发货消息”发给了 MQ。物流系统瞬间消费，把货装车。紧接着准备写 DB 扣款，结果网络卡了一下，数据库报错。
结局：同上。钱没扣，货发了。

这就是臭名昭著的分布式双写难题（Dual-Write Problem）：一个归本地数据库管，一个归外部网络管。没有任何本地事务能同时罩住它们俩。

二、主流大厂的救命稻草：本地消息表（Outbox Pattern）

既然跨网络无法保证事务，那我们能不能用魔法打败魔法？架构师的破局思路：把外部网络问题，强行转化成本地数据库问题！

这就是目前业界使用最广泛、最稳如老狗的兜底方案——本地消息表（Outbox Pattern）。

【工程实战推演】

建表：在你的业务数据库（和扣款表在同一个 MySQL 实例中）里，新建一张表叫local_message_log（本地消息表）。

神仙同框：现在，你的代码变成了这样：

Java

@Transactional public void paySuccess(String orderId) { // 1. 本地数据库扣减余额 accountDB.decreaseBalance(orderId); // 2. 本地数据库写入一条消息日志！状态为“待发送” messageLogDB.insert(new MessageLog(orderId, "待发送")); }

奇迹发生了：因为扣余额和写消息日志在同一个本地 MySQL 里！所以@Transactional完美生效。这两步绝对是同生共死，绝对符合 ACID 强一致性！

扫表大军：代码里再写一个定时任务（或者用 Canal 监听 Binlog），每隔 1 秒去疯狂扫描local_message_log里“待发送”的数据。
死磕投递：定时任务拿到数据后，向 MQ 投递。
- 如果发送失败？没关系，状态还是“待发送”，下一秒接着扫，接着发！死磕到底。
- 如果收到 MQ 的成功 ACK，就把数据库里的状态改为“已发送”。

评价：这个方案极度稳健，逻辑清晰。唯一的缺点是：把业务数据库当成了消息中转站，定时任务疯狂扫表会增加数据库的 I/O 压力。

三、极致黑科技：RocketMQ 的“半消息”（事务消息）

本地消息表虽然稳，但不够优雅。阿里的一群疯子架构师站了出来：“如果每次都要在业务库里建一张破表，这也太搓了！我们能不能让 MQ 自己来承担事务协调者的角色？”

于是，震惊业界的RocketMQ 事务消息黑科技（Half Message）诞生了。它巧妙地借鉴了支付宝“担保交易”的哲学。

【大片级的底层推演】假设你的系统叫 A，你要发消息给系统 B。

第一步：发送“半消息”（支付宝打款）系统 A 先向 RocketMQ 发送一条极其特殊的“半消息”（Half Message）。黑科技点：RocketMQ 收到这条消息后，会把它藏在一个内部的隐藏队列里。消费者（系统 B）此时绝对看不见这条消息！
第二步：执行本地事务（验货）系统 A 收到 RocketMQ 的“半消息投递成功”回执后，开始执行本地 MySQL 的扣款动作。
第三步：二次确认（确认收货或退款）
- 如果本地扣款成功了，系统 A 告诉 RocketMQ：“我完事了，你可以把那条半消息变可见（Commit）了！” 系统 B 瞬间消费，发货。
- 如果本地扣款失败/抛异常了，系统 A 告诉 RocketMQ：“我炸了，赶紧把那条半消息销毁（Rollback）！”
【终极杀招：反查机制】你可能会问：如果第三步，系统 A 在向 MQ 发送Commit的时候，网线被老鼠咬断了怎么办？！半消息岂不是永远悬在半空了？ RocketMQ 微微一笑。如果一条半消息挂了很久没人理，RocketMQ 会主动顺着网线发起反向查询（Transaction Check）！它会来敲系统 A 的门：“哥们，你刚才发了半消息，然后就不吱声了。你本地的扣款到底成功了没？你查一下告诉我！” 系统 A 查了一下本地对账表：“哎呀不好意思，刚才网断了，其实我扣款成功了。”于是告诉 MQ：“去 Commit 吧！”