1. 事务边界概念

1.1 什么是事务边界

事务边界（Transaction Boundary）是分布式系统中标识一个完整业务操作开始与结束的逻辑范围。它定义了哪些操作属于同一个工作单元，以及该单元何时提交或回滚。在单体应用中，事务边界通常由数据库连接或框架（如 Spring @Transactional）隐式管理；但在微服务、消息驱动、事件溯源等架构中，事务边界必须由开发者显式定义。

事务边界的核心要素包括：

• 开始点（Start Point）：触发业务操作的入口，如 HTTP 请求、消息消费、定时任务触发。
• 结束点（End Point）：业务操作完成并产生确定性结果的位置，如响应返回、消息确认、状态持久化。
• 上下文（Context）：贯穿整个边界的共享状态，包括 Trace ID、Span ID、用户身份、请求参数等。
• 一致性保证（Consistency Guarantee）：边界内所有操作要么全部成功，要么全部回滚（或补偿）。

1.2 事务边界在分布式系统中的重要性

在分布式系统中，事务边界的重要性体现在以下四个维度：

没有明确的事务边界，分布式系统会面临以下典型问题：

• 幽灵请求：部分服务成功处理，但调用方未收到响应，导致重复或丢失。
• 观测盲区：Trace 在服务边界处断裂，无法形成完整的调用链。
• 补偿遗漏：回滚操作只覆盖了部分服务，造成数据不一致。

1.3 事务边界与可观测性的关系

事务边界是可观测性的基础单元。OpenTelemetry 的 Trace 模型本质上就是事务边界的具象化表达。每个 Trace 对应一个完整的事务边界，每个 Span 对应边界内的一个操作步骤。

两者的对应关系如下：

下图展示了事务边界与 OpenTelemetry Trace 的映射关系：

1.4 事务边界的分类

根据业务场景和实现方式，事务边界可分为以下三类：

1.5 事务边界的定义原则

在实际项目中，定义事务边界应遵循以下原则：

1. 业务完整性原则：一个事务边界应包含一个完整的业务操作，不可拆分也不可合并。
2. 可补偿原则：边界内的所有操作都应有对应的补偿逻辑，确保最终一致性。
3. 可观测性原则：每个事务边界必须生成唯一的 Trace ID，并在所有参与服务中传播。
4. 粒度适中原则：边界过粗会导致观测数据模糊，过细则造成存储和性能开销。

下图展示了不同粒度的事务边界对可观测性的影响：

1.6 事务边界的代码示例

以下是一个使用 OpenTelemetry Java SDK 手动定义事务边界的示例：

// 1. 创建事务边界（Root Span）
Span rootSpan = tracer.spanBuilder("create-order")
    .setSpanKind(SpanKind.SERVER)
    .setAttribute("order.id", orderId)
    .setAttribute("user.id", userId)
    .startSpan();

try (Scope scope = rootSpan.makeCurrent()) {
    // 2. 边界内的操作：校验库存
    Span inventorySpan = tracer.spanBuilder("check-inventory")
        .setSpanKind(SpanKind.CLIENT)
        .startSpan();
    try {
        inventoryService.checkStock(productId, quantity);
        inventorySpan.setStatus(StatusCode.OK);
    } catch (Exception e) {
        inventorySpan.setStatus(StatusCode.ERROR, "库存不足");
        throw e;
    } finally {
        inventorySpan.end();
    }

    // 3. 边界内的操作：扣减余额
    Span paymentSpan = tracer.spanBuilder("deduct-balance")
        .setSpanKind(SpanKind.CLIENT)
        .startSpan();
    try {
        paymentService.deduct(userId, amount);
        paymentSpan.setStatus(StatusCode.OK);
    } catch (Exception e) {
        paymentSpan.setStatus(StatusCode.ERROR, "余额不足");
        throw e;
    } finally {
        paymentSpan.end();
    }

    // 4. 边界成功结束
    rootSpan.setStatus(StatusCode.OK);
} catch (Exception e) {
    // 5. 边界失败，触发补偿
    rootSpan.setStatus(StatusCode.ERROR, "订单创建失败");
    compensationService.compensate(orderId);
    throw e;
} finally {
    rootSpan.end();
}