2. 压测场景库设计原则

构建一个高质量的 Outbox 表压测场景库，不能仅靠零散脚本的堆砌。必须遵循一套明确的设计原则，确保场景库能够真实反映生产负载、支撑长期性能演进，并降低维护成本。本章围绕构建目标、模块化设计、可复用性与可扩展性三大核心原则展开。

2.1 压测场景库的构建目标

场景库的终极目标是模拟真实、量化瓶颈、驱动优化。具体拆解为以下四个子目标：

2.2 模块化设计

模块化是场景库可维护性的基石。将压测场景拆解为数据层、事务层、传输层、监控层四个独立模块，每个模块可单独替换或升级。

2.3 可复用性要求

场景库中的组件应具备一次编写、多处运行的能力。避免为每个测试目标重复造轮子。可复用性体现在以下三个层面：

• 数据模板复用：定义通用的 Outbox 记录结构（event_id, aggregate_type, payload, status, created_at），通过参数化注入不同的业务语义。
• 压测脚本复用：将“写入 Outbox”、“拉取未发送记录”、“标记已发送”封装为独立函数，通过 YAML/JSON 配置驱动不同场景。
• 监控面板复用：设计通用的 Grafana 看板模板，涵盖 Outbox 表写入 TPS、传输延迟、死锁次数、Binlog 积压量等核心指标。

// 可复用的 Outbox 写入器
public class OutboxWriter {
    private final DataSource dataSource;
    private final String insertSql;

    public OutboxWriter(DataSource dataSource, String tableName) {
        this.dataSource = dataSource;
        this.insertSql = String.format(
            "INSERT INTO %s (event_id, aggregate_type, payload, status, created_at) VALUES (?, ?, ?, 'PENDING', NOW())",
            tableName
        );
    }

    public void write(String eventId, String aggregateType, String payload) {
        try (Connection conn = dataSource.getConnection();
             PreparedStatement ps = conn.prepareStatement(insertSql)) {
            ps.setString(1, eventId);
            ps.setString(2, aggregateType);
            ps.setString(3, payload);
            ps.executeUpdate();
        } catch (SQLException e) {
            throw new RuntimeException("Outbox 写入失败", e);
        }
    }
}

2.4 可扩展性要求

压测场景库必须能够平滑适应业务增长和架构演进。可扩展性设计遵循以下原则：

2.5 设计原则总结

将上述原则归纳为一张决策检查表，供场景库设计时逐项核对：