ActiveMQ Stomp的重新投递和死信

为什么80%的码农都做不了架构师？>>>

刚开始使用ActiveMQ的时候没有深入研究，拿来就用。感觉简单，不会碰到什么大的问题。随着时间的推移，项目对它的依赖越来越强，使用也越来越频繁。问题也随之而来了。

最主要的就是下面这两个现象：
1、队列中只要有一个消息没有被ack掉，那么后面的消息就都卡住了。
2、经过检查，没有被ack掉的消息的数据是正常的，不清楚为什么不会被ack掉。

有上面的现象，那么就会有这样的问题：
1、没有被ack的消息，是不是可以先记录在另外一个地方，让后面的消息继续走？
2、正常的消息没有被ack掉，那么是不是可以让这个消息重新再解析一次？

带着上面的问题查找信息：
第一个问题很好解决，因为’activemq.prefetchSize’的默认值是1，把这个值改大一些就不会卡住。但是错误的消息没有被ack掉的需要自己手动写记录。
第二个问题却感觉有点难，困扰我好久。

查找ActiveMQ的资料，官网给出了死信的配置（DLQ），但是自己配置了却没有任何效果。
后来查看到Apollo的资料，介绍其是在ActiveMQ基础上发展而来的。
然后就折腾Apollo，用原来的stomp-php库，问题依然存在。后来又查找其它支持Apollo的stomp库，查看源码的时候发现，连接服务器的时候多了一个accept-version的header属性。然后继续查，发现stomp有1.0、1.1、1.2多个版本，我用的stomp-php库没有版本的选项，那么默认就是1.0版本，1.0版本是没有nack的操作命令的。

既然找到线索了，那么就继续。先仿照ack的方法，添加一个nack的方法，然后连接服务器的时候添加accept-version的header属性。测试一下，终于成功了。

资料：
1、修改了别人的stomp-php库，添加了accept-version为1.2的header属性，连接
2、我的activemq.xml修改的配置

转载于:https://my.oschina.net/csq/blog/831995

ActiveMQ Stomp的重新投递和死信相关推荐

activeMQ - 消息重发策略和DLQ死信队列
2019独角兽企业重金招聘Python工程师标准>>> 1:死信队列简介 DLQ-死信队列(Dead Letter Queue)用来保存处理失败或者过期的消息. 出现以下情况时,消息 ...
ActiveMQ知识概括
ActiveMQ知识概括 ActiveMQ简介 Java实现ActiveMQ JMS规范与落地 ActiveMQ的broker Spring,SpringBoot整合ActiveMQ ActiveMQ ...
ActiveMQ（二）
目录八:Spring整合Activemq 生产者的实现: 消费者的实现: 设置监听器九:Springboot整合ActiveMQ 1.queue中实现生产者和消费者 2.topic中实现生产者和消 ...
ActiveMQ简介与安装
1. ActiveMQ简介 ActiveMQ是一种开源的,实现了JMS1.1规范的,面向消息(MOM)的中间件,为应用程序提供高效的.可扩展的.稳定的和安全的企业级消息通信.ActiveMQ使用Apa ...
利用死信交换机接收死信
在失败重试策略中,默认的RejectAndDontRequeueRecoverer会在本地重试次数耗尽后,发送reject给RabbitMQ,消息变成死信,被丢弃. 我们可以给simple.queue ...
消息中间件之rabbitMQ实战-死信队列
该篇文章内容较多,包括有rabbitMq相关的一些简单理论介绍,集成spring Boot,provider消息推送实例,consumer消息消费实例,Direct(直连类型交换机).Fanout(广 ...
RabbitMq(五) -- 死信队列和延迟队列
1. 死信 1.1 死信的概念先从概念解释上搞清楚这个定义,死信,顾名思义就是无法被消费的消息,字面意思可以这样理解,一般来说,producer 将消息投递到 broker 或者直接到 queue ...
6.RokcketMQ消息重试与死信队列
消息发送重试机制 Producer对发送失败的消息进行重新发送的机制,称为消息发送重试机制,也称为消息重投机制. 对于消息重投,需要注意以下几点: 生产者在发送消息时,若采用同步或异步发送方式,发送失 ...
RabbitMQ实现死信队列
目录死信队列是什么怎样实现一个死信队列说明实现过程导入依赖添加配置编写mq配置类添加业务队列的消费者添加死信队列的消费者添加消息发送者添加消息测试类测试死信队列的应用场景总 ...
服务异常通讯高级篇二（死信交换机、DelayExchange延迟队列插件）
服务异常通讯高级篇二(死信交换机) 1.初始死信交换机当一个队列中的消息满足下列情况之一时,可以成为死信(dead letter): 消费者使用basic.reject或 basic.nack声明消 ...

ActiveMQ Stomp的重新投递和死信

ActiveMQ Stomp的重新投递和死信相关推荐

最新文章

热门文章