消息的可靠投遞

在使用Rabbit MQ的時(shí)候，在發(fā)送消息的時(shí)候我們希望消息不會投遞失敗，這個(gè)時(shí)候RabbitMQ為我們提供了兩種方式用來控制消息的投遞可靠性模式。

config確認(rèn)模式

return退回模式

rabbitmq整個(gè)消息投遞的路徑為：
producer—>rabbitmq broker—>exchange—>queue—>consumer

config確認(rèn)模式

消息從producer 到 exchange， 不管消息能不能到達(dá)交換機(jī)(exchange)config Calback回調(diào)都會執(zhí)行

return退回模式

交換機(jī)到-queue投遞失敗了，會返回一個(gè)return Calback

我們將利用這兩個(gè)Calback 來控制消息的可靠性

思路： 第一步:配置yml 發(fā)送者開啟cinfirm確認(rèn)機(jī)制 第二步:實(shí)現(xiàn)confirm回調(diào)接口 第三步:生產(chǎn)者發(fā)送消息時(shí)設(shè)置confirm回調(diào)

總結(jié)

以上是生活随笔為你收集整理的rabbitmq消息可靠投递(理论)的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。