我经常在我的消费者身上收到这样的日志消息(如下所示)。
如何避免这种情况?
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,忽略(自动确认)重复...
笔记
- 消费者和生产者都使用故障转移传输连接到代理
- 我只有一个 ActiveMQ 实例
生产者和消费者的连接字符串
故障转移:(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,我只发送一次。
哪位高手可以帮帮我?