【Java】已解决：org.springframework.amqp.AmqpResourceNotAvailableException: The channelMax limit is reache

屿小夏

发布于 2024-08-07 16:42:43

6860

已解决：org.springframework.amqp.AmqpResourceNotAvailableException: The channelMax limit is reached

一、分析问题背景

在使用Spring AMQP进行消息传递时，开发者可能会遇到org.springframework.amqp.AmqpResourceNotAvailableException: The channelMax limit is reached的报错。该异常通常在RabbitMQ的频道数达到上限时抛出。RabbitMQ为每个连接分配的最大频道数是有限的，当使用的频道数超过配置的上限时，就会出现该异常。

场景：在一个高并发的消息处理系统中，多个消费者和生产者频繁创建和关闭RabbitMQ频道，导致频道数达到上限，出现The channelMax limit is reached异常。

示例代码片段：

import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class RabbitConfig {

    @Bean
    public CachingConnectionFactory connectionFactory() {
        CachingConnectionFactory connectionFactory = new CachingConnectionFactory("localhost");
        // 未设置频道上限，使用默认值
        return connectionFactory;
    }

    @Bean
    public RabbitTemplate rabbitTemplate(CachingConnectionFactory connectionFactory) {
        return new RabbitTemplate(connectionFactory);
    }
}

二、可能出错的原因

导致org.springframework.amqp.AmqpResourceNotAvailableException: The channelMax limit is reached报错的原因主要有以下几点：

频道数达到上限：RabbitMQ默认的最大频道数为2047，当同时打开的频道数超过此值时，会抛出该异常。
未正确关闭频道：在高并发环境中，频道没有及时关闭，导致频道资源耗尽。
配置不合理：RabbitMQ的channelMax参数未合理配置，导致默认的最大频道数过低。

三、错误代码示例

以下是一个可能导致该报错的代码示例，并解释其错误之处：

import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class RabbitConfig {

    @Bean
    public CachingConnectionFactory connectionFactory() {
        CachingConnectionFactory connectionFactory = new CachingConnectionFactory("localhost");
        // 未设置频道上限，使用默认值
        return connectionFactory;
    }

    @Bean
    public RabbitTemplate rabbitTemplate(CachingConnectionFactory connectionFactory) {
        return new RabbitTemplate(connectionFactory);
    }

    public void sendMessage(String message) {
        RabbitTemplate rabbitTemplate = rabbitTemplate(connectionFactory());
        // 每次发送消息都创建一个新频道
        rabbitTemplate.convertAndSend("exchange", "routingKey", message);
    }
}

错误分析：

未设置频道上限：默认的channelMax为2047，未设置合理的频道上限。
每次发送消息都创建新频道：在高并发环境中，频繁创建新频道，导致频道数迅速达到上限。

四、正确代码示例

为了解决该报错问题，可以通过以下方法设置合理的频道上限，并确保频道及时关闭。以下是正确的代码示例：

import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class RabbitConfig {

    @Bean
    public CachingConnectionFactory connectionFactory() {
        CachingConnectionFactory connectionFactory = new CachingConnectionFactory("localhost");
        // 设置合理的频道上限，例如5000
        connectionFactory.setChannelCacheSize(5000);
        return connectionFactory;
    }

    @Bean
    public RabbitTemplate rabbitTemplate(CachingConnectionFactory connectionFactory) {
        return new RabbitTemplate(connectionFactory);
    }

    public void sendMessage(String message) {
        RabbitTemplate rabbitTemplate = rabbitTemplate(connectionFactory());
        // 使用现有的RabbitTemplate发送消息
        rabbitTemplate.convertAndSend("exchange", "routingKey", message);
    }
}

通过上述代码，我们可以设置合理的频道上限，并确保消息发送使用现有的RabbitTemplate实例，避免频繁创建新频道。