Avoiding duplicated messages on JMS/ActiveMQ(避免 JMS/ActiveMQ 上的重复消息)
问题描述
有没有办法抑制 ActiveMQ 服务器上定义的队列上的重复消息?
Is there a way to suppress duplicated messages on a queue defined on ActiveMQ server?
我尝试手动定义 JMSMessageID,(message.setJMSMessageID("uniqueid")),但服务器忽略了这个修改并使用内置生成的 JMSMessageID 传递消息.
I tried to define manually JMSMessageID, (message.setJMSMessageID("uniqueid")), but server ignores this modification and deliver a message with built-in generated JMSMessageID.
按照规范,我没有找到有关如何删除重复消息的参考.
By specification, I didn't found a reference about how to deduplicate messages.
在 HornetQ 中,为了处理这个问题,我们需要在消息定义中声明 HQ 特定的属性 org.hornetq.core.message.impl.HDR_DUPLICATE_DETECTION_ID.
In HornetQ, to deal with this problem, we need to declare the HQ specific property org.hornetq.core.message.impl.HDR_DUPLICATE_DETECTION_ID on message definition.
即:
Message jmsMessage = session.createMessage();
String myUniqueID = "This is my unique id"; // Could use a UUID for this
message.setStringProperty(HDR_DUPLICATE_DETECTION_ID.toString(), myUniqueID);
有人知道 ActiveMQ 是否有类似的解决方案?
Somebody knows if there's a similar solution for ActiveMQ?
推荐答案
你应该看看 Apache Camel,它提供了一个可以与任何 JMS 提供者一起工作的幂等消费者组件,请参阅:http://camel.apache.org/idempotent-consumer.html
You should look at Apache Camel, it provides an Idempotent consumer component that would work with any JMS provider, see: http://camel.apache.org/idempotent-consumer.html
将它与 ActiveMQ 组件结合使用使得 JMS 的使用变得非常简单,请参阅:http://camel.apache.org/activemq.html
Using that in combination with the ActiveMQ component makes using JMS quite simple, see: http://camel.apache.org/activemq.html
这篇关于避免 JMS/ActiveMQ 上的重复消息的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持编程学习网!
本文标题为:避免 JMS/ActiveMQ 上的重复消息
基础教程推荐
- 如何使用 Stream 在集合中拆分奇数和偶数以及两者的总和 2022-01-01
- Spring Boot Freemarker从2.2.0升级失败 2022-01-01
- 由于对所需库 rt.jar 的限制,对类的访问限制? 2022-01-01
- 如何强制对超级方法进行多态调用? 2022-01-01
- Java 中保存最后 N 个元素的大小受限队列 2022-01-01
- 如何使用 Eclipse 检查调试符号状态? 2022-01-01
- 如何在不安装整个 WTP 包的情况下将 Tomcat 8 添加到 Eclipse Kepler 2022-01-01
- 在螺旋中写一个字符串 2022-01-01
- 如何对 HashSet 进行排序? 2022-01-01
- 首次使用 Hadoop,MapReduce Job 不运行 Reduce Phase 2022-01-01