outbox架构解说

2025/5/17 16:08:00 来源：https://blog.csdn.net/owolai/article/details/148012155 浏览: 次关键词：outbox架构解说

Outbox 模式是一种用于实现数据一致性的架构模式，特别是在微服务架构中。

它确保在处理事务时，数据的原子性和最终一致性。

Outbox 模式的详细解说：

Outbox 模式的核心思想是将事件或消息存储在数据库的同一个事务中，然后通过一个单独的进程或服务将这些事件或消息发布出去。

具体步骤如下：

1.事务开始：应用程序开始一个数据库事务，包含对业务数据的修改和事件或消息的插入。

2.插入事件：在同一个事务中，将事件或消息插入到一个专门的 "outbox" 表中。

3.事务提交：提交事务。如果事务成功，事件或消息也被持久化到数据库中。

4.事件发布：一个单独的进程或服务（通常称为 "outbox processor" 或 "message relay"）定期轮询 "outbox" 表，将新事件或消息发布到消息代理（如 Kafka、RabbitMQ 等）。

5.事件删除：发布成功后，事件或消息从 "outbox" 表中删除。

数据库表：使用一个专门的 "outbox" 表来存储事件或消息。
轮询机制：outbox processor 定期轮询 "outbox" 表，发布新事件或消息。
事务日志：另一种实现方式是使用数据库的事务日志（如 MySQL 的 binlog）来捕获事件，然后通过 CDC（Change Data Capture）工具发布事件。

假设有一个订单服务，当创建订单时，需要同时更新订单表并发送一个 "订单创建" 事件到消息代理。

用Outbox 模式的具体步骤如下：

1.开始事务：

BEGIN TRANSACTION;

2.插入订单：

INSERT INTO orders (id, customer_id, amount, status) VALUES (1, 100, 250, 'pending');

3.插入事件：

INSERT INTO outbox (id, event_type, payload, created_at) VALUES (1, 'OrderCreated', '{"orderId":1,"customerId":100,"amount":250}', NOW());

4.提交事务：

COMMIT;

5.事件发布：outbox processor 定期查询 outbox 表，发布事件到消息代理，然后删除已发布的事件。

Transactional Outbox vs. Transactional Messaging：
- Transactional Outbox：使用数据库表存储事件，然后通过轮询或 CDC 发布事件。
- Transactional Messaging：直接在事务中发送消息到消息代理，可能需要两阶段提交。