我使用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:有什么策略可以确保消息不会丢失?
1 回答
- 1 回答
- 0 关注
- 174 浏览
添加回答
举报
0/150
提交
取消