您好,登錄后才能下訂單哦!
電商中有這樣的一個(gè)場(chǎng)景:
我們主要討論一下,下單及投遞消息到mq的操作,如何實(shí)現(xiàn)?每種方式優(yōu)缺點(diǎn)?
step1:start transaction
step2:生成訂單
step3:投遞消息到mq
step4:commit transaction
這種方式是將發(fā)送消息放在了事務(wù)提交之前,可能存在的問題:
step3發(fā)生異常
導(dǎo)致step4失敗,下單失敗,直接影響到下單業(yè)務(wù)
step4發(fā)生異常,其他step成功
下單失敗,消息投遞成功,給用戶增加了積分
我們將發(fā)送消息放到事務(wù)之后進(jìn)行:
step1:start transaction
step2:生成訂單
step3:commit transaction
step4:投遞消息到mq
可能會(huì)出現(xiàn)的問題:
step4發(fā)生異常,其他step成功
導(dǎo)致下單成功,投遞消息失敗,用戶未增加積分
上面兩種是比較常見的做法,也是最容易出錯(cuò)的。
step1:start transaction
step2:生成訂單
step3:本地庫(kù)中插入一條需要發(fā)送消息的記錄t_msg_record
step3:commit transaction
step5:新增一個(gè)定時(shí)器,輪詢t_msg_record,將待發(fā)送的記錄投遞到mq中
這種方式借助了數(shù)據(jù)庫(kù)的事務(wù),業(yè)務(wù)和消息記錄作為了一個(gè)原子操作,業(yè)務(wù)成功之后,消息日志必定是存在的。解決了前兩種方式遇到的問題。如果我們的業(yè)務(wù)系統(tǒng)比較單一,可以采用這種方式。
對(duì)于微服務(wù)化的情況,上面這種方式不是太好,每個(gè)服務(wù)都需要上面的操作;也不利于擴(kuò)展。
增加一個(gè)消息服務(wù)及消息庫(kù),負(fù)責(zé)消息的落庫(kù)、將消息發(fā)送投遞到mq。
step1:start transaction
step2:生成訂單
step3:當(dāng)前事務(wù)庫(kù)插入一條日志:生成一個(gè)唯一的業(yè)務(wù)id(bus_id),將bus_id和訂單關(guān)聯(lián)起來保存到當(dāng)前事務(wù)所在的庫(kù)中
step4:調(diào)用消息服務(wù):攜帶bus_id,將消息先落地入庫(kù),此時(shí)消息的狀態(tài)為待發(fā)送狀態(tài),返回消息id(msg_id)
step5:commit transaction
step6:如果上面都成功,調(diào)用消息服務(wù),將消息投遞到mq中;如果上面有失敗的情況,則調(diào)用消息服務(wù)取消消息的發(fā)送
能想到上面這種方式,已經(jīng)算是有很大進(jìn)步了,我們繼續(xù)分析一下可能存在的問題:
在以上方式中,我們繼續(xù)改進(jìn),進(jìn)而出現(xiàn)了更好的一種方式:
step1:生成一個(gè)全局唯一業(yè)務(wù)消息id(bus_msg_id),調(diào)用消息服務(wù),攜帶bus_msg_id,將消息先落地入庫(kù),此時(shí)消息的狀態(tài)為待發(fā)送狀態(tài),返回消息id(msg_id)
step2:start transaction
step3:生成訂單
step4:當(dāng)前事務(wù)庫(kù)插入一條日志(將step3中的業(yè)務(wù)和bus_msg_id關(guān)聯(lián)起來)
step5:commit transaction
step6:分2中情況:如果上面都成功,調(diào)用消息服務(wù),將消息投遞到mq中;如果上面有失敗的情況,則調(diào)用消息服務(wù)取消消息的發(fā)送
方式五和方式四對(duì)比,比較好的一個(gè)地方:將調(diào)用消息服務(wù),消息落地操作,放在了事務(wù)之外進(jìn)行,這點(diǎn)小的改進(jìn)其實(shí)算是一個(gè)非常好的優(yōu)化。
路人甲Java,只生產(chǎn)干貨,公眾號(hào):javacode2018,喜歡的關(guān)注一下。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。