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ò)