如何实施同步交易系统？

发布于 2025-02-13 21:03:12 字数 754 浏览 2 评论 0原文

让我们映像我们在某些.net core controller 中有一个简单的端点，称为createNentity，我们有两个服务，可以保存 Entity /em>到mongo和neo4j数据库（按照此特定顺序）。

我想实现一些模式，以确保我们拥有一致的数据。

为什么？

因为我们可能会有添加到mongo的情况时，但呼叫neo4j崩溃。这意味着数据仍然插入mongo。

一种解决方案是使用try-catch语句进行第二个服务调用，并使用mongo插入的补偿事务。在这种情况下，从mongo中删除实体。另一个可能是将状态用于实体，并将未决作为初始状态，并将其标记为 neo4j成功进行了呼叫。

我还浏览了 saga 和 2pc 模式，但它们用于异步环境和跨微服务（您知道，通过与Rabbitmq，Kafka，Service Bus，Service Bus＆amp＆amp; ）

，但就我而言，有一个微服务。对此有什么想法吗？

原文

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

冰火雁神 2025-02-20 21:03:12

您想在交易中。如果Neo4J失败，请返回Mongo交易，如果成功，请进行提交。

回复收藏 0 原文

瞳孔里扚悲伤 2025-02-20 21:03:12

时间开源项目可用于在同步场景中实现补偿和萨加斯。时间的基本思想是，您将代码写为执行远程调用的代码的故障，不可能发生。如果流程失败，时间将在与崩溃之前完全相同的状态中迁移执行到其他机器。该州包括所有本地变量和阻止调用。
这是使用临时java sdk的传奇示例：

public void bookTrip(String name) {
    // Configure SAGA to run compensation activities in parallel
    Saga.Options sagaOptions = new Saga.Options.Builder().setParallelCompensation(true).build();
    Saga saga = new Saga(sagaOptions);
    try {
      String carReservationID = activities.reserveCar(name);
      saga.addCompensation(activities::cancelCar, carReservationID, name);

      String hotelReservationID = activities.bookHotel(name);
      saga.addCompensation(activities::cancelHotel, hotelReservationID, name);

      String flightReservationID = activities.bookFlight(name);
      saga.addCompensation(activities::cancelFlight, flightReservationID, name);
    } catch (ActivityFailure e) {
      saga.compensate();
      throw e;
    }
  }

不幸的是，。截至2022年夏天，正在开发。当前支持的语言是Typescript/JavaScript，GO，Java，Python ＆amp; php。

对于.net，您还可以使用持久的任务框架和/或

Temporal open source project can be used to implement compensations and SAGAs in synchronous scenarios. The basic idea of Temporal is that you write your code as a failure of the code that performs remote calls cannot happen. In case of a process failure Temporal is going to migrate the execution to a different machine in exactly the same state as before the crash. The state includes all local variables and blocking calls.
Here is a SAGA example using Temporal Java SDK:

public void bookTrip(String name) {
    // Configure SAGA to run compensation activities in parallel
    Saga.Options sagaOptions = new Saga.Options.Builder().setParallelCompensation(true).build();
    Saga saga = new Saga(sagaOptions);
    try {
      String carReservationID = activities.reserveCar(name);
      saga.addCompensation(activities::cancelCar, carReservationID, name);

      String hotelReservationID = activities.bookHotel(name);
      saga.addCompensation(activities::cancelHotel, hotelReservationID, name);

      String flightReservationID = activities.bookFlight(name);
      saga.addCompensation(activities::cancelFlight, flightReservationID, name);
    } catch (ActivityFailure e) {
      saga.compensate();
      throw e;
    }
  }

Unfortunately, the .NET SDK for Temporal is still under development as of the summer of 2022. The currently supported languages are Typescript/Javascript, Go, Java, Python & PHP.

For .NET you can also use Durable Task Framework and/or Azure Durable Functions that are based on the same idea as Temporal.

回复收藏 0 原文