RabbitMQ的應(yīng)用示例

這篇文章主要為大家展示了“RabbitMQ的應(yīng)用示例”，內(nèi)容簡而易懂，條理清晰，希望能夠幫助大家解決疑惑，下面讓小編帶領(lǐng)大家一起研究并學(xué)習(xí)一下“RabbitMQ的應(yīng)用示例”這篇文章吧。

網(wǎng)站建設(shè)哪家好，找創(chuàng)新互聯(lián)公司！專注于網(wǎng)頁設(shè)計(jì)、網(wǎng)站建設(shè)、微信開發(fā)、微信平臺小程序開發(fā)、集團(tuán)企業(yè)網(wǎng)站建設(shè)等服務(wù)項(xiàng)目。為回饋新老客戶創(chuàng)新互聯(lián)還提供了安鄉(xiāng)免費(fèi)建站歡迎大家使用！

雖然后臺使用了讀寫分離技術(shù)，能夠在一定程度上抗擊高并發(fā)，但是如果并發(fā)量特別巨大時(shí)，主數(shù)據(jù)庫不能同時(shí)處理高并發(fā)的請求，這時(shí)數(shù)據(jù)庫容易宕機(jī)。

問題：

現(xiàn)在的問題是如何既能保證數(shù)據(jù)庫正常運(yùn)行，又能實(shí)現(xiàn)用戶數(shù)據(jù)的入庫操作?

解決方案：

引入rabbitMQ技術(shù):

說明:

當(dāng)數(shù)據(jù)庫的訪問壓力過載時(shí)，這時(shí)會將過載以后的數(shù)據(jù)先保存到rabbitMQ中。其中的數(shù)據(jù)結(jié)構(gòu)是隊(duì)列的形式，先進(jìn)先出。這時(shí)數(shù)據(jù)庫從隊(duì)列中取數(shù)據(jù)執(zhí)行。一直到隊(duì)列中的數(shù)據(jù)全部操作完成為止。

RabbitMQ就是消息的中間件。

RabbitMQ介紹：

RabbitMQ性能分析：

1.MSMQ:是微軟的產(chǎn)品 應(yīng)用于.net框架

2.ActiveMQ:是apache的產(chǎn)品 做業(yè)務(wù)用圖廣泛

3.RabbitQM:是愛立信的產(chǎn)品(早期手機(jī)生產(chǎn)廠商)基于erlang語言(函數(shù)式編程大數(shù)據(jù) scala語言)

4.ZeroMQ:大數(shù)據(jù)中應(yīng)用廣泛,缺點(diǎn)容易丟失數(shù)據(jù).但是業(yè)務(wù)系統(tǒng)中使用率較少

5.KafkaMQ:大數(shù)據(jù)項(xiàng)目中使用,50萬/秒 現(xiàn)在主流

5.RabbitMQ環(huán)境搭建:

1.配置JDK:

2.固定虛擬機(jī)IP地址:

3.連接虛擬機(jī):

編輯文件跳轉(zhuǎn)路徑:

Vim go

Cd /usr/local/src

2.安裝rabbitMQ:

1.新建文件rabbitmq

/usr/local/src/rabbitmq

2.將安裝文件導(dǎo)入

3.安裝rabbitMQ

4.開啟遠(yuǎn)程用戶訪問:

將文件復(fù)制到指定目錄下:

cp /usr/share/doc/rabbitmq-server-3.6.1/rabbitmq.config.example /etc/rabbitmq/rabbitmq.config

修改新復(fù)制的文件64行

1.將%%去掉

2.將,號去掉

修改為:

5.開啟rabbitMQ:

執(zhí)行命令:

rabbitmq-plugins enable rabbitmq_management

表示啟動成功

6.開放端口15672和5672

iptables -I INPUT -p tcp --dport 15672 -j ACCEPT

訪問rabbitMQ的控制臺

iptables -I INPUT -p tcp --dport 5672 -j ACCEPT

程序連接rabbitMQ的端口

或者關(guān)閉防火墻

7.啟動/停止服務(wù)

service rabbitmq-server start 啟動

service rabbitmq-server stop 停止

service rabbitmq-server restart 重啟

8.遠(yuǎn)程登錄:

訪問:

http://192.168.154.137:15672/

用戶名和密碼都是guest

9.視圖解析:

10.建立管理員:

11.構(gòu)建虛擬主機(jī):

11.構(gòu)建虛擬主機(jī):

6.rabbitMQ的工作模式:

1.簡單模式:

p:proverder 生產(chǎn)者

c:consumer 消費(fèi)者

紅色部分:隊(duì)列 先進(jìn)先出

原理說明:

生產(chǎn)者負(fù)責(zé)向隊(duì)列中添加消息.消費(fèi)者負(fù)責(zé)消費(fèi)隊(duì)列中的消息.

消費(fèi)者通過監(jiān)聽器,實(shí)時(shí)監(jiān)控消息隊(duì)列.如果消息隊(duì)列中有消息則消費(fèi),如果沒有消息 則等待消息.

2.測試代碼:

1.定義Connection

1.1.定義生產(chǎn)者

3.定義消費(fèi)者:

2.工作模式:

原理說明:

生產(chǎn)者為消息隊(duì)列中生產(chǎn)消息,多個(gè)消費(fèi)者爭搶執(zhí)行權(quán)利,誰搶到誰執(zhí)行.

實(shí)用場景:秒殺業(yè)務(wù) 搶紅包等

測試代碼:

3.發(fā)布訂閱模式:

x:exchange 交換機(jī)

P:表示生產(chǎn)者

C1-2:表示多個(gè)消費(fèi)者

原理說明:

當(dāng)生產(chǎn)者生產(chǎn)消息后,先將消息發(fā)往交換機(jī).交換機(jī)再將消息發(fā)往訂閱了當(dāng)前消息的隊(duì)列,再次有各個(gè)隊(duì)列的消費(fèi)者執(zhí)行.

類似于 廣播

定義消費(fèi)者:：

4.路由模式:

x:表示交換機(jī) type=direct 表示路由

路由模式中,需要定義路由key

原理說明:

1.當(dāng)生產(chǎn)者發(fā)布消息時(shí),會定義指定的路由key 例如 key:error

2.這時(shí)交換機(jī)會根據(jù)路由key發(fā)往滿足條件的隊(duì)列中.如果隊(duì)列中沒有符合條件的路由key將不能執(zhí)行該消息.

5.主題模式:

Type:topic 表示主題模式

• * (star) can substitute for exactly one word.

• # (hash) can substitute for zero or more words.

• 有坑 效果一樣

7.訂單實(shí)現(xiàn)RabbitMQ

1.引入配置文件:

classpath:jdbc.propertiesclasspath:env.properties /hp月n、 口山閏廷比二曰站叩四瞿二月當(dāng)“習(xí) classpath:rabbitmq.properties IUe> /value>" v:shapes="圖片_x0020_42">

2.引入生產(chǎn)者

1.引入配置文件

2.定義發(fā)送端

3.發(fā)送端代碼

通過代碼相rabbitmq中發(fā)送數(shù)據(jù)

4.定義接收端:

引入配置文件

5.定義接收端:

6.測試成功

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

本文題目：RabbitMQ的應(yīng)用示例
文章路徑：http://muchs.cn/article34/ihcspe.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供品牌網(wǎng)站設(shè)計(jì)、網(wǎng)站策劃、企業(yè)建站、搜索引擎優(yōu)化、云服務(wù)器、商城網(wǎng)站

廣告

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