RabbitMQ The channelMax limit is reached. Try later. 解决方案

超、凢脫俗 2022-10-14 01:16 168阅读 0赞

**异常解释**

高并发场景下，channel数到达了限制，所以不能继续创建

## 自搭建RabbitMQ-解决方案 ##

**1、自定义配置**

@Configuration
    @Slf4j
    public class RabbitMQConfig { 
    
    
        @Bean
        public RabbitTemplate rabbitTemplate(final ConnectionFactory connectionFactory) { 
            CachingConnectionFactory cachingConnectionFactory = (CachingConnectionFactory) connectionFactory;
            // 设置ChannelMax为4095
            cachingConnectionFactory.getRabbitConnectionFactory().setRequestedChannelMax(4095);
            final RabbitTemplate rabbitTemplate = new RabbitTemplate(cachingConnectionFactory);
            rabbitTemplate.setMessageConverter(jackson2MessageConverter());
            rabbitTemplate.setMandatory(true);
            rabbitTemplate.setConfirmCallback((correlationData, b, s) -> { 
                if(!b){ 
                    log.error("confirmCallBack 发送失败的数据：{}",correlationData);
                    log.error("confirmCallBack 确认情况：{}",b);
                    log.error("confirmCallBack 发送失败的原因：{}",s);
                }
            });
            rabbitTemplate.setReturnCallback((message, i, s, s1, s2) -> { 
                log.error("returnCallBack 消息：{}",message);
                log.error("returnCallBack 回应码：{}",i);
                log.error("returnCallBack 回应信息：{}",s);
                log.error("returnCallBack 交换机：{}",s1);
                log.error("returnCallBack 路由键：{}",s2);
            });
            return rabbitTemplate;
        }
    
        @Bean
        public Jackson2JsonMessageConverter jackson2MessageConverter() { 
            return new Jackson2JsonMessageConverter();
        }
    }

**2、同步修改MQ服务端的配置**  
rabbitmq.conf

## Set the max permissible number of channels per connection.
    ## 0 means "no limit".
    ##在配置文件中，输入以下参数和自己想要设置的值即可，如果用不到2047，那就不用配置
    # channel_max = 128

## 云服务RabbitMQ解决方案 ##

针对使用的付费版的MQ云服务，可以试试以下方式，配置rabbitMq连接缓存

springBoot 2.3+

rabbitmq:
        cache:
          connection:
            size: 1000
          channel:
            size: 64

参考：[https://blog.csdn.net/qq\_35374224/article/details/106721801][https_blog.csdn.net_qq_35374224_article_details_106721801]

[https_blog.csdn.net_qq_35374224_article_details_106721801]: https://blog.csdn.net/qq_35374224/article/details/106721801