日韩性视频-久久久蜜桃-www中文字幕-在线中文字幕av-亚洲欧美一区二区三区四区-撸久久-香蕉视频一区-久久无码精品丰满人妻-国产高潮av-激情福利社-日韩av网址大全-国产精品久久999-日本五十路在线-性欧美在线-久久99精品波多结衣一区-男女午夜免费视频-黑人极品ⅴideos精品欧美棵-人人妻人人澡人人爽精品欧美一区-日韩一区在线看-欧美a级在线免费观看

歡迎訪問(wèn) 生活随笔!

生活随笔

當(dāng)前位置: 首頁(yè) > 编程资源 > 编程问答 >内容正文

编程问答

干货:RabbitMQ消息队列基本原理介绍

發(fā)布時(shí)間:2024/4/14 编程问答 43 豆豆
生活随笔 收集整理的這篇文章主要介紹了 干货:RabbitMQ消息队列基本原理介绍 小編覺(jué)得挺不錯(cuò)的,現(xiàn)在分享給大家,幫大家做個(gè)參考.

RabbitMQ 是高級(jí)消息隊(duì)列協(xié)議(AMQP)的開(kāi)源消息代理軟件。

RabbitMQ 服務(wù)器是用 Erlang 語(yǔ)言編寫的,消息系統(tǒng)允許軟件、應(yīng)用相互連接和擴(kuò)展。這些應(yīng)用可以相互鏈接起來(lái)組成一個(gè)更大的應(yīng)用,或者將用戶設(shè)備和數(shù)據(jù)進(jìn)行連接。消息系統(tǒng)通過(guò)將消息的發(fā)送和接收分離來(lái)實(shí)現(xiàn)應(yīng)用程序的異步和解耦。

或許你正在考慮進(jìn)行數(shù)據(jù)投遞,非阻塞操作或推送通知。或許你想要實(shí)現(xiàn)發(fā)布 / 訂閱,異步處理,或者工作隊(duì)列。所有這些都可以通過(guò)消息實(shí)現(xiàn)。RabbitMQ 是一個(gè)消息代理 - 一個(gè)消息系統(tǒng)的媒介。它可以為你的應(yīng)用提供一個(gè)通用的消息發(fā)送和接收平臺(tái),并且保證消息在傳輸過(guò)程中的安全。

功能亮點(diǎn):

可靠性:RabbitMQ 提供了各種功能,讓你權(quán)衡性能與可靠性,其中包括持久性,交付確認(rèn)和高可用性。

靈活的路由:消息在到達(dá)隊(duì)列之前,通過(guò)交換機(jī)的路由。RabbitMQ 為典型的路由邏輯提供了幾個(gè)內(nèi)置的交換機(jī)類型。對(duì)于更復(fù)雜的路由,則可以綁定幾種交換機(jī)一起使用甚至可以自己實(shí)現(xiàn)交換機(jī)類型,并且把它作為一個(gè)插件的來(lái)使用。

集群:在本地網(wǎng)絡(luò)上的幾個(gè) RabbitMQ 服務(wù)器可以聚集在一起,作為一個(gè)獨(dú)立的邏輯代理來(lái)使用。

聯(lián)合:對(duì)于服務(wù)器來(lái)說(shuō),它比集群需要更多的松散和非可靠鏈接。為此 RabbitMQ 提供了聯(lián)合模型。

高度可用隊(duì)列:在群集中,隊(duì)列可以被鏡像到幾個(gè)機(jī)器中,確保您的消息即使在出現(xiàn)硬件故障的安全。

多協(xié)議:RabbitMQ 支持上各種消息傳遞協(xié)議的消息傳送.

許多客戶端:有你能想到的幾乎任何語(yǔ)言 RabbitMQ 客戶端。

管理用戶界面:RabbitMQ 附帶一個(gè)簡(jiǎn)單使用管理用戶界面,允許您監(jiān)視和控制您的消息代理的各個(gè)方面。

追蹤:如果您的消息系統(tǒng)行為異常,RabbitMQ 提供跟蹤支持,讓你找出問(wèn)題是什么。

插件系統(tǒng):RabbitMQ 附帶各種插件擴(kuò)展,并且你也可以寫你自己插件.

商業(yè)支持:提供商業(yè)支持、 培訓(xùn)和咨詢。

大型社區(qū):有一個(gè)龐大的社區(qū) RabbitMQ,有各種各樣的客戶端、 插件、 指南等。

原理介紹

RabbitMQ 是一個(gè)消息代理。它的核心原理非常簡(jiǎn)單:接收和發(fā)送消息。你可以把它想像成一個(gè)郵局:你把信件放入郵箱,郵遞員就會(huì)把信件投遞到你的收件人處。在這個(gè)比喻中,RabbitMQ 就扮演著郵箱、郵局以及郵遞員的角色。

RabbitMQ 和郵局的主要區(qū)別是,它不是用來(lái)處理紙張的,它是用來(lái)接收、存儲(chǔ)和發(fā)送消息(message)這種二進(jìn)制數(shù)據(jù)的。

在這里我們使用生產(chǎn)者、消費(fèi)者模型來(lái)進(jìn)行此次的模擬。

生產(chǎn)者消費(fèi)者問(wèn)題(Producer-consumer problem),也稱有限緩沖問(wèn)題(Bounded-buffer problem),是一個(gè)多線程同步問(wèn)題的經(jīng)典案例。該問(wèn)題描述了兩個(gè)共享固定大小緩沖區(qū)的線程——即所謂的“生產(chǎn)者”和“消費(fèi)者”——在實(shí)際運(yùn)行時(shí)會(huì)發(fā)生的問(wèn)題。生產(chǎn)者的主要作用是生成一定量的數(shù)據(jù)放到緩沖區(qū)中,然后重復(fù)此過(guò)程。與此同時(shí),消費(fèi)者也在緩沖區(qū)消耗這些數(shù)據(jù)。該問(wèn)題的關(guān)鍵就是要保證生產(chǎn)者不會(huì)在緩沖區(qū)滿時(shí)加入數(shù)據(jù),消費(fèi)者也不會(huì)在緩沖區(qū)中空時(shí)消耗數(shù)據(jù)。

生產(chǎn)者(Producer)
生產(chǎn)者生成一定量的數(shù)據(jù)放到緩沖區(qū)中的程序統(tǒng)稱,在本實(shí)驗(yàn)環(huán)境中,產(chǎn)生消息并發(fā)送到消息隊(duì)列中的程序就是一個(gè) 生產(chǎn)者(producer)。也是我們上文比喻中寫信,投信的人。

我們一般用 “P” 來(lái)表示:

隊(duì)列(Queue)
它是一種特殊的線性表,在本實(shí)驗(yàn)環(huán)境中用于存放消息,也就是上文比喻中的郵箱。

消息通過(guò)你的應(yīng)用程序和 RabbitMQ 進(jìn)行傳輸,它們能夠只存儲(chǔ)在一個(gè)隊(duì)列(queue)中。 隊(duì)列(queue)沒(méi)有任何限制,你要存儲(chǔ)多少消息都可以——基本上是一個(gè)無(wú)限的緩沖。多個(gè)生產(chǎn)者(producers)能夠把消息發(fā)送給同一個(gè)隊(duì)列,同樣,多個(gè)消費(fèi)者(consumers)也能夠從同一個(gè)隊(duì)列(queue)中獲取數(shù)據(jù)。

隊(duì)列可以繪制成這樣(圖上是隊(duì)列的名稱):

消費(fèi)者(Consumer)
消費(fèi)者便是從消息隊(duì)列中取出數(shù)據(jù)的程序統(tǒng)稱。也就是上文比喻中的收件人,在本實(shí)驗(yàn)中一個(gè)消費(fèi)者(consumer)就是一個(gè)等待獲取消息的程序。

我們把它繪制為 “C”:

需要指出的是生產(chǎn)者、消費(fèi)者、代理一般不會(huì)放置在在同一個(gè)設(shè)備上;事實(shí)上大多數(shù)應(yīng)用也確實(shí)不在會(huì)將他們放在一臺(tái)機(jī)器上。
基礎(chǔ)知識(shí)大概就是這些,對(duì)RabbitMQ感興趣的同學(xué)可以自行搜索學(xué)習(xí)。
在此給大家一些參考資料:
RabbitMQ官網(wǎng)
理論教程
實(shí)戰(zhàn)教程

總結(jié)

以上是生活随笔為你收集整理的干货:RabbitMQ消息队列基本原理介绍的全部?jī)?nèi)容,希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò),歡迎將生活随笔推薦給好友。