主页 / 问题 / 1155611
Accepted
Konstantin
Asked:2020-07-21 23:27:05 +0800 CST2020-07-21 23:27:05 +0800 CST

多个操作的原子性

  • 772

有一个函数可以在某些阶段创建一些对象 Some 。在每个阶段结束时，我都会写入数据库。总共有5个步骤，我可以在任何一个步骤上报错，而前面的步骤都成功完成了。但是这些保存的数据将不再相关，实际上是信息垃圾。为了正确操作，最好回滚中间保存的数据。从架构的角度来看，如何实现操作的原子性？

java

1 个回答

  1. Best Answer

    基本上两种方法

    1. 交易
    2. 最终一致性

    交易

    这是最简单的选择，如果没有禁忌症（见下文），那么它是最容易使用的。

    确保实现该功能的函数（我们称之为它doSomething）在数据库事务中执行就足够了。

    scala我不知道，所以java例子来演示：

    @Transactional
void doSomething() {
   doStep1();
   doStep2();
   doStep3();
   doStep4();
   doStep5();
}

    例如，如果在步骤 3 之后发生错误，则事务将简单地回滚，并且执行步骤 1-3 的数据库中的所有记录也将被回滚。一切看起来就像从未开始一样。

    如果所有步骤都成功完成，那么在第 5 步之后，数据库中的步骤所做的所有更改都将被提交（会有一次提交）。

    那些。这些步骤所做的一切都将保存在数据库中，或者什么都不保存 - 这就是我们需要的。

    重要的一点是try-catch 解决方案不适合。因为它catch并不总是执行，例如，如果执行此功能的服务器完全崩溃，即 烧坏，断电等，所以如果中间步骤提交到数据库，你不能依赖清理和整理状态，你不能使用catch。

    使用数据库中的事务，即使在这种情况下，一切都会正常工作。数据库将回滚事务，仅此而已。

    不幸的是，这并不总是有效。例如：

    1. 你有多个数据库
    2. 您使用的存储不支持事务
    3. 使用外部服务（例如，外部票务服务）。例如，在步骤 3 中，您需要通过 Internet 调用外部服务。这是一个潜在的长时间操作，服务可能不可用，并且由于各种原因长时间保持事务打开是不好的。
    4. 数据库性能不够，即 这是一个瓶颈（事务性是以性能为代价的）。

    在这种情况下，使用最终一致性。

    最终一致性

    在这种方法中，每个步骤都单独执行并存储其结果。如果某处发生错误，则根据错误，重复或回滚该过程。但都是手动的。

    考虑一个例子：

    void buyOnline(Cart cart, User user) {
   // эта операция помечает товары как зарезервированные
   reserveItems(cart);
   // эта операция грубо говоря блокирует необходимую сумму в банке
   PaymentTransaction payment = blockAmount(cart.getTotalPrice(), user.getPaymentInfo());
   if (payment.isSuccess()) {
      // эта операция помечает товары как купленные и создает задачу отделу доставки
      createShipment(cart.getItems(), user.getAddress());
      // эта операция собственно подтверждает банку, что заблокированные средства нужно списать у плательщика
      finalizePayment(payment);
   } else {
      // эта операция отменяет резервацию
      cancelReservationForItems(cart);
   }
}

    另外，这个过程还需要一些处理回滚和修复问题的过程，我会在此过程中提到它们。

    现在让我们考虑如何处理各种错误场景。

    例如，如果预订成功，但随后服务器完全关闭，则这种情况将由后台进程处理，该进程定期审查预订的商品，如果很久以前就取消预订（即，我们假设从预订到createShipment可能需要最多 1 小时）。

    如果您设法阻止了钱，然后一切都失败了，那么您可以手动重新启动该过程createShipment+ finalizePayment，例如，这可以由支持服务在用户调用后使用特殊按钮完成。如果用户根本不打电话，那么银行本身会在一段时间后回滚资金冻结，如果我们没有finalizePayment。而且在我们这边，我们还需要一个任务，它会定期在状态中查找旧订单payed并删除它们，好吧，或者您可以自动重新启动它们 - 这已经是业务逻辑的一部分（这里业务逻辑开始理解某些操作可能无法完成，这是决定如何处理它们的业务）。

    如果我们一切顺利，但我们做不到finalizePayment，那么此操作将由自动任务重复。我知道问题出现了，但是如果我们在多次尝试后仍然无法发送确认信息怎么办？我们已经发货了。在这种情况下，您将不得不手动处理支付系统。主要是保持系统确认付款已通过（这通常是某种交易标识符，或者可能存在由支付系统的数字签名签署的有关付款的信息）。这个确认就是证明，如果出现这种无法访问的全球性问题finalizePayment，粗略地说，操作是通过支付系统的支持通过电话完成的。

    在某些情况下，由于 API 有限，根本不可能确保即使重试也能保证完成两个操作（付款+发货）。或者该操作无法撤消，例如，无法撤消我们在其中写下该产品已购买的电子邮件。或者，例如，我们可能会发货，但我们仍然无法付款。

    在这种情况下，我们会采取补偿措施。对于未付款的发货 - 我们写信给用户付款或退货（或者我们起诉他，因为他没有任何付款确认）。对于电子邮件，我们发送一封新的电子邮件，我们写的地方，对不起，但是出现了问题，货物将不会发货。

    • 2

相关问题