sagas 的并发性有什么价值？

Question

我不明白 saga 并发消息的目的。我希望它表现得更像一个演员。因此，所有具有相同CorrelationId 的消息都是按顺序处理的。 saga 的全部目的是编排一个长时间运行的进程，那么为什么并行消息处理很重要呢？

您能举一个合法的例子，说明与顺序模式相比，为 saga 实例并发处理消息是有益的吗？

还是我理解错了，并发仅仅意味着几个不同的saga实例并行运行？

问的原因是来自NServiceBusdocs的这个片段：

避免从外部资源访问数据的主要原因是saga state的可能争用和不一致。根据持久化器，可​​检索 saga 状态并使用悲观或乐观锁定进行持久化。 如果事务花费的时间太长，则可能会出现另一条与同一个 saga 实例相关的消息。它可能在不同的（并发）线程（或者可能是横向扩展的端点）上处理，并且它要么立即失败（悲观锁定），要么尝试保持状态（乐观锁定）。在这两种情况下，消息都会被重试。

Answer 1

没有，单个 saga 实例的消息需要按顺序处理。 MassTransit 中的 saga 配置没有什么特别之处，您真的想为其使用单独的端点并将并发限制设置为 1。

但这会降低处理不同 saga 实例的消息的性能。为了解决这个问题，保持并发限制高于一，并使用相关 id 的分区过滤器。不幸的是，分区过滤器需要按消息配置，因此您需要为 saga 使用的所有消息配置分区。

但这一切都取决于用例。当使用基于持久性的乐观并发时，所有并发问题都通过重试来解决，每个 saga 持久性提供者都记录了这一点。当然，重试数据库操作会产生一些噪音，但如果重试次数在控制范围内，则可以保持原样。

如果您因大量并发更新而重试大量，您可以恢复为您的 saga 分区。