如何回滚微服务

Question

我对微服务有疑问。假设有5个微服务，例如M1，M2，M3，M3，M4和M5。有4个数据库，由4个微服务连接/访问。例如，M2连接到MySql，M3连接到Cassandra，M4连接到MangoDb，M5连接到Oracle。

现在

步骤1：M1调用M2以更新mySql中的某些用户数据，并成功更新，最后得到M2的成功响应

步骤2：M1呼叫M3以更新Cassandra中的某些数据，并成功更新，最后得到M3的成功响应

步骤3：M1调用M4以更新MangoDb中的某些数据，但由于某些数据库服务器问题或任何其他问题而失败。

在这里，我的要求是，我想回滚以前的微服务（M2和M3）所发生的数据库更改

为了实现这种回滚方案，我们需要做什么？

Answer 1

这是分布式事务的典型情况。无论您对数据库使用单独的技术还是在不同的服务器上使用相同的技术，都将执行事务性操作。为了处理这种类型的事务的回滚，您不能依靠数据库技术机制进行事务和回滚。您必须自己做。

传奇模式

Saga模式是微服务体系结构中分布式事务场景的常见解决方案。分布式Sagas是一种用于管理如您所描述的方案中的故障的模式。

Saga是根据业务流程创建的，例如“在网上商店购买产品”。此过程可能涉及对多个微服务的多个操作。Saga将控制和管理该流程的执行，如果其中一个步骤失败，它将触发操作以还原失败操作之前执行的操作。

有多种实现sagas的方法。这取决于您的体系结构以及微服务之间的通信方式。您是否使用命令和/或事件？

---

例

“在网上商店购买产品”业务流程。可以说，这个业务流程有3个简单的步骤，由3种不同的微服务完成：

• 行动1-在产品库存微服务中储备产品
• 行动2-验证微服务中的付款
• 动作3-订购微订单服务中的产品

使用事件：

您可以发布事件以执行某些操作，如果某个操作失败，则可以发布该事件的还原（或删除）事件。对于上述业务流程，可以说1.动作成功，而2.动作失败。在这种情况下，为了回滚1.操作，您将发布一个事件，例如“
RemoveReservationFromProduct”，以删除保留并将状态恢复到该业务流程开始事务之前的状态。该事件将由事件处理程序处理，该事件处理程序将在数据库中恢复该状态。由于这是一个事件，因此您可以实现失败的重试机制，或者如果代码中存在某些错误，请稍后重新应用它。

使用命令：

如果您使用某种类型的rest
api作为命令直接调用微服务，则可以运行一些delete或update端点以还原所做的更改。对于上述业务流程，可以说1.动作成功，而2.动作失败。在这种情况下，为了回滚1.操作，您将调用delete
api来删除特定产品的预留，以便删除预留并将状态恢复为该业务流程开始交易之前的状态。 。

您可以看一下该示例如何实现Saga模式。