在分布式长事务编排中，业务通常拆分为多个远程阶段，如订单创建、库存锁定、支付确认等。由于网络与服务不稳定，部分阶段可能抛出可恢复异常。异常体系的压制特性可以让编排引擎暂存这些异常而不立即中断流程，同时为每个阶段留下执行痕迹，便于后续统一补偿或回溯。
什么是异常压制特性
异常压制（exception suppression）指在捕获异常后不向外抛出，而是将其记录到上下文对象中，使主流程继续执行。Java 等语言在 try-with-resources 中已有类似概念，我们可以借用到事务编排里。
多阶段痕迹模型
每一个阶段执行后，无论成功或失败，都向痕迹上下文写入一条记录。被压制的异常作为痕迹的一部分保存。
| 阶段名 | 状态 | 压制异常 |
|---|---|---|
| createOrder | SUCCESS | 无 |
| lockStock | FAILED | TimeoutException |
| pay | SKIPPED | 无 |
核心代码实现
下面以 Java 风格伪代码展示如何应用压制特性收集多阶段痕迹。
import java.util.ArrayList;
import java.util.List;
// 阶段执行痕迹
class StepTrace {
String stepName;
String status;
String suppressedError;
StepTrace(String stepName, String status, String suppressedError) {
this.stepName = stepName;
this.status = status;
this.suppressedError = suppressedError;
}
}
// 编排上下文
class OrchestrationContext {
List<StepTrace> traces = new ArrayList<>();
// 压制并记录异常
void runStep(String name, Runnable action) {
try {
action.run();
traces.add(new StepTrace(name, "SUCCESS", null));
} catch (Exception e) {
// 压制异常，仅记录痕迹
traces.add(new StepTrace(name, "FAILED", e.getClass().getSimpleName()));
}
}
void printTraces() {
for (StepTrace t : traces) {
System.out.println(t.stepName + " | " + t.status + " | " + t.suppressedError);
}
}
}
public class Demo {
public static void main(String[] args) {
OrchestrationContext ctx = new OrchestrationContext();
ctx.runStep("createOrder", () -> { /* 调用订单服务 */ });
ctx.runStep("lockStock", () -> { throw new RuntimeException("Timeout"); });
ctx.runStep("pay", () -> { /* 未执行 */ });
ctx.printTraces();
}
}
压制后的决策处理
所有阶段跑完后，编排器检查痕迹列表。若存在被压制的异常，可根据业务规则决定整体回滚还是部分补偿。例如库存锁定失败，可取消订单并通知用户，而不影响已成功的步骤查询。
使用压制特性的注意点
- 只压制明确非致命的异常，避免掩盖严重错误
- 痕迹上下文需设置上限，防止内存膨胀
- 最终必须对被压制异常做出处理，不能丢失
异常压制不是忽略错误，而是把错误推迟到合适的时机统一解决，并保留现场痕迹。
总结
在分布式长事务编排中合理应用异常体系的压制特性，可以有效解耦阶段失败与流程中断，通过多阶段痕迹提升可观测性。配合统一的决策逻辑，系统能够在复杂网络环境下保持健壮与清晰的运行状态。
distributed_transactionexception_suppressionlong_running_process修改时间：2026-07-27 03:45:24