后端 activemq队列模式下的多个消费者问题

问题

最近在项目中使用了 activemq 进行消息的异步传递,只有一个消费者时,系统可以正常运行,但当增加多个消费者时,却只有一个消费者进行消费,其他的消费者不消费。

原因

activemq 有一个机制,叫消息预读取,这个机制默认会读取 1000 条消息发往一个消费者中,当超过 1000 消息堆积时,才会继续读取剩下的消息发往另一个消费者中。当只有一个消费者时,这个机制可以提高效率,但有多个消费者时,就不合适了,会导致其他消费者闲置。

解决办法

在客户端的连接上,拼接jms.prefetchPolicy.all=xxx,就可以调整消息预读取条数,当有多个消费者时,可以适当的调低这个参数,保证其他消费者也可以消费到,从而提高消费速度。

完整的连接示例(以 spring boot 为例):

1

spring.activemq.broker-url=tcp://localhost:61616?jms.prefetchPolicy.all=2

©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容