微服务架构中的分布式事务，如何处理超时和失败提交

Question

假设您有一个服务a，它是大型微服务体系结构的一部分，在这个体系结构中，这些服务通过REST API或涉及某个代理的消息传递（RabbitMQ）相互通信。服务A公开RESTendpoint，该endpoint需要与某个第三方服务进行通信（与不在我们体系结构中的服务进行通信）并在那里创建一些内容，当服务A收到第三方的响应，表示那里一切正常时，它应该将该响应中的一些数据保存在自己的数据库中。

考虑到第三方不提供任何幂等机制，覆盖以下问题的最佳方式是什么。

>

第三方端的创建正常，但在服务A中DB write失败。这将导致不一致的状态，您在第三方端创建了一些内容，但您自己的数据库中不需要关于它的数据。

你收到了来自第三方的超时，所以你不能只是重复呼叫，因为他们没有提供任何幂等性机制。如果重复调用，可能会以两个（或更多）创建的资源而不是一个结束。

问题1。可以通过任何重试机制来解决，该机制可以重试DB调用任意次数。这种方法的问题在于，如果正在重复DB调用的服务实例突然停止。

据推测，更好的方法是服务在第三方成功创建后，发布一条关于成功创建的RabbitMQ消息。此服务将监听该消息，并在收到消息时执行DB调用。利用良好的重试机制和ACKing消息，可以解决服务实例突然关闭怎么办的问题。因此，在这个解决方案中，服务是自己消息的发布者和消费者。还有更好的主意吗？这个解决方案还将引入最终一致性，因为API调用者（调用服务Aendpoint的人）将在第三方成功创建后立即收到响应，但在服务数据库中保留任何内容之前（API客户端实际上需要什么）

超时问题呢？在这种情况下，如何处理来自第三方的超时？。我认为没有什么比发出GET调用来检查他们是否创建了一些东西更好的了。同样，GET调用可能会失败，但它可以重复，直到成功。这里还有一个边际用例，即若服务在发出GET调用时停止，该怎么办。




Answer 1

正确设置容错并不容易。我记得他们在Netflix堆栈中实现了一个专用模块：hystrix。也许这对你有帮助。