用rabbitmq实现一个作业队列

Question

我已经构建了一个 rabbitmq 包装器，它可以向消费者发布消息，并且运行良好。

我是否也可以在 rabbitmq 中构建一个工作队列（如 gearman），它可以将长时间运行的任务分发给消费者，消费者反过来将结果通知发布者。

我想这将要求发布者也充当消费者，我不确定如何实施。 （如果我错了，请纠正我）。

或者，rabbitmq 不是这种情况的工具。

谢谢，

Answer 1

RabbitMQ 支持这种类型的模式。查看RPC tutorial 了解如何实现此模式的引导程序。

它可以根据您的需要以不同的方式实现：

• direct reply queue，队列将被创建并仅用于与请求关联的回复
• 包含所有回复的静态回复队列

它通常意味着将请求与回复关联起来的关联 ID，或者如果回复包含所有必要信息，则它可以是无状态的。

这真的取决于你的需要。