activemq－慢消费者处理

阳光穿透心脏的1/2处 2023-06-12 11:19 15阅读 0赞

PendingMessageLimitStrategy

慢消费者会对non-durable topic带来问题。慢消费者会强制代理在内存中保留旧消息。一旦填满，就会进一步减缓消费速度。

**解决方案：使用PendingMessageLimitStrategy策略。**

除了在预获取缓冲区设置大小之外，在内存中保留待处理消息。通过该策略设定待处理消息大小。

ConstantPendingMessageLimitStrategy ：设定固定值。
    PrefetchRatePendingMessageLimitStrategy：设置乘数因子（在prefetchSize的基础上，乘该乘数因子，即为设定的保留值。）

或者：

\*\*注：\*\*limit的值如果等于０，则除了预获取量之外，不保留任何消息。如果大于０，保留该消息量，如果超过数量限制，则丢弃消息。如果小于０，禁用丢弃消息。此外，设定的保留值应该大于prefetchSize。

MessageEvictionStrategy

该策略针对的是慢消费者，超过保留的数量限制时，消息的剔除策略。

OldestMessageEvictionStrategy：剔除旧消息
    OldestMessageWithLowestPriorityEvictionStrategy：剔除旧消息中权重低的消息
    UniquePropertyMessageEvictionStrategy：剔除带有指定property的消息

或者：

<policyEntry topic=">">
    	<messageEvictionStrategy>
    		<oldestMessageWithLowestPriorityEvictionStrategy/>
    	</messageEvictionStrategy>
    </policyEntry>

或者：

<policyEntry topic=">">
    	<messageEvictionStrategy>
    		<uniquePropertyMessageEvictionStrategy propertyName="test"/>
    	</messageEvictionStrategy>
    </policyEntry>

原文地址：http://www.manongjc.com/article/62599.html

发表评论取消回复

表情：

评论列表（有 0 条评论，15人围观）

还没有评论，来说两句吧...

相关阅读

相关 activemq－慢消费者处理

PendingMessageLimitStrategy 慢消费者会对non-durable topic带来问题。慢消费者会强制代理在内存中保留旧消息。一旦填满，就会进

阳光穿透心脏的1/2处/ 2023年06月12日 11:19/ 0 赞/ 16 阅读

相关 ActiveMQ处理ObjectMessage队列

控制层 //新增队列（发送ObjectMessage消息） @RequestMapping("/sendObjectMessage") @Resp

你的名字/ 2023年02月12日 09:29/ 0 赞/ 192 阅读

相关 ActiveMQ处理TextMessage队列

控制层 //新增队列（发送TextMessage消息） @RequestMapping("/sendTextMessage") @Response

- 日理万妓/ 2023年02月12日 08:24/ 0 赞/ 75 阅读

相关 ActiveMQ多个消费者消费不均匀问题

[2019独角兽企业重金招聘Python工程师标准>>> ][2019_Python_] ![hot3.png][] ![ActiveMQ多个消费者消费不均匀问题][Acti

拼搏现实的明天。/ 2022年10月02日 00:50/ 0 赞/ 217 阅读

相关 activemq 添加生产者消费者连接密码

1.修改activemq.xml配置,需要新增一个插件,在<broker>节点里面<systemUsage>节点前面添加如下 <plugins>

逃离我推掉我的手/ 2022年06月13日 03:16/ 0 赞/ 255 阅读

相关 activemq延迟发送消费者会实时得到消息

目前的情况是生产端告诉TCP端想要延迟发送 TextMessage message = session.createTextMessage(newsJson); lon

野性酷女/ 2022年06月13日 02:44/ 0 赞/ 193 阅读

相关 ActiveMQ中Topic消费者

Consumer 消费者，接收消息接收步骤第一步：创建一个ConnectionFactory对象第二步：从ConnectionFactory对象中获得一

心已赠人/ 2022年05月17日 08:46/ 0 赞/ 197 阅读

相关 ActiveMQ中Queue消费者

Consumer 消费者，接收消息接收步骤第一步：创建一个ConnectionFactory对象第二步：从ConnectionFactory对象中获得一个

电玩女神/ 2022年05月17日 08:06/ 0 赞/ 213 阅读

相关 ActiveMQ之慢消费者处理

简介慢消费者在非持久性主题上会出现问题，因为它们会强制broker为它们在内存保留旧消息。一旦填满，就会导致broker放慢生产者的速度，导致快的消费者也会变慢。目

叁歲伎倆/ 2022年02月02日 23:19/ 0 赞/ 445 阅读

相关 ActiveMQ生产者和消费者案例

一、启动ActiveMQ ![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNz

灰太狼/ 2021年10月14日 01:52/ 0 赞/ 373 阅读