避免JMS/ActiveMQ上的重复消息
有没有办法抑制在ActiveMQ服务器上定义的队列上的重复消息？
我尝试手动定义JMSMessageID (message.setJMSMessageID(“唯一in”))，但服务器忽略了此修改，并使用内置生成的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是否有类似的解决方案吗？
回答 5
Stack Overflow用户
发布于 2011-02-09 19:55:14
您应该看看Apache Camel，它提供了一个可以与任何JMS提供者一起工作的等价性消费者组件，请参阅：http://camel.apache.org/idempotent-consumer.html
将其与ActiveMQ组件结合使用会使使用JMS变得非常简单，请参阅：http://camel.apache.org/activemq.html
Stack Overflow用户
发布于 2011-02-09 08:41:31
我怀疑ActiveMQ本身是否支持它，但实现一个幂等消费者应该很容易。这样做的一种方式是在生产者端向每个消息添加唯一标识符，现在在消费者端使用存储(db、高速缓存等)，可以进行检查以查看消息之前是否已被接收，并基于该检查继续处理。
我之前看到了一个与此类似的堆栈溢出问题-- Apache ActiveMQ 5.3 - How to configure a queue to reject duplicate messages?，这可能也有帮助。
Stack Overflow用户
发布于 2013-08-08 23:49:24
现在支持删除复制到ActiveMQ传输中的消息。请参阅Connection Configuration Guide中的配置值auditDepth和auditMaximumProducerNumber。
https://stackoverflow.com/questions/4934386
复制相似问题