`Outbox + CDC` 是一种替代分布式事务（比如 XA/2PC）的常见方案，用来在「DB + 消息队列」之间实现**最终一致性**。

---

## 1\. 要解决什么问题

典型场景：  
业务更新数据库，同时要发一条消息到 MQ（或 Kafka、RocketMQ 等）：

* 本地事务提交成功，但发消息失败 → 下游系统没收到，数据不一致  
* 先发消息，后更新库，中间失败 → 下游收到了消息，但库没更新，也不一致

**Outbox + CDC** 的目标：  
不再依赖跨资源的强一致事务（2PC/XA），而是：

* 只用 **数据库本地事务** 保证「业务数据 + 消息记录」在同一个库里原子写入  
* 用 **CDC 组件** 把这些消息记录可靠地「扫」出来，发到 MQ  
* 最终达到「数据库状态和消息流最终一致」

---

## 2\. Outbox 模式核心思路

### 2\.1 Outbox 表

在业务数据库里加一张 `outbox` 表（名字随便），字段类似：

* `id`：自增或雪花 ID  
* `aggregate_type` / `biz_type`：业务类型，比如 ORDER、USER 等  
* `aggregate_id` / `biz_id`：业务主键，比如订单号  
* `event_type`：事件类型 CREATED、UPDATED 等  
* `payload`：JSON 字符串，存储要发到 MQ 的消息体  
* `status`：NEW / SENT / FAILED  
* `created_at` / `updated_at`：时间

### 2\.2 本地事务里同时写业务表和 Outbox 表

示意（伪代码）：

* 开启本地事务
* 更新业务表（比如 `order`）
* 插入一条 `outbox` 记录（`status = NEW`，`payload` 为要发的消息）
* 提交事务

这样可以保证：**只要订单成功更新，肯定有一条 outbox 记录；只要订单没更新成功，就没有这条 outbox 记录**。

---

## 3\. CDC（Change Data Capture）

CDC 用来「捕获」数据库里新增的 outbox 记录，然后发到 MQ。

有两类实现方式：

### 3\.1 基于日志的 CDC（推荐）

利用 MySQL binlog：

* 用 Debezium、Canal 之类的组件订阅 binlog  
* 配置只关注 outbox 表  
* 一旦发现有新的 `status = NEW` 的记录：
  * 解析 `payload`，发到 Kafka / MQ  
  * 处理成功后，可以：
    * 直接把 outbox 这条记录标记成已发送（`status = SENT`），或  
    * 由消费端完全依赖幂等，不回写 status（简单一点）

优点：

* 不用写轮询任务，对数据库压力小  
* 保证顺序性好，类似「append-only log」

### 3\.2 应用内轮询（简单版）

如果不引入 Debezium/Canal，也可以：

* 写一个 Spring 定时任务，从 outbox 表查 `status = NEW` 的记录  
* 一条条发到 MQ  
* 发成功后更新 `status = SENT`  
* 失败则重试 / 打标 `FAILED`

缺点：

* 有轮询延迟  
* 频繁查询，有性能问题  
* 需要自己处理幂等、重试、死信等

通常生产环境建议用 **日志型 CDC（Debezium + Kafka）** 这类成熟方案。

---

## 4\. 和 2PC/XA 相比的特点

**优点：**

* 不依赖资源 XA 支持（Redis, 应用程序 本来就不支持 XA）  
* 没有跨资源的长事务、长锁，对数据库性能友好  
* 故障可恢复：消息没成功发，只要 outbox 记录还在，下次 CDC 还能再发  
* 易扩展：换 MQ、加下游系统，不涉及数据库事务层

**缺点：**

* 只保证**最终一致性**，不是「实时强一致」  
* CDC 链路本身需要部署和监控（Debezium/Canal、Kafka Connect 等）  
* 对业务设计有要求：
  * 下游消费必须幂等（同一个事件可能被投递多次）  
  * 需要基于 `biz_id` 或 event id 做去重

---

## 5\. 大致落地方式

假设项目使用的 Spring Boot、MySQL, 可以这样：

1. 在 MySQL 建一张 `outbox_event` 表
2. 在业务代码中：
   * 使用本地事务 `@Transactional`  
   * 更新业务表（例如预览配置、投放配置）  
   * 同时插入一条 `outbox_event` 记录（`payload` 里包含要发到 MQ 或 Kafka 的 JSON）
3. 引入 Debezium（或 Canal）订阅 MySQL binlog，只订阅 `outbox_event` 表：
   * 把事件投递到 Kafka / RocketMQ / RabbitMQ  
   * 或者调用你已有的「Octopus」之类的系统
4. 下游消费方自己保证幂等。

Outbox + CDC 是一种替代分布式事务（比如 XA/2PC）的常见方案，用来在「DB + 消息队列」之间实现最终一致性。

分布式事务替代方案：Outbox + CDC

后端

数据库

架构设计

Outbox+CDC模式通过本地事务+CDC组件实现数据库与消息队列的最终一致性，避免分布式事务的复杂性。核心步骤：业务库中创建Outbox表，本地事务原子写入业务数据和消息记录；利用Debezium/Canal监听binlog捕获新消息，可靠投递到MQ。相比2PC/XA，具有无跨资源锁、易扩展等优势，但需下游消费幂等。适用于SpringBoot+MySQL技术栈，通过@Transactional保证原子写入，CDC组件完成消息可靠投递。

消息队列

MySQL

Redis

Kafka

JSON

AI驱动 智领未来

tencentdb-catalog

腾讯云数据库特惠，新用户首单0.5折起


message-queue-catalog

文章

问答

视频

学习中心

腾讯云实验室

直播

竞赛

腾讯云代码分析专区

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

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

腾讯云数据库专区

腾讯云智能顾问专区

腾讯云原生专区

腾讯混元专区

腾讯云TCE专区

腾讯云Lighthouse专区

腾讯云HAI专区

腾讯云Edgeone专区

腾讯云存储专区

腾讯云智能专区

腾讯轻联专区 

腾讯云开发专区

TAPD专区

腾讯轻量云游戏服专区

腾讯云最具价值专家

腾讯云架构师技术同盟

腾讯云创作之星

腾讯云开发者先锋

腾讯云代码助手

云原生构建

TAPD 敏捷项目管理

Cloud Studio

SDK中心

API中心

命令行工具

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

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

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

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

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

社区新版编辑器体验调研

Outbox+CDC模式通过本地事务+CDC组件实现数据库与消息队列的最终一致性，避免分布式事务的复杂性。核心步骤：业务库中创建Outbox表，本地事务原子写入业务数据和消息记录；利用Debezium/Canal监听binlog捕获新消息，可靠投递到MQ。相比2PC/XA，具有无跨资源锁、易扩展等优势，但需下游消费幂等...

分布式事务替代方案：Outbox + CDC-腾讯云开发者社区-腾讯云

分布式事务替代方案：Outbox + CDC

分布式事务替代方案：Outbox + CDC

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐