我使用Python api将消息插入RabbitMQ,然后使用go api从RabbitMQ获取消息。
关键 1:由于性能原因,RabbitMQ ACK 设置为 false。
我通过python api插入RabbitMQ大约超过100,000,000条消息,但是当我使用go api获取消息时,我发现消息的插入数量不等于获取数量。插入动作和
get 动作是并发的。
关键 2:丢失消息率不超过 1,000,000% 1。
插入动作有日志,python api显示所有插入的消息都成功。
获取操作有日志,go api 显示所有获取消息成功。但数量并不相等。
问题1:我不知道如何找到消息丢失的地方。谁能给我一个建议,如何找到消息丢失的地方?
问题2:有什么策略可以确保消息不会丢失?
相关分类