柚子快報(bào)邀請(qǐng)碼778899分享：分布式 初識(shí)RabbitMq

http://yzkb.51969.com/

目錄

?編輯

1.MQ

1.1MQ？

1.2 mq的作用

2.常見的幾種MQ實(shí)現(xiàn)

3.參考

1.MQ

RabbitMq可以分為兩部分 rabbti 和 mq，rabbit指的是公司名、mq指的是消息隊(duì)列（message queue）

1.1什么是MQ

消息隊(duì)列（mq）是一種在應(yīng)用程序之間傳遞消息的通信模式。它通常由生產(chǎn)者發(fā)送消息到隊(duì)列（先進(jìn)先出），然后再由消費(fèi)者進(jìn)行消費(fèi)。

1.2 mq的作用

1. 應(yīng)用解耦?

現(xiàn)在有一個(gè)分布式的商城項(xiàng)目：它的支付服務(wù)的業(yè)務(wù)流程是 調(diào)用用戶服務(wù)完成余額扣減，調(diào)用訂單服務(wù)完成訂單信息更新。

現(xiàn)在如果業(yè)務(wù)經(jīng)理要求在支付成功后給用戶發(fā)短信提示，那么就在支付服務(wù)中在添加調(diào)用信息服務(wù)就行了。

當(dāng)是如果業(yè)務(wù)經(jīng)理第二天要求，支付成功后添加積分服務(wù)，第三天要求不發(fā)短信了要發(fā)郵箱。此時(shí)整個(gè)代碼就變得很臃腫。而且短信服務(wù)發(fā)生故障，可能導(dǎo)致整個(gè)支付服務(wù)的回滾，這顯然是不好的。

那么此時(shí)我們可以在調(diào)用完用戶服務(wù)后，使用消息隊(duì)列發(fā)布一條消息：調(diào)用用戶服務(wù)扣減余額完成了！。短信服務(wù)，訂單服務(wù)進(jìn)行訂閱，訂閱到這條信息后 短信服務(wù)，訂單服務(wù)就開始執(zhí)行。這樣如果后面再添加服務(wù)，只要通過訂閱信息的方式來(lái)執(zhí)行不就可以解決支付服務(wù)臃腫的問題了。

2.異步提速

通過上面的應(yīng)用解耦其實(shí)就完成了異步提速了，因?yàn)橹Ц斗?wù)中的相關(guān)服務(wù)已經(jīng)是一種并行執(zhí)行的狀態(tài)了。

總時(shí)間：20ms+20ms+20ms+20ms = 80ms

使用mq：

總時(shí)間：20ms + 20ms = 40ms

3. 削峰填谷

當(dāng)某一時(shí)間段，比如雙十一等節(jié)日請(qǐng)求突然暴增，這時(shí)如果使用了mq，那么消息隊(duì)列機(jī)會(huì)把這些請(qǐng)求緩存下來(lái)，然后再根據(jù)它的自身拉取能力進(jìn)行消費(fèi)。

2.常見的幾種MQ實(shí)現(xiàn)

RabbitMqActiveMqRocketMqKafka公司/社區(qū)Rabbit?Apache阿里Apache開發(fā)語(yǔ)言ErlangJavaJavaScala&Java協(xié)議支持AMQP，XMPP，SMTP，STOMPOpenWire，STOPMP，XMPP，AMQP自定義協(xié)議自定義協(xié)議可用性高一般高高單機(jī)吞吐量一般差高非常高消息延遲微妙級(jí)毫秒級(jí)毫秒級(jí)毫秒以內(nèi)消息可靠性高一般高一般

追求可用性：Kafka、 RocketMQ 、RabbitMQ

追求可靠性：RabbitMQ、RocketMQ

追求吞吐能力：RocketMQ、Kafka

追求消息低延遲：RabbitMQ、Kafka

3.參考

01-初探MQ-MQ的三大使用場(chǎng)景：應(yīng)用解耦、異步提速、削峰填谷_mq削峰填谷-CSDN博客

MQ基礎(chǔ)-03.初識(shí)MQ-異步調(diào)用_嗶哩嗶哩_bilibili

柚子快報(bào)邀請(qǐng)碼778899分享：分布式 初識(shí)RabbitMq

http://yzkb.51969.com/

好文推薦