咸阳网站建设公司湖北长安建设网站

1.前言

    由于之前写了一个好用的rabbitmq-spring-boot-start启动器，后面在生产实践之后反馈消费者连接的Channel数量过多，一个消费者的Channel数量可以达到好几百，最多的要干到900多个了，于是乎我就去看了下之前我写的组件的源码，然后去查了下CacheMode的两种模式及相关的参数设置，最终找到了这个是由于一下参数没有设置导致的：

    RabbitProperties类中的静态内部类Channel中的size和checkoutTimeout没有设置

public static class Channel {/*** Number of channels to retain in the cache. When "check-timeout" > 0, max* channels per connection.*/private Integer size;/*** Duration to wait to obtain a channel if the cache size has been reached. If* 0, always create a new channel.*/private Duration checkoutTimeout;，，，，，，，，，，，，，，，，，，，，，，，，，，，，，，，，
}

    size的注释中文意思：缓存中要保留的通道数。当“检查超时”>0时，每个连接的通道数最大值

    checkoutTimeout的注释的中文：如果已达到缓存大小，则等待多长时间获取通道。如果为0，始终创建新信道，如果超时未获取到信道，则消费端可能会报错。

    简单介绍一下CacheMode的两种模式，RabbitProperties类中的静态内部类Connection

public static class Connection {/*** Connection factory cache mode.*/private CacheMode mode = CacheMode.CHANNEL;/*** Number of connections to cache. Only applies when mode is CONNECTION.*/private Integer size;}

CacheMode枚举

public enum CacheMode {/*** Cache channels - single connection.*/CHANNEL,/*** Cache connections and channels within each connection.*/CONNECTION}

    spring-rabbit提供了一个默认的缓存连接工厂：CachingConnectionFactory，而它有两种连接的模式：

    CHANNEL：单例连接，不缓存Channel信道，这里使用单列的避免了连接的创建和销毁，是一种池化技术，很好的复用已经存在的连接。

    CONNECTION：多连接，会缓存对应的Channel信道，当使用这种模式可以提高吞吐量，但是需要设置好对应Connection的size，这个siz只对CONNECTION默认是下设置有用，目的是为了防止连接爆炸

    默认使用的CHANNEL模式，所以就会有这个问题，如果使用spingBoot官网那个估计也会有这个问题的，这个问题就相当于一条消息一个channel信道，回不干扰，相互隔离。

2.解决

2.1消费监听方法中关闭channel

    这种方式在消费者监听方法的try/catch/finally中释放channel资源，但是这种方式不推荐，资源反复创建之后又被关闭清理，这种处理上没有起到复用的效果，简单粗暴。

if (Objects.nonNull(channel)) {channel.basicAck(message.getMessageProperties().getDeliveryTag(), true);try {channel.close();} catch (Exception e) {log.error("消费者监听关闭channel异常:{}", e.getStackTrace());}
}

2.2 配置设置两个参数

zlf:rabbit:rps:## 如果virtual-host不同,在配置一个即可,addresses不同也是可以在配置,eqps的下标以之对应上即可- rabbitmq:virtual-host: xxxxxaddresses: xxxxx,xxxxxxx,xxxxx,xxxx #这里可以配置多个,集群情况下可以逗号分割，配置多个ipport: 5672username: "xxx"password: "xxx"cache:channel: size: 10checkout-timeout: 10000

    需要配置cache.channel的size和checkout-timeout，size配置为10个，一个消费者最多有有10channel信道，但是checkout-timeout参数也要配置，checkout-timeout的值需要大于零，这个参数的值设置为10s是由于SpringAMQP的默认超时时间是10s，所以这个值参考了SpringAMQP的默认超时时间来设置，如果高峰期请求并发高，就有可能需要配置缩短这个超时时间的值，让其可以更快的获取到channel信道。

3.总结

    rabbitmq-spring-boot-start启动器的配置是将spirngBoot的那个启动器的配置RabbitProperties包了一层，rabbitmq-spring-boot-start启动器兼容spirngBoot的那个启动器的配置RabbitProperties的配置，可以支持操作多个rabbmitMq、多个虚拟机和多个队列的多对多的关系，只需简单的配置，就可以实现发送各种类型的消息，简化了代码量，业务上也只需要写简单的监听的代码就可以了，可以说是非常的丝滑，只用去关注处理业务即可，本次分享到此结束，希望我的分享对你有所启发和帮助，请一键三连，么么么哒!