用于 FanOut 消息传递的 RabbitMQ 工作队列

Question

我正在尝试扩展 RabbitMQ 消息传递系统。当前系统非常简单 - 生产者向扇出交换器发送消息，消息由多个消费者处理 - 经典扇出路由。

我有来自不同类型的多个消费者（例如：一个打印到屏幕，一个记录到文件，一个保存到数据库，......）。 我的挑战 - 我不确定扩大消费者规模的最佳方式是什么。如果我添加来自同一类型的其他消费者 - 我将在数据库中获得双重日志或双重条目。 ...（想想从同一个扇出交换消费的两个 DB 消费者）。

我想我可以创建一个发布到工作队列的消费者，但我想知道 rabbitmq 中是否有更好的“内置”解决方案。

提前致谢， zf

Answer 1

如果您需要扩展消费者以更快地消费来自扇出交换的所有消息，您需要竞争消费；所以你需要更多的消费者连接到绑定到扇出交换的同一个队列。
这样，每个消费者都将独立于其他消费者消费一批消息。批处理中的消息数量由预取计数属性 (http://www.rabbitmq.com/consumer-prefetch.html) 定义。
这样，在您的情况下，您应该能够扩展消费者，避免数据库中的双重日志和双重条目。