上传11MB以上媒体时RabbitMQ队列TCP连接丢失，请求技术协助

问题现象 #

• 上传11MB以上媒体文件时，对应RabbitMQ队列出现TCP连接丢失，其余队列运行正常
• 异常队列内消息处于Ready状态且未被确认，需重启消费者才能恢复队列连接
• 存在消息payload截断的情况

排查与修复建议 #

1. 调整RabbitMQ大消息相关配置 #

RabbitMQ默认的帧大小和单条消息限制可能无法适配11MB以上的消息，需修改以下配置：

• 服务器端：编辑rabbitmq.conf，调整帧大小和最大消息限制（根据实际业务需求设置）：

  # 设置TCP帧大小为16MB（需大于单条消息大小）
  frame_max = 16777216
  # 允许单条消息最大为20MB
  max_message_size = 20971520
  

  修改后重启RabbitMQ服务生效。
• 客户端：确保客户端连接时同步设置对应的frame_max参数，以Java客户端为例：

  ConnectionFactory factory = new ConnectionFactory();
  factory.setFrameMax(16777216); // 与服务端保持一致
  

2. 排查操作系统TCP缓冲区限制 #

大消息传输可能因系统TCP缓冲区不足导致连接中断，检查并调整：

• Linux系统执行以下命令查看当前缓冲区大小：

  sysctl net.core.rmem_max net.core.wmem_max
  

• 若值过小，临时调整为16MB：

  sysctl -w net.core.rmem_max=16777216
  sysctl -w net.core.wmem_max=16777216
  

• 写入/etc/sysctl.conf实现永久生效：

  net.core.rmem_max=16777216
  net.core.wmem_max=16777216
  

3. 优化消费者端配置 #

• 调小prefetch_count值，避免一次性预取过多大消息导致内存溢出或连接异常：

  channel.basicQos(1); // 每次仅预取1条大消息
  

• 确保消费者的消息接收缓冲区足够大，避免因缓冲区满导致消息截断。

4. 大消息拆分方案（替代优化） #

若调整配置后仍存在问题，建议将11MB以上的媒体文件拆分为多个小消息分片传输，消费者端接收后再拼接还原，从根源规避大消息传输风险。

内容的提问来源于stack exchange，提问作者Sahana S