派单、支付、结算这几个关键动作，在三马代驾的架构里全都依赖消息队列解耦。队列一抖，丢一条消息，用户侧看到的就是"订单状态卡住"。这篇文章把我们在生产上踩过的消息问题收敛成三类：

一、丢消息：先搞清楚会丢在哪

消息从生产到消费要过三道关，每一道都可能丢：

把"发送"这件事变成一个本地消息表流程

// 1. 业务数据与待发消息同库写入（本地事务）
@Transactional
public void afterPaySuccess(PayCallback cb) {
    orderRepo.markPaid(cb.getOrderId());
    outboxRepo.save(OutboxMsg.of("order.paid", cb.getOrderId()));
}

// 2. 独立任务扫描 outbox 表，投递到 MQ，投递成功打标
// 3. 未打标记录按指数退避重投，超过上限进死信告警

数据库事务先保住"消息一定被记下来"，投递可靠性交给异步重试

。这样即便 MQ 短暂不可用，恢复后消息照样能补发出去。

二、重复消费：只靠 MQ 永远防不住

网络超时会引发一个经典误判——生产者以为发送失败重发了一条，消费者其实已经收到过。

at-least-once 语义下，重复是常态，去重必须在业务层做。

CREATE TABLE consume_log (
    biz_id    VARCHAR(64) PRIMARY KEY,
    consumer  VARCHAR(32) NOT NULL,
    created_at DATETIME NOT NULL
) ENGINE=InnoDB;

幂等表记录和业务变更新必须在同一个本地事务里

，否则会出现"记了幂等但业务没改"或反过来的空洞。

三、乱序：同一单据的事件必须串行

支付成功和退款到账可能几乎同时到达，如果消费者并发处理，就可能出现"状态被旧事件覆盖"。三马代驾的解法很直接：

再可靠的链路也要有兜底，我们保留了三层防线：

即使前面所有机制都失效，对账也能在第二天把账拉平

消息可靠投递不是靠一个开关解决的，它是一组组合拳：本地消息表保发送、幂等表保消费、分区与 CAS 保顺序、对账兜底全局。三马代驾把这套流程固化进了脚手架，新服务接入队列时默认就带上这些能力，而不是等出事故再补。

派单、支付、结算这几个关键动作，在三马代驾的架构里全都依赖消息队列解耦。队列一抖，丢一条消息，用户侧看到的就是"订单状态卡住"。这篇文章把我们在生产上踩过的消息问题收敛成三类：丢消息、重复消费、乱序，并给出对应的工程做法。

三马代驾实战：消息队列丢消息、重复消费与乱序，三类问题三套解法

消息队列丢消息、重复消费、乱序是高并发系统的三类高频故障。本文以三马代驾的派单支付链路为例，给出本地消息表保发送、幂等表挡重复、分区与CAS保顺序的完整做法，并用死信告警与T+1对账兑底。

架构设计

后端

数据库

消息队列故障导致订单状态卡住？三马代驾实战总结：丢消息用本地消息表+confirm+持久化；重复消费靠唯一键幂等表；乱序用分区+单线程+CAS更新；死信、监控、对账兜底，保消息可靠投递。

文章

问答

视频

教程

学习中心

腾讯云实验室

直播

竞赛

腾讯云代码分析专区

腾讯iOA零信任安全管理系统专区

腾讯云架构师技术同盟交流圈

腾讯云数据库专区

腾讯云智能顾问专区

腾讯云原生专区

腾讯混元专区

腾讯云TCE专区

腾讯云Lighthouse专区

腾讯云HAI专区

腾讯云Edgeone专区

腾讯云存储专区

腾讯云智能专区

腾讯轻联专区 

腾讯云开发专区

TAPD专区

腾讯轻量云游戏服专区

EdgeOne AI 安全实战专区

腾讯云最具价值专家

腾讯云架构师技术同盟

腾讯云创作之星

腾讯云开发者先锋

腾讯云代码助手

云原生构建

TAPD 敏捷项目管理

Cloud Studio

SDK中心

API中心

命令行工具

涵盖代码开发、场景应用、自动测试全流程，助你从零构建专属AI助手

一站式MCP教程库，解锁AI应用新玩法

聚焦“写作效率、视觉美观与运行性能”三方面进行全面升级，为您提供更高效、稳定的创作环境

社区富文本&Markdown编辑器全新改版上线，欢迎大家体验!

诚挚邀请您参与本次调研，分享您的真实使用感受与建议。您的反馈至关重要，感谢您的支持与参与！

三马代驾实战：消息队列丢消息、重复消费与乱序，三类问题三套解法

三马代驾实战：消息队列丢消息、重复消费与乱序，三类问题三套解法

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐