【发布时间】:2021-07-27 15:29:55
【问题描述】:
我正在跟踪rabbitmq,我发现spring rabbit 在新线程上消费了一条消息。我想知道它在哪里创建一个新线程
【问题讨论】:
标签: spring rabbitmq spring-amqp spring-rabbit
我正在跟踪rabbitmq,我发现spring rabbit 在新线程上消费了一条消息。我想知道它在哪里创建一个新线程
【问题讨论】:
标签: spring rabbitmq spring-amqp spring-rabbit
(默认)SimpleMessageListenerContainer 将消息传递给每个消费者的专用线程;当容器为start()ed 时创建线程。您可以指定自定义TaskExecutor。默认情况下,它使用SimpleAsyncTaskExecutor。
DirectMessageListenerContainer 调用 amqp-client 调度程序线程上的侦听器。
【讨论】:
com.rabbitmq.client.Consumer#handleDelivery 到org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer#invokeListener
BlockingQueueConsumer。