mongodb - 使用 MongoDB 模拟 Oracle 序列

Question

我们的领域模型处理销售发票，每张发票都有一个自动生成的唯一编号。创建发票时，我们的 SalesInvoiceService 从 SalesInvoiceNumberGenerator 中检索一个数字，使用该数字和一些其他对象(卖方、买方、签发日期等)创建一个 SalesInvoice 并将其存储在 SalesInvoiceRepository 中。由于我们使用 MongoDB 作为我们的数据库，我们的 MongoDbSalesInvoiceNumberGenerator 在给定的 InvoicePolicies.nextSalesInvoiceNumber 上使用带有 $inc 1 的 findAndModify 命令来生成这个唯一的数字，类似于我们使用 Oracle 序列。

这在正常情况下有效。但是，当由于违反业务规则(例如无效的开具日期)而导致发票创建失败时，将抛出异常并且我们的 InvoicePolicies.nextSalesInvoiceNumber 已经递增。显然，由于没有事务管理这个工作单元，这个增量不会回滚，所以我们最终会丢失发票号。我们确实为用户提供了手动补偿机制，但我们希望首先避免这种情况。

你会如何处理这种情况？不，切换到另一个数据库不是选项:)

谢谢!

Answer 1

TL;DR:你想要的是 strict serializability ，但你可能不会得到它，除非你完全放弃并发(然后你甚至在理论上获得线性化)。零差距很容易，但要确保今天的发票数量不低于昨天几乎是不可能的。

这很棘手，或者至少非常昂贵。对于任何其他数据存储也是如此，因为您必须限制应用程序的并发性以保证它。想一想在办公室里传来传去的自动递增邮票，但有些上类族弄丢了信件。棘手...但是您可以降低可能性。

在竞争激烈时很难生成没有间隙的序列，在分布式系统中也非常困难。在生成发票的整个过程中保持锁定通常不是一种选择，尽管这很容易。那么让我们试试看:

Easiest way out: Use a singleton background worker, i.e. a single-threaded process that runs on a single machine. Have it explicitly check whether the current number is really present in the invoice collection. Because it's single-threaded on a single machine, it can't have race conditions. Done, via limiting concurrency.

当允许并发时，事情会变得困惑:

最好使用类似 two-phase commit protocol 的东西.本质上，使整个发票创建过程成为一个长期运行的事务，并显式存储未决事务，即存储所有尚未使用但已保留的数字。

然后跟踪每笔交易的完成状态。如果某个事务在超时后仍未完成，请考虑再次使用该数字。很难将其添加到计数器代码中，但这是可能的(检查是否存在超时交易，否则获取新的计数器值)。

有几种可能的错误，但都可以解决。这在链接和网上有更好的解释。不过，通常很难正确实现。

但是，超时带来了一个问题，因为您需要对生成发票所需时间的假设进行硬编码。这在接近日/月/年障碍时可能会很尴尬，因为您需要避免在 2015 年和 2014 年分别创建发票 12345 和 12344。

即使这样也不能保证在有限的时间间隔内没有空缺号码:如果没有更多的请求可以使用当年的空缺号码，您就会遇到问题。