时间戳

首页 > 解决方案 > ActiveMQ messageId 无法停止复制

spring - ActiveMQ messageId 无法停止复制

问题描述

我正在使用 ActiveMQ 进行消息传递，并且有一个要求，如果消息是重复的，那么它应该由 AMQ 自动处理。为此，我生成唯一的消息密钥并设置为消息处理器。以下是代码：

jmsTemplate.convertAndSend(dataQueue, event, messagePostProccessor -> {

    LocalDateTime dt = LocalDateTime.now();
    long ms = dt.get(ChronoField.MILLI_OF_DAY) / 1000;
    String messageUniqueId = event.getResource() + event.getEntityId() + ms;
    System.out.println("messageUniqueId : " + messageUniqueId);
    messagePostProccessor.setJMSMessageID(messageUniqueId);
    messagePostProccessor.setJMSCorrelationID(messageUniqueId);
    return messagePostProccessor;
});

可以看出，代码生成唯一的 id，然后将其设置为 messagepostproccessor。

可以帮助我吗，我需要做其他配置吗？

标签： springactivemqactivemq-artemis

解决方案

消费者可以接收到重复的消息主要有两个原因：生产者多次发送相同的消息，或者消费者多次收到相同的消息。

Apache ActiveMQ Artemis 包含强大的自动重复消息检测功能，可以多次过滤生产者发送的消息。

为了防止消费者多次接收相同的消息，必须实现幂等消费者，即 Apache Camel 提供了可与任何 JMS 提供者一起使用的幂等消费者组件，请参阅：http ://camel.apache.org/idempotent-consumer .html

推荐阅读