RabbitMQ：预取消息处理

Question

我正在使用Spring AMQP与RabbitMQ一起工作。以下是我的配置：

<rabbit:connection-factory id="connectionFactory"
    host="${queue.host}" port="${queue.port}" />
<rabbit:template id="amqpTemplate" connection-factory="connectionFactory" />
<rabbit:admin connection-factory="connectionFactory" />
<rabbit:queue name="${queue.names}" durable="true"
    exclusive="false" />
<rabbit:listener-container
    connection-factory="connectionFactory" acknowledge="auto" error-handler="airbrakeHandler" prefetch="1000" >
    <rabbit:listener ref="consumer" queue-names="${queue.names}" />
</rabbit:listener-container>

正如您所看到的，prefetchCount是1000。

我想知道预取的消息是否在消费者中并行处理；也就是说，多个线程调用onMessage（消息消息）方法。或者消息是按顺序处理的；也就是说，一个线程迭代预取的消息，并以连续的方式调用每个消息的onMessage（消息消息消息）方法。

我应该注意到，处理的顺序对我来说并不重要。事实上，它们一次处理一个。

提前感谢。

Answer 1

SimpleMessageListenerContainer配置包括一个concurrency参数，用于设置使用者线程的最大数量：

concurrency: The number of concurrent consumers to start for each listener.

对于单线程操作，可以将其设置为“1”-例如：

<rabbit:listener-container ... prefetch="1000" concurrency="1">
    <rabbit:listener ref="consumer" queue-names="${queue.names}" />
</rabbit:listener-container>

有关详细信息，请参阅Spring Docs和SimpleMessageListenerContainer的javadoc。