避免在JMS/ActiveMQ上重复的消息

Question

有一种方法可以抑制ActiveMQ服务器上定义的队列上的重复消息吗？

我尝试手动定义JMSMessageID,(message.setJMSMessageID("uniqueid")),但服务器忽略此修改并传递带有内置生成的JMSMessageID的消息.

根据规范,我没有找到关于如何重复删除邮件的参考.

在HornetQ中,为了解决这个问题,我们需要在消息定义上声明HQ特定属性org.hornetq.core.message.impl.HDR_DUPLICATE_DETECTION_ID.

即:

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是否有类似的解决方案？

Answer 1

您应该查看Apache Camel,它提供了一个可与任何JMS提供程序一起使用的Idempotent使用者组件,请参阅:http://camel.apache.org/idempotent-consumer.html

将它与ActiveMQ组件结合使用可以非常简单地使用JMS,请参阅:http: //camel.apache.org/activemq.html

Answer 2

我怀疑ActiveMQ是否本身就支持它，但是实现幂等消费者应该很容易。一种方法是在生产者端为每个消息添加唯一的标识符，现在在消费者端使用商店（数据库，缓存等），可以检查消息是否在之前和之后收到。继续根据该检查进行处理。

我在同一行上看到了先前的stackoverflow问题-Apache ActiveMQ 5.3-如何配置队列以拒绝重复消息？，这也可能会有所帮助。