ActiveMQ的消息重发策略和DLQ处理

2019独角兽企业重金招聘Python工程师标准>>>

ActiveMQ的消息重发策略和DLQ处理博客分类： MQ

在以下三种情况中，ActiveMQ消息会被重发给客户端/消费者：
1.使用一个事务session，并且调用了rollback()方法；
2.一个事务session，关闭之前调用了commit；
3.在session中使用CLIENT_ACKNOWLEDGE签收模式，并且调用了Session.recover()方法。

Broker根据自己的规则，通过BrokerInfo命令包和客户端建立连接，向客户端传送缺省发送策略。但是客户端可以使用ActiveMQConnection.getRedeliveryPolicy()方法覆盖override这个策略设置。

Java代码

RedeliveryPolicy policy = connection.getRedeliveryPolicy();
policy.setInitialRedeliveryDelay(500);
policy.setBackOffMultiplier(2);
policy.setUseExponentialBackOff(true);
policy.setMaximumRedeliveries(2);

一旦消息重发尝试超过重发策略中配置的maximumRedeliveries(缺省为6次)时，会给broker发送一个"Poison ack"，通知它，这个消息被认为是一个毒丸(a poison pill)，接着broker会将这个消息发送到DLQ(Dead Letter Queue)，以便后续分析处理。

缺省死信队列(Dead Letter Queue)叫做ActiveMQ.DLQ;所有的未送达消息都会被发送到这个队列，以致会非常难于管理。你可以设置activemq.xml文件中的destination policy map的"individualDeadLetterStrategy"属性来修改.

Java代码

<broker...>
<destinationPolicy>
<policyMap>
<policyEntries>
<policyEntry queue=">">
<deadLetterStrategy>
<!--
Use the prefix 'DLQ.' for the destination name, and make
the DLQ a queue rather than a topic
-->
<individualDeadLetterStrategy
queuePrefix="DLQ." useQueueForQueueMessages="true" />
</deadLetterStrategy>
</policyEntry>
</policyEntries>
</policyMap>
</destinationPolicy>
...
</broker>

自动丢弃过期消息(Expired Messages)
一些应用可能只是简单的丢弃过期消息，而不想将它们放到DLQ中，完全跳过了DLQ。在dead letter strategy死信策略上配置processExpired属性为false，可以实现这个功能。

Java代码

<broker...>
<destinationPolicy>
<policyMap>
<policyEntries>
<policyEntry queue=">">
<!--
Tell the dead letter strategy not to process expired messages
so that they will just be discarded instead of being sent to
the DLQ
-->
<deadLetterStrategy>
<sharedDeadLetterStrategy processExpired="false" />
</deadLetterStrategy>
</policyEntry>
</policyEntries>
</policyMap>
</destinationPolicy>
...
</broker>

将非持久消息(non-persistent messages)放入死信队列
ActiveMQ缺省不会将未发到的非持久消息放入死信队列。如果一个应用程序并不想将消息message设置为持久的，那么记录下来那些未发送到的消息对它来说往往也是没有价值的。不过如果想实现这个功能，可以在dead-letter strategy死信策略上设置processNonPersistent="true"

Java代码

<broker...>
<destinationPolicy>
<policyMap>
<policyEntries>
<policyEntry queue=">">
<!--
Tell the dead letter strategy to also place non-persisted messages
onto the dead-letter queue if they can't be delivered.
-->
<deadLetterStrategy>
<sharedDeadLetterStrategy processNonPersistent="true" />
</deadLetterStrategy>
</policyEntry>
</policyEntries>
</policyMap>
</destinationPolicy>
...
</broker>

http://sharong.iteye.com/blog/1987171

转载于:https://my.oschina.net/xiaominmin/blog/1597342

ActiveMQ的消息重发策略和DLQ处理相关推荐

activeMQ - 消息重发策略和DLQ死信队列
2019独角兽企业重金招聘Python工程师标准>>> 1:死信队列简介 DLQ-死信队列(Dead Letter Queue)用来保存处理失败或者过期的消息. 出现以下情况时,消息 ...
ActiveMQ的消息重发机制
本文以ActiveMQ最新的5.10版本为准. 大家知道,JMS规范中,Message消息头接口中有setJMSRedelivered(boolean redelivered)和getJMSRedel ...
ActiveMQ消息重发
2019独角兽企业重金招聘Python工程师标准>>> 消息重发的问题: 1. 处理失败指的是MessageListener的onMessage方法里抛出RuntimeExcept ...
activemq - 浅析消息确认模式
2019独角兽企业重金招聘Python工程师标准>>> 前言 JMS的消息确认模式,定义了客户端(消息发送者或者消费者)与broker确认消息的方式,可以认为是客户端与Broker之 ...
PHP中使用ActiveMQ实现消息队列
2019独角兽企业重金招聘Python工程师标准>>> PHP中使用ActiveMQ实现消息队列前面我们已经学了如何部署ActiveMQ, 我们知道通过ActiveMQ的一个管理后台 ...
mqtt消息推送 java_MQTT+ActiveMQ实现消息推送（服务器端java实现）
上一篇文章已经介绍了mqtt+activemq实现消息推送移动端的实现,也介绍了利用自带的web console进行消息发布的方法.但是在具体的项目应用中,当我们将需要将该消息推送模块嵌入到一个后台管 ...
ActiveMQ点对点消息通信demo
2019独角兽企业重金招聘Python工程师标准>>> 1.下载ActiveMQ,安装并启动activeMQ, 2.登录控制台,http://localhost:8161/admin ...
JMS学习九 ActiveMQ的消息持久化到Mysql数据库
1.将连接Mysql数据库驱动包,放到ActiveMQ的lib目录下 2,修改ActiveMQ的conf目录下的active.xml文件,修改数据持久化的方式 2.1 修改原来的kshadb的持久化 ...
【ActiveMQ】消息生产者自动注入报错：Could not autowire. No beans of 'JmsMessagingTemplate' type found
标签:public style hat and 报错 require core ota ati 使用ActiveMQ过程中,定义消息生产者: package com.s ...

ActiveMQ的消息重发策略和DLQ处理

ActiveMQ的消息重发策略和DLQ处理相关推荐

最新文章

热门文章