RabbitMQ的Connection和Channel

我們知道無論是生產(chǎn)者還是消費(fèi)者，都需要和 RabbitMQ Broker 建立連接，這個(gè)連接就是一條 TCP 連接，也就是 Connection。

一旦 TCP 連接建立起來，客戶端緊接著可以創(chuàng)建一個(gè) AMQP 信道（Channel），每個(gè)信道都會(huì)被指派一個(gè)唯一的 ID。

信道是建立在 Connection 之上的虛擬連接，RabbitMQ 處理的每條 AMQP 指令都是通過信道完成的。

我們完全可以使用 Connection 就能完成信道的工作，為什么還要引入信道呢？

試想這樣一個(gè)場(chǎng)景，一個(gè)應(yīng)用程序中有很多個(gè)線程需要從 RabbitMQ 中消費(fèi)消息，或者生產(chǎn)消息，那么必然需要建立很多個(gè) Connection，也就是多個(gè) TCP 連接。

然而對(duì)于操作系統(tǒng)而言，建立和銷毀 TCP 連接是非常昂貴的開銷，如果遇到使用高峰，性能瓶頸也隨之顯現(xiàn)。

RabbitMQ 采用類似 NIO（Non-blocking I/O）的做法，選擇 TCP 連接復(fù)用，不僅可以減少性能開銷，同時(shí)也便于管理。

每個(gè)線程把持一個(gè)信道，所以信道復(fù)用了 Connection 的 TCP 連接。

同時(shí) RabbitMQ 可以確保每個(gè)線程的私密性，就像擁有獨(dú)立的連接一樣。當(dāng)每個(gè)信道的流量不是很大時(shí)，復(fù)用單一的 Connection 可以在產(chǎn)生性能瓶頸的情況下有效地節(jié)省 TCP 連接資源。

但是信道本身的流量很大時(shí)，這時(shí)候多個(gè)信道復(fù)用一個(gè) Connection 就會(huì)產(chǎn)生性能瓶頸，進(jìn)而使整體的流量被限制了。

此時(shí)就需要開辟多個(gè) Connection，將這些信道均攤到這些 Connection 中，至于這些相關(guān)的調(diào)優(yōu)策略需要根據(jù)業(yè)務(wù)自身的實(shí)際情況進(jìn)行調(diào)節(jié)。

信道在 AMQP 中是一個(gè)很重要的概念，大多數(shù)操作都是在信道這個(gè)層面展開的。

比如 channel.exchangeDeclare、channel.queueDeclare、channel.basicPublish、channel.basicConsume 等方法。

RabbitMQ 相關(guān)的 API 與 AMQP 緊密相連，比如 channel.basicPublish 對(duì)應(yīng) AMQP 的 Basic.Publish 命令。

名詞解釋：

NIO，也稱非阻塞 I/O，包含三大核心部分：Channel（信道）、Buffer（緩沖區(qū)）和 Selector（選擇器）。

NIO 基于 Channel 和 Buffer 進(jìn)行操作，數(shù)據(jù)總是從信道讀取數(shù)據(jù)到緩沖區(qū)中，或者從緩沖區(qū)寫入到信道中。

Selector 用于監(jiān)聽多個(gè)信道的時(shí)間（比如連接打開，數(shù)據(jù)到達(dá)等）。因此，單線程可以監(jiān)聽多個(gè)數(shù)據(jù)的信道。

到此這篇關(guān)于RabbitMQ中的Connection和Channel信道詳解的文章就介紹到這了,更多相關(guān)RabbitMQ的Connection和Channel內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評(píng)論