消费端从activemq中取出一定量消息后,是一个一个进行处理,还是开启多个线程同时处理呢? 5
2个回答
展开全部
如果你用异步接收 MessageListener的 onMessage() 监听消费就是多线程,
如果是同步接收 receive() 方法接收 就是单线程 同步接收
如果是同步接收 receive() 方法接收 就是单线程 同步接收
追问
那onMessage()监听消费的处理线程大小可以设置吗?
追答
默认情况下,MQ每个destination都对应唯一的线程;
写消耗累,然后这个消耗类里启用多线程去消费 这个功能我也做过,这样方便流程控制
已赞过
已踩过<
评论
收起
你对这个回答的评价是?
推荐律师服务:
若未解决您的问题,请您详细描述您的问题,通过百度律临进行免费专业咨询