真实的国产乱ⅩXXX66竹夫人,五月香六月婷婷激情综合,亚洲日本VA一区二区三区,亚洲精品一区二区三区麻豆

成都創(chuàng)新互聯(lián)網(wǎng)站制作重慶分公司

RabbitMQ的應用示例-創(chuàng)新互聯(lián)

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

創(chuàng)新互聯(lián)憑借在網(wǎng)站建設、網(wǎng)站推廣領域領先的技術能力和多年的行業(yè)經(jīng)驗,為客戶提供超值的營銷型網(wǎng)站建設服務,我們始終認為:好的營銷型網(wǎng)站就是好的業(yè)務員。我們已成功為企業(yè)單位、個人等客戶提供了成都網(wǎng)站制作、網(wǎng)站設計服務,以良好的商業(yè)信譽,完善的服務及深厚的技術力量處于同行領先地位。

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

問題:

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

解決方案:

引入rabbitMQ技術:

RabbitMQ的應用示例

說明:

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

RabbitMQ就是消息的中間件。

RabbitMQ介紹:

RabbitMQ的應用示例

RabbitMQ性能分析:

RabbitMQ的應用示例

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

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

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

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

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

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

1.配置JDK:

2.固定虛擬機IP地址:

RabbitMQ的應用示例

3.連接虛擬機:

編輯文件跳轉路徑:

Vim go

Cd /usr/local/src

2.安裝rabbitMQ:

1.新建文件rabbitmq

/usr/local/src/rabbitmq

2.將安裝文件導入

RabbitMQ的應用示例

3.安裝rabbitMQ

RabbitMQ的應用示例

4.開啟遠程用戶訪問:

將文件復制到指定目錄下:

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

修改新復制的文件64行

RabbitMQ的應用示例

1.將%%去掉

2.將,號去掉

修改為:

RabbitMQ的應用示例

5.開啟rabbitMQ:

執(zhí)行命令:

rabbitmq-plugins enable rabbitmq_management

RabbitMQ的應用示例

表示啟動成功

6.開放端口15672和5672

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

訪問rabbitMQ的控制臺

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

程序連接rabbitMQ的端口

或者關閉防火墻

7.啟動/停止服務

service rabbitmq-server start 啟動

service rabbitmq-server stop 停止

service rabbitmq-server restart 重啟

RabbitMQ的應用示例

8.遠程登錄:

訪問:

http://192.168.154.137:15672/

用戶名和密碼都是guest

RabbitMQ的應用示例

9.視圖解析:

RabbitMQ的應用示例

10.建立管理員:

RabbitMQ的應用示例

11.構建虛擬主機:

RabbitMQ的應用示例

RabbitMQ的應用示例

11.構建虛擬主機:

RabbitMQ的應用示例

RabbitMQ的應用示例

RabbitMQ的應用示例

6.rabbitMQ的工作模式:

1.簡單模式:

RabbitMQ的應用示例

p:proverder 生產(chǎn)者

c:consumer 消費者

紅色部分:隊列 先進先出

原理說明:

生產(chǎn)者負責向隊列中添加消息.消費者負責消費隊列中的消息.

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

2.測試代碼:

1.定義Connection

RabbitMQ的應用示例

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

RabbitMQ的應用示例

RabbitMQ的應用示例

3.定義消費者:

RabbitMQ的應用示例

2.工作模式:

RabbitMQ的應用示例

原理說明:

生產(chǎn)者為消息隊列中生產(chǎn)消息,多個消費者爭搶執(zhí)行權利,誰搶到誰執(zhí)行.

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

測試代碼:

RabbitMQ的應用示例

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

RabbitMQ的應用示例

x:exchange 交換機

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

C1-2:表示多個消費者

原理說明:

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

類似于 廣播

RabbitMQ的應用示例

定義消費者::

RabbitMQ的應用示例

4.路由模式:

RabbitMQ的應用示例

x:表示交換機 type=direct 表示路由

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

原理說明:

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

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

5.主題模式:

RabbitMQ的應用示例

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、 口山閏廷比二曰站叩四瞿二月當“習 classpath:rabbitmq.properties IUe> /value>" v:shapes="圖片_x0020_42">

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

1.引入配置文件

RabbitMQ的應用示例

2.定義發(fā)送端

RabbitMQ的應用示例

3.發(fā)送端代碼

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

RabbitMQ的應用示例

RabbitMQ的應用示例

4.定義接收端:

引入配置文件

RabbitMQ的應用示例

5.定義接收端:

RabbitMQ的應用示例

6.測試成功

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


標題名稱:RabbitMQ的應用示例-創(chuàng)新互聯(lián)
轉載注明:http://weahome.cn/article/googg.html

其他資訊

在線咨詢

微信咨詢

電話咨詢

028-86922220(工作日)

18980820575(7×24)

提交需求

返回頂部