`

ActiveMQ死信队列

阅读更多
Apache的ActiveMQ是JMS的一个开源实现,下面来说说ActiveMQ的使用

1. admin的web管理

浏览器输入http://localhost:8161/,打开后台管理页面:


2. DLQ - 死信队列 (Dead Letter Queue)

用来保存处理失败或者过期的消息。

出现下面情况时,消息会被重发:
i. 事务会话被回滚。
ii. 事务会话在提交之前关闭。
iii. 会话使用CLIENT_ACKNOWLEDGE模式,并且Session.recover()被调用。


1. 当一个消息被重发超过最大重发次数(缺省为6次,可以修改)时,会给broker发送一个"有毒标记“,这个消息被认为是有问题,这时broker将这个消息发送到DLQ,以便后续处理。

2. 缺省的死信队列是ActiveMQ.DLQ,没有特别指定,死信都会被发送到这个队列。

3. 缺省持久消息过期,会被送到DLQ,非持久消息不会送到DLQ。

4. 可以通过配置文件(activemq.xml)来调整死信发送策略。
分享到:
评论

相关推荐

    ActiveMQ队列消息过期时间设置和自动清除解决方案.docx

    在 ActiveMQ 中,死信队列默认是 ACTIVEMQ.DLQ 队列。可以通过插件来设置死信队列的过期时间和清除策略。 有多种策略可以选择: 1. 直接抛弃死信队列:可以使用 DiscardingDLQBrokerPlugin 插件来抛弃死信队列。...

    ActiveMQ消息过期时间设置和自动清除解决方案

    本文档详细介绍了在Apache ActiveMQ 5.15.3版本中如何进行消息过期时间的设置,以及如何配置自动清除机制,特别是针对死信队列的处理方式。 #### 1. 消息过期设置 ##### 参数详解 - **Message 过期则客户端不能...

    7道消息队列ActiveMQ面试题!

    6. ActiveMQ的死信队列 在消息处理失败的情况下,如果希望消息不被服务器直接删除,而是能够再次提供给其他消费者处理或重试,可以考虑使用死信队列。这通常涉及关闭AUTO_ACKNOWLEDGE模式,改为手动确认消息。这样,...

    ActiveMQ消息中间件面试专题1

    通过理解服务器宕机时的数据存储策略,处理丢消息的策略,优化持久化消息的发送,调整prefetch机制以确保消息公平分配,以及利用死信队列来处理异常情况,我们可以更好地利用ActiveMQ构建健壮的分布式系统。

    ActiveMQ消息中间件面试专题.pdf

    为了解决这个问题,ActiveMQ 提供了死信队列(Dead Letter Queue)功能。当消息无法正常处理时,可以配置将这些消息路由到死信队列,以便后续进行特殊处理或分析。 ActiveMQ 是一款广泛应用的消息中间件,基于 Java...

    activemq测试样例

    ActiveMQ提供了多种策略来处理积压,如死信队列、优先级队列和时间戳策略等。例如,你可以设置消息的TTL(Time To Live)属性,让过期的消息自动删除,以避免无限增长的积压。 此外,ActiveMQ还支持多种协议,如...

    aop+activemq测试.zip

    "activemq 产生死信并处理死信"是指在ActiveMQ中,当消息无法被正确消费时,会被移到死信队列,这可能是由于消费者故障、超时或其他错误。处理死信是保持系统稳定的关键,通常包括分析死信原因、修复问题、以及可能...

    apache-activemq-5.0.0-src.zip_ActiveMQ 源代码_activemq_activemq.src

    通过深入学习和研究ActiveMQ的源代码,开发者不仅可以掌握消息中间件的基本原理,还能学习到高级特性如事务处理、消息优先级、延迟消息、死信队列等。同时,对于Java NIO、多线程编程、网络编程等领域也有很好的实践...

    apache-activemq-5.15.2.zip

    10. **消息重试和死信队列**:ActiveMQ提供自动消息重试和死信队列功能,处理那些无法成功投递的消息。 11. **事务支持**:ActiveMQ支持本地JMS事务和XAS(分布式事务),确保消息的一致性。 12. **消息代理性能...

    ActiveMQ的activemq.xml详细配置讲解

    - `<policyEntries>`用于定义基于主题或队列的策略,如大小限制、死信处理、消息存活时间等。 - `<destinationPolicy>`元素内的`<policyEntry>`可以指定特定的队列或主题策略。 4. **Destinations** - `...

    C#,activemq,mq

    此外,ActiveMQ还具备事务管理、持久化、消息优先级、死信队列等功能,这些都是在设计和实现复杂分布式系统时的重要考虑因素。 在实际开发中,需要注意性能优化,例如合理配置ActiveMQ服务器,使用预分配的缓冲区...

    activemq-5.12.0.zip

    5. **高级特性**:包括事务、优先级、时间戳、死信队列、消息分页等,这些特性使得ActiveMQ能够处理复杂的业务需求。 6. **安全性**:ActiveMQ支持多种安全认证和授权机制,如JAAS(Java Authentication and ...

    ActiveMQ in Action

    书中的章节还涉及了ActiveMQ的高级特性,例如事务支持、持久化、消息优先级和死信队列。事务保证了消息的原子性,确保在异常情况下能够正确处理消息。持久化则确保即使服务器重启,消息也不会丢失。死信队列则用于...

    apache-activemq-5.2.0-bin.zip

    7. **消息重试与死信队列**:ActiveMQ可以配置自动重试策略,当消息无法传递时,会将其放入死信队列,便于后续的诊断和处理。 8. **Web控制台**:5.2.0版本包括了一个基于Web的管理界面,用户可以通过浏览器监控和...

    activemq官方安装包

    在实际应用中,ActiveMQ还支持许多高级特性,如持久化存储、消息确认、事务处理、消息分页、消息优先级和死信队列等。这些特性确保了在大规模并发和高负载情况下,消息的可靠传递和系统性能。 总结来说,ActiveMQ...

    MQ之ActiveMQ思维导图.zip

    4. **高级特性**:包括事务、持久化、优先级、时间戳、消息组、死信队列、DLQ 等。 5. **集群与高可用**:描述如何通过集群配置实现 ActiveMQ 的高可用性。 6. **监控与管理**:介绍使用 Web Console 或 JMX 进行...

    activemq demo

    9. **高级特性**:可能还会接触到ActiveMQ的一些高级特性,如消息优先级、死信队列、消息组等。 10. **性能与监控**:学习如何评估ActiveMQ的性能,并了解如何通过管理控制台或API进行监控和故障排查。 在这个...

    activemq5配置文档

    - **错误处理与重试机制**:配置ActiveMQ来处理短信发送失败的情况,例如设置重试策略和死信队列。 5. **性能优化**: - **并发与线程池**:配置合适的线程池大小可以优化ActiveMQ的并发性能。 - **消息压缩**:...

    ActiveMQ 5.7源码及jar包

    2. **高级特性**:文档还会涵盖高级特性,如事务、消息优先级、时间戳、死信队列等,帮助开发者充分利用ActiveMQ的功能。 3. **故障排查**:文档可能包含常见问题的解决方案,对于调试和优化ActiveMQ的性能非常有用...

    activeMQ发送消息返回消息

    ActiveMQ提供了重试和死信队列等机制来处理这些问题,确保消息的可靠传递。 在实际应用中,ActiveMQ的配置和使用可能更复杂,需要考虑安全性、性能优化、持久化、网络拓扑等因素。同时,JMS规范也提供了许多高级...

Global site tag (gtag.js) - Google Analytics