RabbitMQ 消息丢失

我使用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:有什么策略可以确保消息不会丢失?


米琪卡哇伊
浏览 175回答 1
1回答
打开App,查看更多内容
随时随地看视频慕课网APP

相关分类

Go