spring-boot - 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 {}: --------------", s1, s2);
        messageDeliveryCallbackService.returnedMessage(msg, i, s, s1, 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 个事务，但这个数字会逐渐增加

先感谢您。

标签： spring-bootspring-integrationspring-rabbit

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

spring-boot - AmqpResourceNotAvailableException：达到 channelMax 限制。等会再试

问题描述

解决方案

推荐阅读