3. 事件驱动架构基础：Event、Event Bus、Event Sourcing 与 CQRS 简介

在分布式系统与微服务架构中，服务间的通信方式决定了系统的耦合度、扩展性与容错能力。事件驱动架构（Event-Driven Architecture, EDA）通过将状态变更封装为不可变的事件，实现了服务间的异步、松耦合通信。本章将系统梳理 EDA 的四个核心概念：Event、Event Bus、Event Sourcing 与 CQRS，为后续跨服务熔断传播与隔离设计奠定理论基础。

3.1 核心概念：Event（事件）

事件是 EDA 中最基本的通信单元，代表“已经发生的事情”。在微服务中，事件通常由某个服务在完成业务操作后发布，其他服务通过订阅来感知并做出响应。

3.2 事件通道：Event Bus（事件总线）

Event Bus 是事件在服务间传递的中介层，负责事件的接收、路由、过滤与投递。它解耦了事件发布者与订阅者，使双方无需感知彼此的网络地址与生命周期。

3.2.1 核心功能

• 发布/订阅（Pub/Sub）：支持一对多的消息分发模式。
• 路由规则：基于事件类型、标签或内容进行精确或模糊匹配。
• 持久化与重试：确保事件在消费者故障时不丢失，支持死信队列。
• 顺序保证：在分区（Partition）级别维持事件顺序。

3.2.2 常见实现对比

3.3 事件溯源（Event Sourcing）

传统持久化模式只保存实体的当前状态，而事件溯源将每个状态变更都记录为不可变事件。实体的当前状态由事件序列通过重放（Replay）计算得出。

3.3.1 核心优势

• 完整审计轨迹：所有变更均可追溯，满足合规要求。
• 时间旅行：可重建任意历史时刻的实体状态。
• 事件驱动原生：事件存储天然支持异步发布。
• 消除对象-关系阻抗：无需复杂的 ORM 映射。

3.3.2 典型事件存储结构

-- 事件表结构示例（PostgreSQL）
CREATE TABLE event_store (
    event_id        UUID PRIMARY KEY,
    aggregate_type  VARCHAR(100) NOT NULL,      -- 聚合类型，如 "Order"
    aggregate_id    VARCHAR(64) NOT NULL,       -- 聚合 ID
    event_type      VARCHAR(100) NOT NULL,      -- 事件类型，如 "OrderCreated"
    event_data      JSONB NOT NULL,             -- 事件载荷
    version         INT NOT NULL,               -- 聚合版本号（乐观锁）
    created_at      TIMESTAMPTZ NOT NULL DEFAULT NOW(),
    UNIQUE (aggregate_type, aggregate_id, version)
);

3.4 命令查询职责分离（CQRS）

CQRS 将系统的读写模型分离为独立的命令模型（写）与查询模型（读）。命令模型处理业务逻辑并产生事件，查询模型针对展示需求优化数据读取。

3.4.1 分离带来的好处

3.4.2 与 Event Sourcing 的协同

Event Sourcing 与 CQRS 经常组合使用：命令模型将事件写入 Event Store，查询模型通过订阅事件流构建并更新自己的读视图。这种组合在微服务中被称为 ES/CQRS 模式。

3.5 三者关系与适用场景

Event、Event Bus、Event Sourcing 与 CQRS 并非必须同时使用。下表总结了各组件在微服务熔断与隔离场景中的角色定位：