仅当重复消息仍与ActiveMQ Artemis和JBoss EAP 7.1排队时，才丢弃重复消息

Question

我们在JBoss EAP7.1上使用ActiveMQ Artemis。

我们注意到，一旦具有特定_amq_duppl_id值的消息通过队列传递，如果消息生成器试图再次将具有相同_amq_duppl_id值的消息发送到同一队列，则代理将丢弃该消息。然而，我们的需要是仅当重复消息仍在队列中时才丢弃它们。

有没有办法达到这个目的？

public void sendMessage(final T msg, final String id) { 
   jmsTemplate.send(destination, new MessageCreator() { 
      @Override
      public Message createMessage(Session session) throws JMSException { 
         Message message = session.createObjectMessage(msg);
         message.setStringProperty("_AMQ_DUPL_ID", id);
         return message;
      }
   });
}

为了解决这个问题，我们认为像Artemis这样的重复消息检测会有所帮助。然而，当外部应用程序挂起我们的消费者时，我们需要定时器能够再次将消息放入队列。

Answer 1

ActiveMQ Artemis上的重复消息检测按设计进行。它的目标是避免使用者收到重复消息的任何机会，这意味着即使消息可能不再在队列中（例如，因为它被使用了），该消息的任何重复仍然应该被拒绝。

这里的要求类似于询问如何将具有相同主键的多条记录插入到数据库表中。它根本不能，因为拥有主键的全部意义在于避免重复记录。

我建议您为websocket调用实现某种超时，否则您的应用程序将受到您无法控制的资源的负面影响。