1

我经常在我的消费者身上收到这样的日志消息(如下所示)。

如何避免这种情况?

2013 年 9 月 16 日 14:02:36 WARN (ActiveMQMessageConsumer.java:1348) - 连接时重复调度:ID:tablets-prod-43952-1379342529758-1:4 到消费者:ID:tablets-prod-43952-1379342529758- 1:4:20:1,忽略(自动确认)重复...

笔记

生产者和消费者的连接字符串

故障转移:(ssl://" + ip + ":" + port + ")?maxReconnectAttempts=-1&timeout=5000

代理配置

<destinationPolicy>
    <policyMap>
      <policyEntries>
        <policyEntry topic=">" producerFlowControl="false">
          <pendingMessageLimitStrategy>
            <constantPendingMessageLimitStrategy limit="1000"/>
          </pendingMessageLimitStrategy>
        </policyEntry>
        <policyEntry queue=">" producerFlowControl="false">
          <pendingQueuePolicy>
            <vmQueueCursor/>
          </pendingQueuePolicy>
        </policyEntry>
      </policyEntries>
    </policyMap>
</destinationPolicy>

另一个问题是:

我的消费者经常收到重复的消息。我的意思是两条具有相同正文/有效负载的消息。我知道这一点,因为我在正文中有自己的 ID,我只发送一次。

哪位高手可以帮帮我?

4

0 回答 0