问题描述
我知道在其他帖子中提到了这个错误 (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