java - 一个线程可以消耗多个队列吗？

Question

我有一个 Java 线程调用 basicConsume(String queueName,...)从 RabbitMQ 服务器获取消息。

单个线程是否可以同时阻塞多个队列，例如consume(List<String> queues,...)它在哪里返回这些队列中的第一个可用项目？

我看过the API但没有找到任何方法来做到这一点。

Answer 1

如果你想等待多个队列，你可以简单地创建一个Consumer(它可以是一个QueueingConsumer或一个自定义的)并多次调用 basicConsume() 在您的队列上，并使用相同的消费者实例作为参数。

这样，当(或者，在 QueueingConsumer 的情况下，consumer.nextDelivery() 时，将调用 handleDelivery() 回调> 将阻塞直到)队列中的第一个项目可用。