探索分布式事务处理的新境界：Saga旅行预订示例

在分布式系统中，两阶段提交（2PC）的扩展性问题促使我们寻找新的解决方案，这就是 Saga 模式发挥作用的地方。它将全局交易分解为多个步骤或活动，每个步骤内部可执行原子事务，而整体一致性则由 Saga 负责保证。当出现错误时，Saga 将执行逆向的补偿步骤，以确保业务回滚到一个已知的终止状态。要深入了解 Saga，请阅读Saga：如何在无需两阶段提交的情况下实现复杂业务交易。

项目介绍

这个开源项目是一个基于 Camunda 实现的 Saga 示例：旅行预订。它模拟了酒店、汽车和航班预订的分布式场景，在无法成功预定航班时需要取消酒店和租车服务。项目通过图形化建模或 Java DSL（Model-API）来构建 Saga，并利用轻量级的 Camunda 过程引擎运行实例。

项目技术分析

该项目采用 Camunda 的 Model-API 定义 Saga，使得流程的编写清晰明了。TripBookingSaga 类展示了如何启动 Camunda 引擎并部署 Saga 流程。每个业务操作（如预订酒店、租车、订机票）及其相应的补偿动作（如取消操作）都是通过适配器类实现的。如果任何一个环节出错，事件子过程会触发补偿事件，确保业务的一致性。

此外，项目还提供了一个可选的 Spring Boot 应用程序，方便集成到更复杂的环境中，并支持 Camunda 的可视化工具进行流程监控。

项目及技术应用场景

• 分布式系统中的复杂业务流程管理
• 需要在多服务之间协调的跨域事务
• 在无法使用两阶段提交的情况下的数据一致性维护
• 系统故障恢复和业务回滚策略设计

例如，电商平台的商品购买、物流配送、支付等环节，可以采用 Saga 模式实现事务的协调。

项目特点

1. 轻量级实现：依赖 Camunda 过程引擎，易于集成到不同环境。
2. 灵活定义：可通过图形化建模或 Java DSL 编写 Saga 流程。
3. 自动补偿：发生异常时，能自动执行补偿任务，保障业务一致性。
4. 可视化监控：支持 Camunda 的可视化工具，方便查看流程状态和调试。

开始使用

要开始体验这个项目，您需要 Java 和 Maven。您可以：

1. 克隆或下载项目。
2. 运行 src/main/java/io/flowing/trip/saga/camunda/springboot/Application.java 启动 Spring Boot 应用，这将启动一个总是会在飞行预订环节“失败”的 Saga 示例。
3. 如需检查 Camunda 数据库，可以使用 Camunda 的独立 web 应用，连接地址如下：

   jdbc:h2:tcp://localhost:8092/mem:camunda;DB_CLOSE_DELAY=-1;DB_CLOSE_ON_EXIT=FALSE
   

或者，直接运行 src/main/java/io/flowing/trip/saga/camunda/simple/TripBookingSaga.java，不需要任何额外基础设施。

通过这个项目，你将深入理解 Saga 模式的实施细节，以及如何使用 Camunda 来管理分布式事务。无论你是初学者还是经验丰富的开发者，这都将是一次有价值的探索之旅。现在就加入，开启你的 Saga 之旅吧！