0


解决RabbitMQ的The channelMax limit is reached. Try later.

The channelMax limit is reached. Try later.顾名思义就是channel达到数量限制
查看源码得出
在这里插入图片描述
大概意思就是:
默认最大通道数;2047,因为它在服务器端是第2048个,每个连接用于协商和错误通信。
也可以在rabbitmq的管控台看出
在这里插入图片描述
总结:一个客户端连接(一个服务)默认只能有2047个通道数,也就是2047个消费者,在高并发的情况可能不够用,其实这个数字是可以修改。修改步骤如下:
第一:
创建rabbitmq配置文件rabbitmq.conf

default_user = guest
default_pass = guest
#最大通道数量
channel_max =6114

在这里插入图片描述
第二:关闭rabbitmq镜像服务
docker stop 镜像名/镜像id

docker stop rabbitmq

第三:移除rabbitmq镜像服务
docker rm 镜像名/镜像id

docker rm rabbitmq

第四:启动rabbitmq镜像服务

docker run -d --name rabbitmq \
-p 5673:5672 \
-p 15673:15672 \
-v /etc/rabbitmq/rabbitmq.conf:/etc/rabbitmq/rabbitmq.conf \
-e RABBITMQ_CONFIG_FILE=/etc/rabbitmq/rabbitmq.conf \
--restart=always \
rabbitmq:3.11.1-management

第五:在消费者服务配置,不配置不生效
具体配置如下:

importorg.springframework.amqp.rabbit.connection.CachingConnectionFactory;importorg.springframework.beans.factory.annotation.Value;importorg.springframework.context.annotation.Bean;importorg.springframework.context.annotation.Configuration;/**
 * @author leishen
 */@ConfigurationpublicclassRabbitMQConfiguration{@Value("${spring.rabbitmq.username}")privateString username;@Value("${spring.rabbitmq.password}")privateString password;@Value("${spring.rabbitmq.host}")privateString host;@Value("${spring.rabbitmq.port}")privateInteger port;@Value("${spring.rabbitmq.virtual-host}")privateString virtualHost;/**
     * 设置最大通道数
     * @return
     */@BeanpublicCachingConnectionFactorycachingConnectionFactory(){CachingConnectionFactory cachingConnectionFactory=newCachingConnectionFactory();com.rabbitmq.client.ConnectionFactory rabbitConnectionFactory = cachingConnectionFactory.getRabbitConnectionFactory();//默认2047
        rabbitConnectionFactory.setRequestedChannelMax(6114);
        rabbitConnectionFactory.setUsername(username);
        rabbitConnectionFactory.setPort(port);
        rabbitConnectionFactory.setHost(host);
        rabbitConnectionFactory.setVirtualHost(virtualHost);
        rabbitConnectionFactory.setPassword(password);return cachingConnectionFactory;}}

第六:打开管控台查看,结果配置生效
在这里插入图片描述


本文转载自: https://blog.csdn.net/m0_46360888/article/details/130310217
版权归原作者 shmily&&ylimhs 所有, 如有侵权,请联系我们删除。

“解决RabbitMQ的The channelMax limit is reached. Try later.”的评论:

还没有评论