symfony - 在一组消息之后施加障碍

Question

我创建消息组（例如 G1、G2、...）。

在每个组内，所有消息都可以并行处理，顺序无关紧要。

但是，要处理 G2，来自 G1 的所有消息必须已完成处理。

是否有可能在rabbitmq中实现这一点？（最后我将在 symfony 中实现它......）

我的问题与具有“消息屏障”功能的消息队列有关？

标签： symfonyrabbitmqmessage-queuesymfony-messenger

Answer 1

队列不适合这种情况。使用像Cadence Workflow这样的编排器，它可以开箱即用地支持您的场景。它还允许实施复杂的错误处理和重试策略。