MQ - 消息中間件

image.png
MQ的高可用
MQ的集群和容錯(cuò)
MQ的持久性
延時(shí)發(fā)送/定時(shí)投遞
簽收機(jī)制
Spring整合
MQ之前:系統(tǒng)之間互相調(diào)用。
容易存在的問(wèn)題:
1.系統(tǒng)之間接口耦合比較嚴(yán)重。
每增加一個(gè)下游系統(tǒng),都要對(duì)上游系統(tǒng)接口進(jìn)行改造。
2.無(wú)法面對(duì)大流量并發(fā)。
上游下單較快,下游處理較慢。
(讀取訂單,庫(kù)存檢查,庫(kù)存凍結(jié),余額檢查,余額凍結(jié),訂單生成,余額扣減,庫(kù)存扣減,生成流水,余額解凍,庫(kù)存解凍)
3.等待同步時(shí)性能低下。
同步調(diào)用,等待返回。
引入MQ后:
面向消息的中間件是指利用高效可靠的消息傳遞進(jìn)行與平臺(tái)無(wú)關(guān)的數(shù)據(jù)交流,并基于數(shù)據(jù)通信來(lái)進(jìn)行分布式系統(tǒng)的集成。通過(guò)提供消息傳遞和消息排隊(duì)模型在分布式環(huán)境下提供應(yīng)用解耦,彈性伸縮,冗余儲(chǔ)存,流量削峰,異步通信,數(shù)據(jù)同步等功能。
發(fā)送無(wú)需等待,發(fā)送者和接收者的生命周期沒(méi)有必然關(guān)系。

image.png
異步消息的消費(fèi)和處理
控制消息的消費(fèi)順序
整合SpringBoot
MQ的集群容錯(cuò)