admin管理员组文章数量:1578031
异常解释
高并发场景下，channel数到达了限制，所以不能继续创建
自搭建RabbitMQ-解决方案
1、自定义配置
@Configuration
@Slf4j
public class RabbitMQConfig {
@Bean
public RabbitTemplate rabbitTemplate(final ConnectionFactory connectionFactory) {
CachingConnectionFactory cachingConnectionFactory = (CachingConnectionFactory) connectionFactory;
// 设置ChannelMax为4095
cachingConnectionFactory.getRabbitConnectionFactory().setRequestedChannelMax(4095);
final RabbitTemplate rabbitTemplate = new RabbitTemplate(cachingConnectionFactory);
rabbitTemplate.setMessageConverter(jackson2MessageConverter());
rabbitTemplate.setMandatory(true);
rabbitTemplate.setConfirmCallback((correlationData, b, s) -> {
if(!b){
log.error("confirmCallBack 发送失败的数据：{}",correlationData);
log.error("confirmCallBack 确认情况：{}",b);
log.error("confirmCallBack 发送失败的原因：{}",s);
}
});
rabbitTemplate.setReturnCallback((message, i, s, s1, s2) -> {
log.error("returnCallBack 消息：{}",message);
log.error("returnCallBack 回应码：{}",i);
log.error("returnCallBack 回应信息：{}",s);
log.error("returnCallBack 交换机：{}",s1);
log.error("returnCallBack 路由键：{}",s2);
});
return rabbitTemplate;
}
@Bean
public Jackson2JsonMessageConverter jackson2MessageConverter() {
return new Jackson2JsonMessageConverter();
}
}
2、同步修改MQ服务端的配置
rabbitmq.conf
## Set the max permissible number of channels per connection.
## 0 means "no limit".
##在配置文件中，输入以下参数和自己想要设置的值即可，如果用不到2047，那就不用配置
# channel_max = 128
云服务RabbitMQ解决方案
针对使用的付费版的MQ云服务，可以试试以下方式，配置rabbitMq连接缓存
springBoot 2.3+
rabbitmq:
cache:
connection:
size: 1000
channel:
size: 64
参考：https://blog.csdn/qq_35374224/article/details/106721801
本文标签： 解决方案channelMaxRabbitMQreachedlimit
版权声明：本文标题：RabbitMQ The channelMax limit is reached. Try later. 解决方案 内容由热心网友自发贡献，该文观点仅代表作者本人， 转载请联系作者并注明出处：https://www.elefans.com/dianzi/1725724917a1038832.html， 本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容，一经查实，本站将立刻删除。
发表评论