如何在 RabbitMQ 中跟踪并行进度和完成

How to track parallel progress and completion in RabbitMQ

场景是我希望我的代码迭代订单上的所有行项目并将它们分别插入队列中以进行并行处理。产品在最终登陆数据存储之前会经过多个队列。

我知道我可以将订单 ID 附在产品上,这样它们最终会放在一起,但我的问题是:

有没有办法标记产品,以便 RabbitMQ 了解它们是一个组的一部分并报告进度或完成情况?

我知道可以使用代码设置数组来跟踪 progress/completion 或使用数据存储。我只是想知道在重新发明轮子之前是否有一些工具可以与 RabbitMQ 一起使用。

不,在 RabbitMQ 中没有项目的逻辑分组,除了它们所在的队列。

您需要在您的应用程序中实现该逻辑。