ActiveMQ Artemis中的消息重复在消息被使用后仍然被拒绝

Question

我使用的是ActiveMQ Artemis 2.10，在我的用例中，我希望避免队列中有重复的消息，所以在向队列发送消息之前，我设置了属性message.hdr_duplicate_detection_id：

ClientConsumer consumer = session.createConsumer(queueName);
ClientMessage message = consumer.receive();
message.putStringProperty(Message.HDR_DUPLICATE_DETECTION_ID, hashVal);

但问题是，即使在此消息被消耗之后，如果我试图发送另一个具有相同hashVal值的消息，新消息也会被拒绝。即使队列中没有其他具有相同hashVal值的消息。

是否有一种方法可以将重复检测设置为仅当队列中存在具有相同HDR_DUPLICATE_DETECTION_ID的未使用消息时才拒绝消息？

Answer 1

你看到的行为是意料之中的。对于每个邮件，重复检测ID应该是唯一的。如果您对多个消息使用相同的ID，那么它可能会被拒绝，如果它还没有被驱逐，代理上的重复ID缓存就会被拒绝。根据缓存的大小从缓存中驱逐ID。一旦缓存达到其配置的大小，它将在添加新ID时开始删除最旧的ID。