在 Spring Boot 微服务中实现分布式事务时，用…

当需要跨多个微服务实现分布式事务、失败回滚和最终一致性时，使用 Saga 模式（编排或协同）配合 Kafka/RabbitMQ/Axon。

适用场景

解决思路

1. 设计事务流程：映射操作序列及其补偿事务（如 Order → Payment → Inventory → Shipment，对应 Cancel/Refund/Release/Cancel），并验证每个正向步骤都有对应的补偿。
2. 选择实现方式：协同式（Choreography）适用于全新项目、参与者较少，使用 Spring Cloud Stream + Kafka/RabbitMQ；编排式（Orchestration）适用于复杂工作流或遗留系统，使用 Axon Framework、Eventuate Tram 或 Camunda；选择前评估团队经验与系统复杂度。
3. 用本地事务实现各服务：每个服务原子性地完成本地 ACID 事务，例如在 @Transactional 方法中保存订单后通过 KafkaTemplate 发送 order.created 事件，并验证本地事务在事件发布前已提交。
4. 实现补偿事务：每个正向操作都需要幂等的补偿，例如 refundPayment 中查找支付记录、将状态设为 REFUNDED、保存并发送 payment.refunded 事件，并确认补偿可安全多次执行（幂等）。
5. 配置消息代理：配置 Kafka 幂等消费者，例如在 KafkaConfig 中设置 ConcurrentKafkaListenerContainerFactory 与 DefaultErrorHandler，启用 transactional ID 并验证 exactly-once 语义。
6. 实现 Saga 编排器（仅编排式）：例如 OrderSagaOrchestrator 中生成 sagaId、持久化 SagaState 后发送 saga.order.start 命令，并在 payment.failed 监听中发送 order.compensate 与 inventory.compensate 命令、更新状态为 FAILED；验证发送命令前 saga 状态已持久化，并检查每条失败路径的补偿触发。
7. 实现事件处理器（仅协同式）：例如 OrderEventHandler 监听 payment.processed，调用 orderService.reserveInventory 并发送 inventory.reserved，捕获 InsufficientInventoryException 时发送 inventory.insufficient；验证每个事件处理器正确触发下一步或补偿。
8. 添加监控与可观测性：配置 PrometheusMeterRegistry，跟踪 saga 执行时长、补偿次数、失败率、卡住的 saga，并对超过预期时长的 saga 设置告警。
9. 设计最佳实践：使用数据库约束或去重表使补偿事务幂等；使用不可变事件（Java record）防止意外修改；将 saga 状态存入持久化存储以便恢复。
10. 错误处理最佳实践：为服务间调用实现熔断器；对超过重试上限的消息使用死信队列；为每个 saga 步骤设置合适超时（默认 30s，可配置）。
11. 监控最佳实践：跟踪 saga 状态（PENDING、COMPLETED、COMPENSATING、FAILED）；监控补偿执行时间；当 saga 超过 SLA 时长时告警。

适用边界 · 注意事项

• 需要强一致性而非最终一致性的场景
• 参与者之间使用同步通信的场景
• 无法保证消息代理高可用或无法持久化 saga 状态的场景