(需求实战_终章_08)SSM集成RabbitMQ 订阅模式 关键代码讲解、开发、测试
機(jī)制和return確認(rèn)機(jī)制都是相對于生產(chǎn)者而言的,
生產(chǎn)者發(fā)送消息一般會有消息發(fā)送成功和消息發(fā)送失敗兩種場景。
生產(chǎn)者消息發(fā)送成功有兩種情況:
一種是:消息發(fā)到了指定的消息隊列中, 在指定的消息隊列中可以找到信息;
另一種情況就是:消息也發(fā)送成功了,但是,沒有指定路由key也就是消息發(fā)出了無法路由到指定消息隊列的消息,消息會被return監(jiān)聽到一些關(guān)鍵、唯一標(biāo)識性信息,例如:全局唯一ID,可以通過補(bǔ)償機(jī)制,結(jié)合關(guān)鍵信息,重新處理此信息。
生產(chǎn)者消息發(fā)送失敗
建交換機(jī)
首先,confirm確認(rèn)機(jī)制和return確認(rèn)機(jī)制都是相對于生產(chǎn)者而言的,生產(chǎn)者發(fā)送消息一般會有消息發(fā)送成功和消息發(fā)送失敗兩種場景。生產(chǎn)者消息發(fā)送成功有兩種情況:一種是:消息發(fā)到了指定的消息隊列中, 在指定的消息隊列中可以找到信息; 另一種情況就是:消息也發(fā)送成功了,但是,沒有指定路由key也就是消息發(fā)出了無法路由到指定消息隊列的消息,消息會被return監(jiān)聽到一些關(guān)鍵、唯一標(biāo)識性信息,例如:全局唯一ID,可以通過補(bǔ)償機(jī)制,結(jié)合關(guān)鍵信息,重新處理此信息。
生產(chǎn)者消息發(fā)送失敗只有一種情況:
交換機(jī)沒有創(chuàng)建。
為什么呢?
這個項目采用的RabbitMQ的訂閱模式Topic,生產(chǎn)者發(fā)送消息到交換機(jī)中,消費(fèi)者進(jìn)行隊列聲明或者創(chuàng)建,然后,在交換機(jī)中進(jìn)行隊列綁定交換機(jī)操作。
項目源碼(企業(yè)實戰(zhàn)):
https://github.com/gb-heima/order
切換到rabbitmq-cr分支
總結(jié)
以上是生活随笔為你收集整理的(需求实战_终章_08)SSM集成RabbitMQ 订阅模式 关键代码讲解、开发、测试的全部內(nèi)容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: SpringBoot整合Redis(单机
- 下一篇: linux CentOS7最小化安装环境