【问题标题】:Where does spring rabbit consume a message on a new thread春兔在哪里消费新线程上的消息
【发布时间】:2021-07-27 15:29:55
【问题描述】:

我正在跟踪rabbitmq,我发现spring rabbit 在新线程上消费了一条消息。我想知道它在哪里创建一个新线程

【问题讨论】:

    标签: spring rabbitmq spring-amqp spring-rabbit


    【解决方案1】:

    Choosing a Container

    (默认)SimpleMessageListenerContainer 将消息传递给每个消费者的专用线程;当容器为start()ed 时创建线程。您可以指定自定义TaskExecutor。默认情况下,它使用SimpleAsyncTaskExecutor

    DirectMessageListenerContainer 调用 amqp-client 调度程序线程上的侦听器。

    【讨论】:

    • 我想知道消息是如何以及在哪里跨线程传递的,从com.rabbitmq.client.Consumer#handleDeliveryorg.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer#invokeListener
    • BlockingQueueConsumer
    猜你喜欢
    • 1970-01-01
    • 1970-01-01
    • 2010-11-09
    • 1970-01-01
    • 2013-02-03
    • 1970-01-01
    • 1970-01-01
    • 2017-11-16
    • 2015-07-17
    相关资源
    最近更新 更多