使用spring amqp在RabbitMQ服务器中配置多线程消费者?

Pan*_*005 2 multithreading rabbitmq consumer spring-amqp

我们正在使用 Spring-AMQP 实现 RabbitMQ,我们的要求是在多个线程中运行消费者以消费来自单个队列的消息。是否需要完成任何服务器(RabbitMQ)端脚本或我们可以在消费者级别为单个队列运行多个线程的任何其他方式?

提前致谢!

Art*_*lan 5

我想,这是你的答案:

<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>
Run Code Online (Sandbox Code Playgroud)

注意并发属性。 这是一个手册