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