一对多队列

Question

我有一个生产者，一个队列和N个消费者。生产者创造了由消费者执行的“就业”。我想使用拉模型，其中消费者从队列中提取作业，当它完成前一个任务时，而不是使用循环的推送模型，在这个模型中，作业被除以等于使用者。

我的消费者使用相同的代码，但是当我运行它时，第一个用户连接和接收所有的作业。即使在调试中查看它，第一个也会得到所有东西，但是第二个etc不会收到任何消息(即使在第一个执行接收之前执行接收时也是如此，因为接收会返回一些作业)。

连接网址："amqp://guest:guest@prodconstest/?brokerlist='tcp://127.0.0.1:5767'“

每个消费者的代码：

1. 创建AMQConnection
2. 使用自动ack创建队列会话
3. 连接启动
4. 创建队列"ADDR:" + queueName + "; {create: always, link:{x-subscribes: {exclusive: false}}}"
5. 创造消费者

理论上是否有可能使用AMQP队列来实现？如果是这样的话，是怎么做的？

Answer 1

似乎我必须在connection中更改maxprefetch参数。对于我的用例来说，默认值5000太大了，将其更改为1可以使这个系统正常工作。