Java客户端中的RabbitMQ通道和线程

Question

每个通道都有自己的分派线程。对于每个渠道一个消费者的最常见用例，这意味着消费者不会拖住其他消费者。如果每个通道有多个使用者，请注意长时间运行的使用者可能会阻碍回调到该通道上其他使用者的调度。

我有各种命令（消息）通过单个入站队列和通道进入，该队列和通道附加了DefaultConsumer。假设DefaultConsumer中有一个threadpool允许我直接从consumer回调方法运行应用程序逻辑，并且我没有阻止后面命令的处理，这是正确的吗？如果有瓶颈，我可以给RMQ一个更大的线程池？

此外，偶尔还有一个来自其他线程的basicPublish到同一通道。我认为这确实会拖累消费者？我想我应该利用一个新的渠道做这件事？

Answer 1

您提到的线程池不是defaultconsumer的一部分，而是connection的一部分，该部分在其通道和defaultconsumer之间共享。它允许并行调用不同的使用者。请参阅指南的这一部分。

因此，您希望通过增加线程池的大小，可以达到更高的并行度级别。然而，这并不是影响它的唯一因素。

有一个很大的警告：不管线程池中有多少个线程，通过单个通道流动的传入消息都是串行处理的。这就是consumerworkservice的实现方式。

因此，为了能够同时使用传入的消息，您必须管理多个通道，或者将这些消息放入一个单独的线程池中。

发布不使用connections的线程池中的线程，因此它们不会阻止使用者。

更多的细节，你可以查看这个帖子。