使用 pubsub 架构解决竞争问题的最佳实践

Question

假设我有这个微服务架构并且它们都使用 pubsub 进行交互。

基本上，如果进行汽车销售，它会执行任务 1，这会导致任务 2a 和 2b，如果皮革座椅可用，则会执行任务 3。 请注意，任务 2a 和 2b 是同时发生的，因为它是一个 pubsub

理论上，这很有效，但在实践中，我发现任务 2b 和 3 在执行 2a 之前执行的情况。这会导致任务 3 导致错误，因为尚未从任务 2a 生成 CAR 123。

我正在考虑在执行任务 2b 时添加延迟，但我想知道是否有解决此类问题的“更标准”的方法？

（不，我们不能将任务 3 更改为 upsert 命令）

Answer 1

要让它按您的意愿工作，您可以让销售和皮革座椅服务发布到同一个主题。

如果主题有一个分区，那么销售消息将始终在座位服务产生的消息之前。

如果主题有多个分区，则在两条消息上设置相同的值（某种 ID，最好是 uuid，以不创建热分区）作为分区键，这样两条消息都可以在同一个分区上生成并且仍然保持您需要的订单。