八 MQ容錯處理方式(MQ訊息持久化)

2021-09-29 19:59:32 字數 346 閱讀 5073

上面所說,消費者掛了,可以通過應答方式進行再次處理。如果是mq掛了呢?那麼全部訊息就丟失了?下面是mq掛了,保證訊息不丟失處理。

//宣告佇列**中,設定訊息持久化

boolean durable = false;//持久化宣告
//宣告佇列

channel.queuedeclare(queue_name, durable, false, false, null);
durable:宣告好的佇列,不能改變它的設定,也就是宣告佇列後不可以將值true和false互改,**沒錯,但是執行會報錯,因為持久化模式已經宣告好,只能刪除佇列重新生成。

聊聊mq中訊息消費的幾種方式

對mq了解不是很多的,可以看一下下面兩篇文章 聊聊mq的使用場景 聊聊業務系統中投遞訊息到mq的幾種方式 聊聊訊息消費的幾種方式 如何確保訊息至少消費一次 如何保證訊息消費的冪等性 從消費者的角度出發,分析一下訊息消費的兩種方式 push方式 pull方式 mq接收到訊息 mq主動將訊息推送給消費者...

聊聊mq中訊息消費的幾種方式

對mq了解不是很多的,可以看一下下面兩篇文章 聊聊mq的使用場景 聊聊業務系統中投遞訊息到mq的幾種方式 聊聊訊息消費的幾種方式 如何確保訊息至少消費一次 如何保證訊息消費的冪等性 從消費者的角度出發,分析一下訊息消費的兩種方式 push方式 pull方式 mq接收到訊息 mq主動將訊息推送給消費者...

聊聊業務系統中投遞訊息到mq的幾種方式

電商中有這樣的乙個場景 下單成功之後送積分的操作,我們使用mq來實現 下單成功之後,投遞一條訊息到mq,積分系統消費訊息,給使用者增加積分 我們主要討論一下,下單及投遞訊息到mq的操作,如何實現?每種方式優缺點?step1 start transaction step2 生成訂單 step3 投遞訊...