MQ的使用場(chǎng)景

常用的消息隊(duì)列有rabbitmq、activemq、kafka、RocketMQ

異步處理:例如完成某種業(yè)務(wù)之后需要發(fā)短信發(fā)郵件通知時(shí),就可以采用一步的方式完成短信或郵件的通知。

流量削峰:常見的秒殺場(chǎng)景
(秒殺活動(dòng)流量過大,導(dǎo)致流量暴增,最終可能導(dǎo)致應(yīng)用掛掉。一般會(huì)在應(yīng)用前端加入消息隊(duì)列來控制活動(dòng)人數(shù),假如消息隊(duì)列超過最大數(shù)量,應(yīng)該直接拋棄用戶請(qǐng)求或者跳轉(zhuǎn)到錯(cuò)誤頁面。秒殺業(yè)務(wù)根據(jù)消息隊(duì)列中的請(qǐng)求信息在做后續(xù)的業(yè)務(wù)處理)

日志處理:最典型的就是kafka。因?yàn)閗afka最初的設(shè)計(jì)就是用于日志處理,大數(shù)據(jù)里面用的特別多,通過日志采集,定時(shí)寫到kafka隊(duì)列,然后kafka隊(duì)列對(duì)日志數(shù)據(jù)進(jìn)行接收、儲(chǔ)存和轉(zhuǎn)發(fā)

應(yīng)用解耦
例如:商品服務(wù)和訂單服務(wù)之間。用戶下單后,訂單服務(wù)會(huì)通知商品服務(wù)。不使用MQ的情況是訂單服務(wù)調(diào)用商品服務(wù)的接口,這樣訂單服務(wù)和商品服務(wù)之間是耦合的;使用MQ,訂單服務(wù)完成持久化處理,將消息寫入MQ消息隊(duì)列中,返回用戶訂單下單成功,商品服務(wù)來訂閱這個(gè)下單的消息,采用拉或推的方式獲得下單信息,商品服務(wù)根據(jù)商品下單信息進(jìn)行商品庫存信息修改,這樣當(dāng)下單時(shí)商品服務(wù)不可用時(shí),也不影響正常下單,這就完成了訂單服務(wù)和商品服務(wù)之間的解耦。

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時(shí)請(qǐng)結(jié)合常識(shí)與多方信息審慎甄別。
平臺(tái)聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點(diǎn),簡(jiǎn)書系信息發(fā)布平臺(tái),僅提供信息存儲(chǔ)服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容