AmqpResourceNotAvailableException：已达到 channelMax 限制稍后再试

如何解决AmqpResourceNotAvailableException：已达到 channelMax 限制稍后再试

我知道在其他帖子中提到了这个错误 (https://github.com/spring-projects/spring-amqp/issues/999 和 https://github.com/spring-projects/spring-amqp/issues/853)，但我还没有找到适合我的解决方案。

我的项目定义了一组按队列发布和消费消息的微服务。当我 以每秒 200 个事务运行我的压力测试我收到此错误：

已达到 channelMax 限制。稍后再试

此错误仅在余下的一个微服务中显示。

我在我的项目中使用：

spring-boot-starter-amqp.2.3.4.RELEASE
 spring-rabbit:2.2.11

我的兔子设置是：

  public ConnectionFactory publisherConnectionFactory() {
    final CachingConnectionFactory connectionFactory = new 
    CachingConnectionFactory(rabbitMQConfigProperties.getHost(),rabbitMQConfigProperties.getPort());
    connectionFactory.setUsername(rabbitMQConfigProperties.getUser());
    connectionFactory.setPassword(rabbitMQConfigProperties.getpass());
    connectionFactory.setPublisherReturns(true);
    connectionFactory.setPublisherConfirms(true);
    connectionFactory.setConnectionNameStrategy(connecFact -> rabbitMQConfigProperties.getNameStrategy());
    connectionFactory.setRequestedHeartBeat(15);
    return connectionFactory;
}


@Bean(name = "firstRabbitTemplate")
public RabbitTemplate firstRabbitTemplate(MessageDeliveryCallbackService messageDeliveryCallbackService) {
    final RabbitTemplate template = new RabbitTemplate(publisherConnectionFactory());
    template.setMandatory(true);
    template.setMessageConverter(jsonMessageConverter());
    template.setReturnCallback((msg,i,s,s1,s2) -> {
        log.error("Publisher Unable to deliver the message {},Queue {}: --------------",s2);
        messageDeliveryCallbackService.returnedMessage(msg,s2);
    });
    template.setConfirmCallback((correlationData,ack,cause) -> {
        if (!ack) {
            log.error("Message unable to connect Exchange,Cause {}: ack{}--------------",cause,ack);
        }
    });
    return template;
}

我的问题是：

我应该设置 ChannelCacheSize 和 setChannelCheckoutTimeout 吗？。我做了一个将 channelCacheSize 增加到 50 的测试，但问题仍然存在。根据我之前提到的，这些参数的最佳值是多少？我读到 channelCheckoutTimeout 应该高于 0 但我不知道我必须设置什么值。

现在我每秒处理大约 200 个事务，但这个数字会逐渐增加

提前致谢。

解决方法

channel_max 在客户端和服务器之间协商并应用于连接。默认值为 2047，因此您的经纪人似乎施加了下限。

https://www.rabbitmq.com/channels.html#channel-max

使用发布者确认时，将通道返回到缓存会延迟，直到收到确认；因此，当音量较大时，通常需要更多的通道。

您可以重新配置代理以允许更多通道，或者将 CacheMode 更改为 CONNECTION 而不是默认值 (CHANNEL)。

https://docs.spring.io/spring-amqp/docs/current/reference/html/#cachingconnectionfactory