1. Outbox 模式概述

1.1 什么是 Outbox 模式

Outbox 模式是一种用于解决分布式系统中本地事务与远程消息/事件发送一致性问题的架构模式。其核心思想是：将需要发送的消息或事件先持久化到业务数据库的同一本地事务中的 Outbox 表，再由一个独立的异步进程（Relay / Publisher）轮询该表并将消息可靠地投递到消息中间件或下游系统。

该模式避免了在分布式事务中常见的“先发消息后提交”或“先提交后发消息”带来的数据不一致风险，是微服务架构中实现最终一致性的经典方案之一。

1.2 核心价值

1.3 典型应用场景

• 订单创建 → 发送通知：订单服务在本地事务中写入订单表和 Outbox 表，异步触发短信/邮件/推送通知。
• 用户注册 → 积分发放：用户服务完成注册后，通过 Outbox 表异步调用积分服务，避免注册接口阻塞。
• 支付回调 → 更新库存：支付成功后将“库存扣减事件”写入 Outbox 表，由 Relay 投递到库存服务，保证支付与库存最终一致。
• 跨服务事件驱动：微服务间通过 Outbox 表 + CDC（Change Data Capture）或轮询实现事件总线，替代强依赖消息队列的两阶段提交。
• 数据同步与复制：将变更记录写入 Outbox 表，由同步组件异步推送到缓存、搜索引擎或数据仓库。

1.4 Outbox 模式架构流程

下图展示了 Outbox 模式在分布式事务中的核心数据流与组件关系：

1.5 Outbox 表结构示例

一个典型的 Outbox 表设计包含以下关键字段：

CREATE TABLE outbox (
    id              BIGINT AUTO_INCREMENT PRIMARY KEY,
    aggregate_id    VARCHAR(64)   NOT NULL COMMENT '业务聚合根ID',
    aggregate_type  VARCHAR(64)   NOT NULL COMMENT '业务聚合根类型',
    event_type      VARCHAR(128)  NOT NULL COMMENT '事件类型',
    payload         JSON          NOT NULL COMMENT '事件载荷',
    status          TINYINT       NOT NULL DEFAULT 0 COMMENT '0:待发送 1:已发送 2:发送失败',
    created_at      DATETIME      NOT NULL DEFAULT CURRENT_TIMESTAMP,
    updated_at      DATETIME      NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
    INDEX idx_status_created (status, created_at)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

1.6 模式对比：Outbox vs 传统方案