SpringBoot 2.7.15中ConnectionFactory#setMaxInboundMessageBodySize配置不生效问题

以下是针对你遇到的问题的排查和解决方案：

1. 检查RabbitMQ Broker端配置 #

即使客户端设置了maxInboundMessageBodySize，如果RabbitMQ Broker端配置了max_message_size限制（部分托管RabbitMQ服务如Cloud Foundry上的实例可能默认设为64MB），会优先触发Broker的限制。

• 通过RabbitMQ Management UI查看Broker的max_message_size参数（进入Admin -> Policies或Parameters页面）
• 或使用命令行查询：rabbitmqctl list_parameters
• 若存在该限制，需调整Broker配置或联系Cloud Foundry服务提供商修改参数

2. 验证ListenerContainer的实际配置 #

ConnectionFactory的maxInboundMessageBodySize设置可能未被消息监听容器继承，需确认容器的实际配置值：

• 添加代码打印容器的配置：

  @Autowired
  private MessageListenerContainer messageListenerContainer;
  
  @PostConstruct
  public void verifyContainerConfig() {
      if (messageListenerContainer instanceof AbstractMessageListenerContainer) {
          AbstractMessageListenerContainer container = (AbstractMessageListenerContainer) messageListenerContainer;
          System.out.println("Listener Container Max Inbound Body Size: " + container.getMaxInboundMessageBodySize());
      }
  }
  

• 若输出仍为64MB，需显式为监听容器设置该参数：

  @Bean
  public SimpleMessageListenerContainer customListenerContainer(ConnectionFactory connectionFactory) {
      SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
      container.setConnectionFactory(connectionFactory);
      container.setQueueNames("your-target-queue");
      container.setMessageListener(yourMessageListenerBean());
      container.setMaxInboundMessageBodySize(100 * 1024 * 1024); // 100MB
      return container;
  }
  

3. 使用配置文件替代代码配置 #

避免代码配置可能的遗漏，直接通过application.properties或application.yml设置监听容器的参数：

# 针对Simple类型监听容器
spring.rabbitmq.listener.simple.max-inbound-message-body-size=100MB
# 针对Direct类型监听容器（若使用）
spring.rabbitmq.listener.direct.max-inbound-message-body-size=100MB

4. 排查Cloud Foundry环境干扰 #

• 查看应用环境变量：执行cf env your-app-name，检查VCAP_SERVICES中的RabbitMQ配置是否包含覆盖应用设置的参数
• 确认JVM启动参数中是否有系统属性覆盖了AMQP配置，比如-Dspring.rabbitmq.listener.simple.max-inbound-message-body-size

5. 确认消息实际大小 #

验证消息体的真实大小是否确实为71506699字节（约68MB），排除消息头部/属性额外占用空间导致的误判。

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