如何回滚微服务之间发生的事务？
how to roll back a transaction happening between microservices?
我们有 microservice 架构，其中每个 microservice 大部分都是独立的。但是由于一些遗留原因，有一种情况我们必须从另一个内部调用另一个 microservice。
例如：下面的方法是Legal Service
的一部分
@Autowired
public ServiceManager UserServiceManager;
public void updateUserLegalData(){
//do db update of Legal info for the user
userServiveManager.setAcceptedLegal(true);
}
上面有两个 db transactions。一个正在更新 legalService 数据库，另一个正在更新 UserService 数据库。请注意 userService 是 microservice运行 在单独的 VM 上。
我们看到合法服务数据库已更新但对 userService 的调用失败的情况 (Internal server error)。所以这会使应用程序处于不一致状态。我们如何以推荐的方式解决此问题？
谢谢
这种情况只能用 JTA global/distributed 事务来处理。 JTA 是 Java EE 标准的一部分，可以有各种实现者。 Atomikos 通常是首选工具。
Here is good writeup from Dave Syer (Spring ecosystem contributor). 它还包含工作示例。它有点过时，但仍然相关。您可以在他的示例之上应用一些更现代的 Spring 抽象。
我为我的书创作了一些 GitHub examples of JTA transactions。请注意，存在模拟错误并且事务分布在 JMS 和 JDBC 数据源中。
但还要记住，由于涉及两阶段提交算法，因此跨各种数据源的 JTA 事务很慢。所以人们常常试图避免它们，而宁愿处理不知何故不一致。
不要做分布式事务。
为了与您现有的遗留系统集成，一种方法可以是一个单独的（微）服务，它侦听来自您的 userService 的更新事件并将相应的更新转发到 legalService。
Spring集成可能适合这样的任务。
干杯，
迈克尔
好吧，如果你在互联网上读到一点关于这个主题的信息，它目前是一个很大的崩溃点，但有一个答案是每个人都同意的，分布式事务不是解决这个问题的方法。它们太笨拙和错误，我们不能依赖它们来保证数据的一致性。
那么我们的选择是什么，人们正在尝试通过 Apache Kafka 或事件源（专注于保存正在更改数据的事件而不是保存数据本身）来协调微服务事务。那么这些有什么问题呢？好吧，它们与我们习惯的通常编程模型完全不同，并且从技术和组织的角度来看非常复杂，因此您开始针对技术挑战进行编程，而不是针对业务问题进行编程。
那么替代方案是什么，我个人开发了另一个概念并写了一篇关于它的博客，您可能会感兴趣。在它的基础上，它使用完整的微服务设计原则和 Spring Boot + Netflix in a J2EE container 并完全使用事务，在这里写所有细节太长了，如果你有兴趣可以阅读link 下面。
跨微服务的事务可能会变得复杂并且会减慢系统速度，解决分布式事务问题的最佳方法之一就是完全避免它们。
如果你避免跨微服务的分布式事务，那么你就不会遇到这种情况。
如果您必须跨微服务实现分布式事务，那么我认为有两种方法：
两阶段提交协议
**最终一致性
在你的情况下，我建议使用消息总线和标志在服务之间进行通信，因此如果合法服务将数据添加到合法数据库中，请锁定该记录并在消息总线上发送消息，当它是用户服务时up 它将在其末尾选择消息并更新数据库，并将确认消息发送到消息总线上，一旦收到确认消息，就会解除锁定，否则 delete/rollback 一定时间后的记录。在您的案例中，这看起来很复杂但可靠且防故障的解决方案。
我们有 microservice 架构，其中每个 microservice 大部分都是独立的。但是由于一些遗留原因，有一种情况我们必须从另一个内部调用另一个 microservice。
例如：下面的方法是Legal Service
@Autowired
public ServiceManager UserServiceManager;
public void updateUserLegalData(){
//do db update of Legal info for the user
userServiveManager.setAcceptedLegal(true);
}
上面有两个 db transactions。一个正在更新 legalService 数据库，另一个正在更新 UserService 数据库。请注意 userService 是 microservice运行 在单独的 VM 上。
我们看到合法服务数据库已更新但对 userService 的调用失败的情况 (Internal server error)。所以这会使应用程序处于不一致状态。我们如何以推荐的方式解决此问题？
谢谢
这种情况只能用 JTA global/distributed 事务来处理。 JTA 是 Java EE 标准的一部分，可以有各种实现者。 Atomikos 通常是首选工具。
Here is good writeup from Dave Syer (Spring ecosystem contributor). 它还包含工作示例。它有点过时，但仍然相关。您可以在他的示例之上应用一些更现代的 Spring 抽象。
我为我的书创作了一些 GitHub examples of JTA transactions。请注意，存在模拟错误并且事务分布在 JMS 和 JDBC 数据源中。
但还要记住，由于涉及两阶段提交算法，因此跨各种数据源的 JTA 事务很慢。所以人们常常试图避免它们，而宁愿处理不知何故不一致。
不要做分布式事务。
为了与您现有的遗留系统集成，一种方法可以是一个单独的（微）服务，它侦听来自您的 userService 的更新事件并将相应的更新转发到 legalService。 Spring集成可能适合这样的任务。
干杯， 迈克尔
好吧，如果你在互联网上读到一点关于这个主题的信息，它目前是一个很大的崩溃点，但有一个答案是每个人都同意的，分布式事务不是解决这个问题的方法。它们太笨拙和错误，我们不能依赖它们来保证数据的一致性。
那么我们的选择是什么，人们正在尝试通过 Apache Kafka 或事件源（专注于保存正在更改数据的事件而不是保存数据本身）来协调微服务事务。那么这些有什么问题呢？好吧，它们与我们习惯的通常编程模型完全不同，并且从技术和组织的角度来看非常复杂，因此您开始针对技术挑战进行编程，而不是针对业务问题进行编程。
那么替代方案是什么，我个人开发了另一个概念并写了一篇关于它的博客，您可能会感兴趣。在它的基础上，它使用完整的微服务设计原则和 Spring Boot + Netflix in a J2EE container 并完全使用事务，在这里写所有细节太长了，如果你有兴趣可以阅读link 下面。
跨微服务的事务可能会变得复杂并且会减慢系统速度，解决分布式事务问题的最佳方法之一就是完全避免它们。 如果你避免跨微服务的分布式事务，那么你就不会遇到这种情况。
如果您必须跨微服务实现分布式事务，那么我认为有两种方法：
两阶段提交协议 **最终一致性
在你的情况下，我建议使用消息总线和标志在服务之间进行通信，因此如果合法服务将数据添加到合法数据库中，请锁定该记录并在消息总线上发送消息，当它是用户服务时up 它将在其末尾选择消息并更新数据库，并将确认消息发送到消息总线上，一旦收到确认消息，就会解除锁定，否则 delete/rollback 一定时间后的记录。在您的案例中，这看起来很复杂但可靠且防故障的解决方案。