SpringBoot管理RabbitMQ中的Channel详解

Channel是什么

RabbitMQ是AMQP0-9-1协议的实现，先来看看AMQP0-9-1协议中对通道Channel的阐述。

有些应用程序需要与broker建立多个连接。但是，保持多个TCP连接同时打开是不可取的，因为这样做会消耗系统资源，使配置防火墙更加困难。AMQP0-9-1的Connection可以多路复用，Channel可以被认为是“共享一个TCP连接的轻量级连接”。

客户端执行的每个协议操作都发生在一个channel上。在特定channel上的通信与在另一个channel上的通信完全独立，因此每个协议方法也都带有信道ID(a.k.a)。一个整数，代理和客户端都使用它来确定该方法用于哪个通道。

channel仅存在于connection的上下文中，而不会单独存在。当channel关闭时，其上的所有channel也会关闭。

对于使用多个线程/进程进行处理的应用程序，为每个线程/进程打开一个新channel而不在它们之间共享channel是很常见的。

在普通的JAVAEE项目中，经常采用1个进程-1个connection-1个channel。

但是这在JAVAWEB场景中实不可取的。

一个web项目仅有1个进程，会有非常多的线程，每个线程都创建一个connection是不可取的。

在AMQP-0-9-1协议中推荐了使用每个线程使用一个独立的channel，这样不同线程之间的channel相互独立，并且公用同一个connection。

但是问题又来了，在并发情况下，web场景下，用户的每一次http请求都是一个线程，难道这样的每一个http请求都要对应创建一个channel吗？

Spring在集成RabbitMQ时对这个问题有了非常好的解决。

Spring如何管理Channel？

springboot使用了RabbitMQ中的IO多路复用的理念，并对这种方案在web场景下进行了优化，尽可能的复用空闲中的channel。

boot默认使用 CachingConnectionFactory 对 Connection 和空闲 Channel 进行缓存。

看看Spring中的RabbitMQ是如何工作的：

Spring中对RabbitMQ的消息操作都是通过一个Template模板对象 RabbitTemplate ，该对象中封装了对消息的接受和发送的各种重载方法。

消息的send都需要调用一个核心私有方法 doExcute() 。

管理RabbitMQ中的事务Channel

Spring也是通过 TransactionSupport 进行管理RabbitMQ中的事务Channel。

这一点和MyBatis的 SqlSessionTemplate 管理开启事务的 SqlSession 的步骤相同。

这里不多赘述如果管理事务的channel

1.当第一次有请求连接rabbitmq时，spring创建一个AMQP的connection，并使用CachingConnectionFactory将其封装并缓存起来。

2.然后使用这个connection，创建channel，当channel的任务执行完成后（也就是逻辑close时，并非真正的关闭了channel，而是在内存中给channel创建了一个标记。）

则使用 CachingConnectionFactory 的静态子类 ChannelConnectionFactoryProxy 把这个channel缓存到一个空闲列表中。开启了事务的channel存放在不同的列表中。

3.其他线程执行任务时，CachingConnectionFactory中获取connection，然后创建channel时，会去ChannelConnectionFactoryProxy的空闲列表中寻找哪些channel是open状态。

然后将寻找到的一个channel移出列表，并使用这个channel执行任务。（取出缓存中的channel这一过程是同步代码块, 开启了事务的channel存放在不同的列表中。）

4.任务执行完毕，将channel在缓存入空闲列表中。默认最多缓存25个channel

到此这篇关于SpringBoot管理RabbitMQ中的Channel详解的文章就介绍到这了,更多相关SpringBoot管理Channel内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

最新评论