SpringBoot管理RabbitMQ中的Channel详解

 更新时间:2023年08月29日 08:44:50   作者:Abstracted  
这篇文章主要介绍了SpringBoot管理RabbitMQ中的Channel详解,channel仅存在于connection的上下文中,而不会单独存在,当channel关闭时,其上的所有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内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • SpringBoot整合RabbitMQ实现六种工作模式的示例

    SpringBoot整合RabbitMQ实现六种工作模式的示例

    这篇文章主要介绍了SpringBoot整合RabbitMQ实现六种工作模式,本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2022-07-07
  • Java 开发的几个注意点总结

    Java 开发的几个注意点总结

    这篇文章主要介绍了Java开发的几个注意点的相关资料,需要的朋友可以参考下
    2016-09-09
  • Java使用Google Zxing生成二维码的例子

    Java使用Google Zxing生成二维码的例子

    本篇文章主要介绍了Java使用Google Zxing生成二维码的例子。小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2017-03-03
  • SpringBoot注册Filter的两种实现方式

    SpringBoot注册Filter的两种实现方式

    这篇文章主要介绍了SpringBoot注册Filter的两种实现方式,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2020-08-08
  • SpringMVC JSON数据交互及RESTful支持实现方法

    SpringMVC JSON数据交互及RESTful支持实现方法

    这篇文章主要介绍了SpringMVC JSON数据交互及RESTful支持实现方法,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-06-06
  • 8张图带你全面了解Java kafka的核心机制

    8张图带你全面了解Java kafka的核心机制

    kafka是目前企业中很常用的消息队列产品,可以用于削峰、解耦、异步通信,本文就通过几张图带大家全面认识一下kafka,现在我们不妨带入kafka设计者的角度去思考该如何设计,它的架构是怎么样的、都有哪些组件组成、如何进行扩展等等,需要的朋友可以参考下
    2023-05-05
  • java邮件乱码的彻底解决方案

    java邮件乱码的彻底解决方案

    在本篇文章里小编给大家整理的是关于java邮件乱码的彻底解决方案,需要的朋友们可以学习下。
    2019-12-12
  • 如何把spring boot应用发布到Harbor

    如何把spring boot应用发布到Harbor

    这篇文章主要介绍了如何把spring boot应用发布到Harbor,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2019-11-11
  • Java中后台线程实例解析

    Java中后台线程实例解析

    这篇文章主要介绍了Java中后台线程实例解析,分享了相关代码示例,小编觉得还是挺不错的,具有一定借鉴价值,需要的朋友可以参考下
    2018-02-02
  • Java虚拟机工作原理

    Java虚拟机工作原理

    本文主要介绍了Java虚拟机的工作原理。具有很好的参考价值。下面跟着小编一起来看下吧
    2017-03-03

最新评论