RabbitMQ 通道因未确认消息引发崩溃

我想跟进确认一下，您的问题是否已经得到解决。如果您还需要更多信息，请随时回复。 如果以上信息对您有所帮助，欢迎点击 “Accept Answer”，帮助社区中的其他用户找到解决方案。谢谢！

您好 Jun Liu，

根据您的描述，这种情况与消费者接收消息的速度超过其处理和确认消息的速度相一致，导致大量未确认消息在 Channel 中不断累积，并进一步增加 Broker 的内存占用。

缓解此问题最有效的方法之一，是配置 Consumer Prefetch Limit（消费者预取限制），以限制 RabbitMQ 在任意时间点可以向单个消费者发送的未确认消息数量。通常可以先将 prefetch 值设置为一个适中的数值，例如 10、50 或 100，然后根据消费者的处理能力以及性能测试结果进行调整。这样可以避免消费者一次性接收过多消息，同时也有助于在可用 Worker 之间实现更加均衡的消息分配。

此外，我建议检查消费者的消息确认（acknowledgment）行为，确认消息是否能够及时完成确认，以及是否存在耗时较长的操作导致 ACK 延迟。与此同时，可以监控队列深度、消息速率、内存使用情况以及 Channel 统计信息，以进一步判断瓶颈主要位于消费者端还是 Broker 端。

最后，如果系统对消息吞吐量的要求较高，可以考虑增加消费者数量进行横向扩展（scale out），同时评估应用程序本身是否存在可以降低消息处理延迟的优化空间。

希望这些信息能够帮助您进一步定位问题。如果您觉得这个回答对您有所帮助，请点击 “Accept Answer”，这样也可以帮助遇到类似问题的其他用户。

Jason