我们正在使用 Spring-AMQP 实现 RabbitMQ,我们的要求是在多个线程中运行 consumer 以使用来自单个队列的消息。 是否需要完成任何服务器(RabbitMQ)端脚本,或者我们可以在消费者级别为单个队列运行多个线程的任何其他方法?
提前感谢!
我想
,这是你的答案:
<rabbit:listener-container id="container1" connection-factory="connectionFactory" acknowledge="manual" concurrency="5">
<rabbit:listener id="testListener" queue-names="foo, #{bar.name}" ref="testBean" method="handle"/>
</rabbit:listener-container>
请注意并发属性。这是一本手册