java - 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。