一、mq訊息傳送
1、傳送端mq-client(訊息生產者:producer)將訊息傳送給mq-server;
2、mq-server將訊息落地;
3、mq-server回ack給mq-client(producer);
4、mq-server將訊息傳送給訊息接受端mq-client(訊息消費者:customer);
5、mq-client(customer)消費接受到訊息後傳送ack給mq-server;
6、mq-server將落地訊息刪除
二、訊息重**送原因
為了保證訊息必達,mq使用了訊息超時、重傳、確認機制。使得訊息可能被重**送,如上圖中,由於網路不可達原因:3和5中斷,可能導致訊息重發。訊息生產者a收不到mq-server的ack,重複向mq-server傳送訊息。mq-server收不到訊息消費者b的ack,重複向訊息消費者b發訊息。
三、訊息重**送產生的後果
舉個例子:購買會員卡,上游支付系統負責給使用者扣款,下游系統負責給使用者發卡,通過mq非同步通知。不管是上半場的ack丟失,導致mq收到重複的訊息,還是下半場ack丟失,導致購卡系統收到重複的購**知,都可能出現,上游扣了一次錢,下游發了多張卡。
四、mq內部如何做到冪等性的
對於每條訊息,mq內部生成乙個全域性唯
一、與業務無關的訊息id:inner-msg-id。當mq-server接收到訊息時,先根據inner-msg-id判斷訊息是否重**送,再決定是否將訊息落地到db中。這樣,有了這個inner-msg-id作為去重的依據就能保證一條訊息只能一次落地到db。
五、訊息消費者應當如何做到冪等性
1、對於非冪等性業務且要求實現冪等性業務:生成乙個唯一id標記每一條訊息,將訊息處理成功和去重日誌通過事物的形式寫入去重表。
2、對於非冪等性業務可不實現冪等性的業務:權衡去重所花的代價決定是否需要實現冪等性,如:購物會員卡成功,向使用者傳送通知簡訊,傳送一次或者多次影響不大。不做冪等性可以省掉寫去重日誌的操作。
mq冪等mysql MQ解決訊息重發 做到冪等性
一 mq訊息傳送 1 傳送端mq client 訊息生產者 producer 將訊息傳送給mq server 2 mq server將訊息落地 3 mq server回ack給mq client producer 4 mq server將訊息傳送給訊息接受端mq client 訊息消費者 custo...
MQ訊息冪等
一 緣起 mq訊息必達,架構上有兩個核心設計點 1 訊息落地 2 訊息超時 重傳 確認 再次回顧訊息匯流排核心架構,它由 傳送端 服務端 固化儲存 接收端 四大部分組成。為保證訊息的可達性,超時 重傳 確認機制可能導致訊息匯流排 或者業務方收到重複的訊息,從而對業務產生影響。舉個栗子 購買會員卡,上...
MQ解決訊息重發 做到冪等性
一 mq訊息傳送 1 傳送端mq client 訊息生產者 producer 將訊息傳送給mq server 2 mq server將訊息落地 3 mq server回ack給mq client producer 4 mq server將訊息傳送給訊息接受端mq client 訊息消費者 custo...