這篇文章主要為大家展示了“RabbitMQ的應(yīng)用示例”,內(nèi)容簡而易懂,條理清晰,希望能夠幫助大家解決疑惑,下面讓小編帶領(lǐng)大家一起研究并學(xué)習(xí)一下“RabbitMQ的應(yīng)用示例”這篇文章吧。
創(chuàng)新互聯(lián)憑借在網(wǎng)站建設(shè)、網(wǎng)站推廣領(lǐng)域領(lǐng)先的技術(shù)能力和多年的行業(yè)經(jīng)驗,為客戶提供超值的營銷型網(wǎng)站建設(shè)服務(wù),我們始終認(rèn)為:好的營銷型網(wǎng)站就是好的業(yè)務(wù)員。我們已成功為企業(yè)單位、個人等客戶提供了成都網(wǎng)站制作、網(wǎng)站設(shè)計服務(wù),以良好的商業(yè)信譽(yù),完善的服務(wù)及深厚的技術(shù)力量處于同行領(lǐng)先地位。雖然后臺使用了讀寫分離技術(shù),能夠在一定程度上抗擊高并發(fā),但是如果并發(fā)量特別巨大時,主數(shù)據(jù)庫不能同時處理高并發(fā)的請求,這時數(shù)據(jù)庫容易宕機(jī)。
問題:
現(xiàn)在的問題是如何既能保證數(shù)據(jù)庫正常運(yùn)行,又能實現(xiàn)用戶數(shù)據(jù)的入庫操作?
解決方案:
引入rabbitMQ技術(shù):
說明:
當(dāng)數(shù)據(jù)庫的訪問壓力過載時,這時會將過載以后的數(shù)據(jù)先保存到rabbitMQ中。其中的數(shù)據(jù)結(jié)構(gòu)是隊列的形式,先進(jìn)先出。這時數(shù)據(jù)庫從隊列中取數(shù)據(jù)執(zhí)行。一直到隊列中的數(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)用廣泛,缺點容易丟失數(shù)據(jù).但是業(yè)務(wù)系統(tǒng)中使用率較少
5.KafkaMQ:大數(shù)據(jù)項目中使用,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)者
紅色部分:隊列 先進(jìn)先出
原理說明:
生產(chǎn)者負(fù)責(zé)向隊列中添加消息.消費(fèi)者負(fù)責(zé)消費(fèi)隊列中的消息.
消費(fèi)者通過監(jiān)聽器,實時監(jiān)控消息隊列.如果消息隊列中有消息則消費(fèi),如果沒有消息 則等待消息.
2.測試代碼:
1.定義Connection
1.1.定義生產(chǎn)者
3.定義消費(fèi)者:
2.工作模式:
原理說明:
生產(chǎn)者為消息隊列中生產(chǎn)消息,多個消費(fèi)者爭搶執(zhí)行權(quán)利,誰搶到誰執(zhí)行.
實用場景:秒殺業(yè)務(wù) 搶紅包等
測試代碼:
3.發(fā)布訂閱模式:
x:exchange 交換機(jī)
P:表示生產(chǎn)者
C1-2:表示多個消費(fèi)者
原理說明:
當(dāng)生產(chǎn)者生產(chǎn)消息后,先將消息發(fā)往交換機(jī).交換機(jī)再將消息發(fā)往訂閱了當(dāng)前消息的隊列,再次有各個隊列的消費(fèi)者執(zhí)行.
類似于 廣播
定義消費(fèi)者::
4.路由模式:
x:表示交換機(jī) type=direct 表示路由
路由模式中,需要定義路由key
原理說明:
1.當(dāng)生產(chǎn)者發(fā)布消息時,會定義指定的路由key 例如 key:error
2.這時交換機(jī)會根據(jù)路由key發(fā)往滿足條件的隊列中.如果隊列中沒有符合條件的路由key將不能執(zhí)行該消息.
5.主題模式:
Type:topic 表示主題模式
* (star) can substitute for exactly one word.
# (hash) can substitute for zero or more words.
有坑 效果一樣
7.訂單實現(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è)資訊頻道!
本文標(biāo)題:RabbitMQ的應(yīng)用示例-創(chuàng)新互聯(lián)
分享路徑:http://bm7419.com/article16/googg.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供網(wǎng)站策劃、網(wǎng)站設(shè)計、微信小程序、做網(wǎng)站、靜態(tài)網(wǎng)站、全網(wǎng)營銷推廣
聲明:本網(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)
猜你還喜歡下面的內(nèi)容