如何用rabbitMQ实现Fork-join

Question

我想用rabbitMQ在php中实现fork-join模式。我设法将工作分成多个部分，并并行处理它们。但我不知道如何加入结果。

似乎rabbitMQ没有等同的期货或承诺。

任何帮助我们都将不胜感激。

Answer 1

这不是RabbitMQ会为您做的事情。您必须编写自己的代码来管理它。

它的要点是在您的消息中使用“关联id”来完成工作。当发送响应时，包含相同的关联id。

接收响应的代码将存储带有关联id的响应，这样当所有响应都被返回时，它可以将所有响应放在一起。

请参阅“拆分器”(http://www.enterpriseintegrationpatterns.com/patterns/messaging/Sequencer.html)

和“聚合器”(http://www.enterpriseintegrationpatterns.com/patterns/messaging/Aggregator.html)

更多信息的模式