SpringBoot管理RabbitMQ中的Channel詳解
Channel是什么
RabbitMQ是AMQP0-9-1協(xié)議的實現(xiàn)，先來看看AMQP0-9-1協(xié)議中對通道Channel的闡述。
有些應(yīng)用程序需要與broker建立多個連接。但是，保持多個TCP連接同時打開是不可取的，因為這樣做會消耗系統(tǒng)資源，使配置防火墻更加困難。AMQP0-9-1的Connection可以多路復(fù)用，Channel可以被認為是“共享一個TCP連接的輕量級連接”。
客戶端執(zhí)行的每個協(xié)議操作都發(fā)生在一個channel上。在特定channel上的通信與在另一個channel上的通信完全獨立，因此每個協(xié)議方法也都帶有信道ID(a.k.a)。一個整數(shù)，代理和客戶端都使用它來確定該方法用于哪個通道。
channel僅存在于connection的上下文中，而不會單獨存在。當channel關(guān)閉時，其上的所有channel也會關(guān)閉。
對于使用多個線程/進程進行處理的應(yīng)用程序，為每個線程/進程打開一個新channel而不在它們之間共享channel是很常見的。
在普通的JAVAEE項目中，經(jīng)常采用1個進程-1個connection-1個channel。
但是這在JAVAWEB場景中實不可取的。
一個web項目僅有1個進程，會有非常多的線程，每個線程都創(chuàng)建一個connection是不可取的。
在AMQP-0-9-1協(xié)議中推薦了使用每個線程使用一個獨立的channel，這樣不同線程之間的channel相互獨立，并且公用同一個connection。
但是問題又來了，在并發(fā)情況下，web場景下，用戶的每一次http請求都是一個線程，難道這樣的每一個http請求都要對應(yīng)創(chuàng)建一個channel嗎？
Spring在集成RabbitMQ時對這個問題有了非常好的解決。
Spring如何管理Channel？
springboot使用了RabbitMQ中的IO多路復(fù)用的理念，并對這種方案在web場景下進行了優(yōu)化，盡可能的復(fù)用空閑中的channel。
boot默認使用 CachingConnectionFactory 對 Connection 和空閑 Channel 進行緩存。
看看Spring中的RabbitMQ是如何工作的：
Spring中對RabbitMQ的消息操作都是通過一個Template模板對象 RabbitTemplate ，該對象中封裝了對消息的接受和發(fā)送的各種重載方法。
消息的send都需要調(diào)用一個核心私有方法 doExcute() 。
管理RabbitMQ中的事務(wù)Channel
Spring也是通過 TransactionSupport 進行管理RabbitMQ中的事務(wù)Channel。
這一點和MyBatis的 SqlSessionTemplate 管理開啟事務(wù)的 SqlSession 的步驟相同。
這里不多贅述如果管理事務(wù)的channel
1.當?shù)谝淮斡姓埱筮B接rabbitmq時，spring創(chuàng)建一個AMQP的connection，并使用CachingConnectionFactory將其封裝并緩存起來。
2.然后使用這個connection，創(chuàng)建channel，當channel的任務(wù)執(zhí)行完成后（也就是邏輯close時，并非真正的關(guān)閉了channel，而是在內(nèi)存中給channel創(chuàng)建了一個標記。）
則使用 CachingConnectionFactory 的靜態(tài)子類 ChannelConnectionFactoryProxy 把這個channel緩存到一個空閑列表中。開啟了事務(wù)的channel存放在不同的列表中。
3.其他線程執(zhí)行任務(wù)時，CachingConnectionFactory中獲取connection，然后創(chuàng)建channel時，會去ChannelConnectionFactoryProxy的空閑列表中尋找哪些channel是open狀態(tài)。
然后將尋找到的一個channel移出列表，并使用這個channel執(zhí)行任務(wù)。（取出緩存中的channel這一過程是同步代碼塊, 開啟了事務(wù)的channel存放在不同的列表中。）
4.任務(wù)執(zhí)行完畢，將channel在緩存入空閑列表中。默認最多緩存25個channel
到此這篇關(guān)于SpringBoot管理RabbitMQ中的Channel詳解的文章就介紹到這了,更多相關(guān)SpringBoot管理Channel內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
下面小編就為大家?guī)硪黄猨ava隨機數(shù)生產(chǎn)算法實例。小編覺得挺不錯的，現(xiàn)在就分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2017-10-10
SpringBoot整合SQLite數(shù)據(jù)庫全過程
sqlite是一個很輕量級的數(shù)據(jù)庫,可以滿足日常sql的需求,下面這篇文章主要給大家介紹了關(guān)于SpringBoot整合SQLite數(shù)據(jù)庫的相關(guān)資料,文中通過實例代碼介紹的非常詳細,需要的朋友可以參考下2023-03-03
IDEA創(chuàng)建Servlet程序的兩種實現(xiàn)方法
Servlet是JavaWeb應(yīng)用程序中不可或缺的組件之一,本文主要介紹了IDEA創(chuàng)建Servlet程序的兩種實現(xiàn)方法,具有一定的參考價值,感興趣的可以了解一下2023-10-10
Spring Boot實現(xiàn)分片上傳、斷點續(xù)傳與進度條功能
本文介紹了如何使用SpringBoot實現(xiàn)分片上傳、斷點續(xù)傳和進度條等功能,本文通過實例代碼給大家介紹的非常詳細,對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值,需要的朋友參考下吧2026-02-02
這篇文章主要介紹了log4j2使用filter過濾日志方式，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-12-12
Springboot設(shè)置windows和Linux臨時上傳路徑方式
文章介紹了在Windows和Linux系統(tǒng)中設(shè)置臨時上傳路徑的方法,對于Windows系統(tǒng),可以通過修改注冊表或者環(huán)境變量來實現(xiàn),而對于Windows和Linux,可以在應(yīng)用程序中注入Bean來設(shè)置臨時上傳路徑2026-03-03
Java數(shù)據(jù)結(jié)構(gòu)之二叉查找樹的實現(xiàn)
二叉查找樹（亦稱二叉搜索樹、二叉排序樹）是一棵二叉樹，且各結(jié)點關(guān)鍵詞互異，其中根序列按其關(guān)鍵詞遞增排列。本文將通過示例詳細講解二叉查找樹，感興趣的可以了解一下2022-03-03
CORS(Cross-Origin?Resource?Sharing,跨域資源共享)是一種機制,允許在瀏覽器中向不同源(域名、協(xié)議或端口不同)的服務(wù)器發(fā)起請求,下面我們就來看看如何在Spring框架配置跨域CORS吧2025-10-10
JSR107是Java規(guī)范請求,定義了緩存接口,如CachingProvider、CacheManager、Cache等,SpringCache是Spring對緩存的抽象,通過@EnableCaching開啟緩存注解,使用@Cacheable、@CachePut、@CacheEvict等注解進行緩存操作,本文介紹SpringBoot 緩存的相關(guān)知識,感興趣的朋友一起看看2025-12-12
這篇文章主要介紹了淺談Java字符串比較的三種方法,字符串比較是常見的操作，包括比較相等、比較大小、比較前綴和后綴串等,需要的朋友可以參考下2023-04-04