小編給大家分享一下關(guān)于RabbitMQ應用場景與實例的詳解，相信大部分人都還不怎么了解，因此分享這篇文章給大家參考一下，希望大家閱讀完這篇文章后大有收獲，下面讓我們一起去了解一下吧！

創(chuàng)新互聯(lián)是專業(yè)的泊頭網(wǎng)站建設公司，泊頭接單;提供做網(wǎng)站、網(wǎng)站制作,網(wǎng)頁設計,網(wǎng)站設計,建網(wǎng)站,PHP網(wǎng)站建設等專業(yè)做網(wǎng)站服務;采用PHP框架,可快速的進行泊頭網(wǎng)站開發(fā)網(wǎng)頁制作和功能擴展;專業(yè)做搜索引擎喜愛的網(wǎng)站,專業(yè)的做網(wǎng)站團隊,希望更多企業(yè)前來合作!

解決分布式事務的一致性，消息隊列、消息中間件，消息中間件也可以稱消息隊列，是指用高效可靠的消息傳遞機制進行與平臺無關(guān)的數(shù)據(jù)交流，并基于數(shù)據(jù)通信來進行分布式系統(tǒng)的集成。通過提供消息傳遞和消息隊列模型，可以在分布式環(huán)境下擴展進程的通信。

當下主流的消息中間件有RabbitMQ、Kafka、ActiveMQ、RocketMQ等。其能在不同平臺之間進行通信，常用來屏蔽各種平臺協(xié)議之間的特性，實現(xiàn)應用程序之間的協(xié)同。優(yōu)點在于能夠在客戶端和服務器之間進行同步和異步的連接，并且在任何時刻都可以將消息進行傳送和轉(zhuǎn)發(fā)，是分布式系統(tǒng)中非常重要的組件，主要用來解決應用耦合、異步通信、流量削峰等問題。

RabbitMQ是使用Erlang編寫的一個開源的消息隊列，本身支持很多的協(xié)議：AMQP，XMPP, SMTP, STOMP，也正是如此，使的它變的非常重量級，更適合于企業(yè)級的開發(fā)。它同時實現(xiàn)了一個Broker構(gòu)架，這意味著消息在發(fā)送給客戶端時先在中心隊列排隊，對路由(Routing)、負載均衡(Load balance)或者數(shù)據(jù)持久化都有很好的支持。

RabbitMQ從整體上來看是一個典型的生產(chǎn)者消費者模型，主要負責接收、存儲和轉(zhuǎn)發(fā)消息。

生產(chǎn)者：

生產(chǎn)者連接到RabbitMQ Broker，建立一個連接(Connection)開啟一個信道(Channel)
生產(chǎn)者聲明一個交換器，并設置相關(guān)屬性，比如交換機類型、是否持久化等
生產(chǎn)者聲明一個隊列井設置相關(guān)屬性，比如是否排他、是否持久化、是否自動刪除等
生產(chǎn)者通過路由鍵將交換器和隊列綁定起來
生產(chǎn)者發(fā)送消息至RabbitMQ Broker，其中包含路由鍵、交換器等信息
相應的交換器根據(jù)接收到的路由鍵查找相匹配的隊列
如果找到，則將從生產(chǎn)者發(fā)送過來的消息存入相應的隊列中
如果沒有找到，則根據(jù)生產(chǎn)者配置的屬性選擇丟棄還是回退給生產(chǎn)者
關(guān)閉信道
關(guān)閉連接
消費者：

消費者連接到RabbitMQ Broker ，建立一個連接(Connection)，開啟一個信道(Channel)
消費者向RabbitMQ Broker請求消費相應隊列中的消息，可能會設置相應的回調(diào)函數(shù)
等待RabbitMQ Broker回應并投遞相應隊列中的消息，消費者接收消息
消費者確認(ack) 接收到的消息
RabbitMQ從隊列中刪除相應己經(jīng)被確認的消息
關(guān)閉信道
關(guān)閉連接
http://www.sohu.com/a/280203461_411876
為什么要有信道：生產(chǎn)者和消費者都要和RabbitMQ Broker 建立連接，這是一條tcp連接，而操作系統(tǒng)對于TCP連接的創(chuàng)建與銷毀是非常昂貴的開銷。

而高并發(fā)的時候，可能每秒有上萬條tcp連接，資源浪費的同時也會超過操作系統(tǒng)每秒所能連接的數(shù)量，要在一條tcp連接上操作，又能保證各個線程之間的私密性，所以出現(xiàn)信道channel。

信道是虛擬連接，在connection基礎上的虛擬連接，在應用程序和Rabbit Broker建立tcp連接時，客戶端緊接著建立一個AMQP信道(channel)，每個channel有的ID，處理每條AMQP指令都是通過信道完成的。信道就像電纜里的光纖束，一條電纜內(nèi)含有許多光纖束，允許所有的連接通過多條光線束進行傳輸和接收。

AMQP，高級消息隊列協(xié)議，AMQP協(xié)議這種降低耦合的機制是基于與上層產(chǎn)品，語言無關(guān)的協(xié)議。是一種二進制協(xié)議，提供客戶端應用與消息中間件之間多通道、協(xié)商、異步、安全、中立和高效地交互。從整體來看，AMQP協(xié)議可劃分為兩層：
功能層(定義命令，用于實現(xiàn)業(yè)務邏輯)，傳輸層(基于二進制數(shù)據(jù)流傳輸，將應用程序調(diào)用的指令傳回服務器，并返回結(jié)果)。

以上是關(guān)于RabbitMQ應用場景與實例的詳解的所有內(nèi)容，感謝各位的閱讀！相信大家都有了一定的了解，希望分享的內(nèi)容對大家有所幫助，如果還想學習更多知識，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道！

當前名稱：關(guān)于RabbitMQ應用場景與實例的詳解-創(chuàng)新互聯(lián)
地址分享：http://aaarwkj.com/article30/ccoepo.html

成都網(wǎng)站建設公司_創(chuàng)新互聯(lián)，為您提供小程序開發(fā)、App開發(fā)、營銷型網(wǎng)站建設、微信小程序、網(wǎng)站改版、關(guān)鍵詞優(yōu)化

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)