带有RabbitMqBundle的管道和过滤器

Question

我正在尝试用http://www.eaipatterns.com/PipesAndFilters.html创建管道和过滤器( RabbitMqBundle )实现。最后的设置应该如下所示：

[main_topic_exchange]

   |---BK=S1.K1---> consumer1.1 ---BK=S2.K1---> consumer2.1---> ...
   |---BK=S1.K2---> consumer1.2 ---BK=S2.K2---> consumer2.2---> ...
                             ...............
   |---BK=S1.Kn---> consumer1.n ---BK=S2.Kn---> consumer2.n---> ...

基本上，我需要能够配置管道“蓝图”，并根据我的需要启动尽可能多的管道实例(为了可伸缩性)。

• 每个管道，或管道的第一个使用者，都绑定到一个交换(例如BK=S1.k1)。
• 消息从一个计算阶段(例如BK=S2.K1)传递到下一个计算阶段。
• 每个队列都是独占的。
• 必须保证通过管道的消息顺序。
• 过程将由监督管理d

我的解决方案：

1. 使用现有的包和代码--生产者和路由密钥，直接指示回调中的下一个阶段--不要太灵活，不能硬编码。
2. 扩展rabbitmqbundle并创建具有路由密钥设置器方法的使用者，并从命令行传递它：

./app/console rabbitmq:pipe1_consumer1 --route=S1.K1 --next=S2.K1 ./app/console rabbitmq:pipe1_consumer2 --route=S2.K1 --next=S3.K1 ./app/console rabbitmq:pipe1_consumer2 --route=S2.K1 --next=S3.K1

- next将指示下一个计算阶段(使用者)的路由密钥。

我不知道什么是最优雅的解决方案，有什么想法吗？

谢谢。

Answer 1

这里是RabbitMQBundle作者。包的最初目标是实现几种消息传递模式。考虑到管道和过滤器只是另一种模式，最好是实现它并将其添加到库中。我欢迎这样的增加。