消费端从activemq中取出一定量消息后,是一个一个进行处理,还是开启多个线程同时处理呢?

Posted

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了消费端从activemq中取出一定量消息后,是一个一个进行处理,还是开启多个线程同时处理呢?相关的知识,希望对你有一定的参考价值。

参考技术A 如果你用异步接收 MessageListener的 onMessage() 监听消费就是多线程,
如果是同步接收 receive() 方法接收 就是单线程 同步接收追问

那onMessage()监听消费的处理线程大小可以设置吗?

追答

默认情况下,MQ每个destination都对应唯一的线程;

写消耗累,然后这个消耗类里启用多线程去消费 这个功能我也做过,这样方便流程控制

参考技术B 这看你设计的时候,如何提供多线程代码,就可以同时处理,activemq本身就是多线程的

以上是关于消费端从activemq中取出一定量消息后,是一个一个进行处理,还是开启多个线程同时处理呢?的主要内容,如果未能解决你的问题,请参考以下文章

activeMQ中queue 与 topic 区别

一ActiveMQ消息队列

ActiveMQ(24):Consumer高级特性之Slow Consumer Handling(慢消费者的处理)

JMS + ActiveMQ

消息队列 ActiveMQ

消息队列 ActiveMQ