? ? ? ? 什么叫做獨(dú)立消息服務(wù)？獨(dú)立消息服務(wù)是指：在分布式架構(gòu)系統(tǒng)當(dāng)中各個(gè)子系統(tǒng)之間相互調(diào)用而產(chǎn)生的事物問(wèn)題的一種解決方案心铃，它提供相應(yīng)接口服務(wù)api供消息生產(chǎn)方，跟消息消費(fèi)方使用，從而盡可能的達(dá)到事物強(qiáng)一致性保證姑子，下面我們將介紹獨(dú)立消息服務(wù)的實(shí)現(xiàn)！

? ? ? ? 舉一個(gè)用戶(hù)下單支付的例子测僵，我們有一個(gè)支付網(wǎng)關(guān)系統(tǒng)街佑，在接收到第三方回調(diào)通知成功的情況下，我們訂單系統(tǒng)需要update訂單表為已支付捍靠，并insert支付流水沐旨，在會(huì)員賬戶(hù)系統(tǒng)，我們需要往會(huì)員賬戶(hù)加余額榨婆，記錄賬戶(hù)流水等等...

首先磁携，介紹一下獨(dú)立消息服務(wù)由幾個(gè)子系統(tǒng)組成：

? ? ? ? 1、消息服務(wù)子系統(tǒng)：主要提供以下作用

? ? ? ? ? ? ? ? a纲辽、用于存儲(chǔ)預(yù)發(fā)送消息

? ? ? ? ? ? ? ? b颜武、確認(rèn)并發(fā)送消息

? ? ? ? ? ? ? ? c璃搜、查詢(xún)狀態(tài)確認(rèn)超時(shí)的消息

? ? ? ? ? ? ? ? d、確認(rèn)消息已被成功消費(fèi)

? ? ? ? ? ? ? ? e鳞上、查詢(xún)消息確認(rèn)超時(shí)的消息

? ? ? ? ? ? ? ? f这吻、刪除本地消息（已完成）

? ? ? ? 2、MQ實(shí)時(shí)消息服務(wù)子系統(tǒng)：mq消息隊(duì)列

? ? ? ? 3篙议、消息狀態(tài)確認(rèn)子系統(tǒng)：用于輪詢(xún) or 定時(shí)任務(wù)查詢(xún)生產(chǎn)方消息投遞異常的記錄唾糯，進(jìn)行重新投遞。

? ? ? ? 4鬼贱、消息恢復(fù)子系統(tǒng)：用于輪詢(xún) or 定時(shí)任務(wù)查詢(xún) 消費(fèi)端消費(fèi)失敗的異常日志記錄移怯，進(jìn)行消費(fèi)恢復(fù)。

下面介紹正向流程：

? ? ? ? ? 第一步：用戶(hù)調(diào)用網(wǎng)關(guān)系統(tǒng)这难，通過(guò)網(wǎng)關(guān)系統(tǒng)通過(guò)訂單系統(tǒng)確認(rèn)并創(chuàng)建一條待支付的訂單舟误，

? ? ? ? ? 第二步：用戶(hù)微信掃碼完成支付，

? ? ? ? ? 第二步：網(wǎng)關(guān)系統(tǒng)接收到微信回調(diào)通知姻乓，調(diào)用實(shí)時(shí)消息服務(wù)（mq）投遞一條訂單隊(duì)列消息嵌溢。

? ? ? ? ? 第三步：訂單系統(tǒng)監(jiān)聽(tīng)到實(shí)時(shí)消息服務(wù)mq，調(diào)用消息服務(wù)子系統(tǒng) 保存一條預(yù)發(fā)送的消息（更新賬戶(hù)）到消息服務(wù)子系統(tǒng)的DB存儲(chǔ)蹋岩。

? ? ? ? 第四步：消息服務(wù)子系統(tǒng)保存訂單系統(tǒng)發(fā)來(lái)了的預(yù)發(fā)送消息存到本地DB赖草，并返回存儲(chǔ)的結(jié)果。

? ? ? ? ? 第五步：訂單系統(tǒng)得到消息服務(wù)子系統(tǒng)本地存儲(chǔ)成功之后剪个，訂單系統(tǒng)開(kāi)始執(zhí)行本地事物（更新訂單狀態(tài)秧骑、并insert支付流水記錄），并再次調(diào)用消息服務(wù)子系統(tǒng)告知訂單處理成功的結(jié)果扣囊，

? ? ? ? ? 第六步：消息服務(wù)子系統(tǒng)得到訂單處理完成的結(jié)果之后乎折，會(huì)更新剛才存在本地的那條預(yù)發(fā)送的消息（更新賬戶(hù)）的狀態(tài)，改為可發(fā)送如暖。并通過(guò)調(diào)用實(shí)時(shí)消息服務(wù)（mq）投遞一條更新會(huì)員賬戶(hù)的消息隊(duì)列笆檀。

? ? ? ? ? ? 第七步：會(huì)員系統(tǒng)監(jiān)聽(tīng)到隊(duì)列當(dāng)中的一條更新賬戶(hù)的消息之后，會(huì)執(zhí)行本地更新賬戶(hù)盒至，并將隊(duì)列中的更新賬戶(hù)消息刪除掉酗洒，再調(diào)用消息服務(wù)子系統(tǒng)，確認(rèn)已消費(fèi)枷遂，并刪除這條已被消費(fèi)的消息記錄樱衷。

? 異常流程：

? ? ? ? ? ? 1、在第三步中酒唉，我調(diào)用消息服務(wù)子系統(tǒng) 保存一條預(yù)發(fā)送的消息（更新賬戶(hù)）到消息服務(wù)子系統(tǒng)的DB存儲(chǔ)的接口當(dāng)中矩桂，如果網(wǎng)絡(luò)終端導(dǎo)致接口調(diào)用失敗，或者調(diào)用成功但一直得不到消息服務(wù)子系統(tǒng)的一個(gè)存儲(chǔ)結(jié)果痪伦？

? ? ? ? ? ? 答：調(diào)用失斨读瘛／收不到反饋結(jié)果雹锣，本地事物也不會(huì)處理。

? ? ? ? ? ? 2癞蚕、在第五步中蕊爵，如果訂單系統(tǒng)收到消息服務(wù)子系統(tǒng)的預(yù)發(fā)送消息DB存儲(chǔ)成功結(jié)果，然后進(jìn)行本地訂單處理的事物也成功／失敗桦山，但是由于網(wǎng)絡(luò)原因攒射，再次調(diào)用消息服務(wù)子系統(tǒng)告知訂單處理成功的結(jié)果的這個(gè)動(dòng)作失敗，下面流程怎么走恒水？

? ? ? ? ? ? 答：消息狀態(tài)確認(rèn)子系統(tǒng)就是來(lái)解決這種異常会放，它會(huì)去輪詢(xún)消息日志表，根據(jù)規(guī)則找出預(yù)發(fā)送狀態(tài)的消息記錄钉凌，然后去調(diào)用訂單系統(tǒng)確認(rèn)是否已經(jīng)訂單處理完成咧最，如果訂單處理失敗，則調(diào)用消息服務(wù)子系統(tǒng)將這條消息記錄刪除掉甩骏，如果訂單處理是完成的窗市，則調(diào)用正向流程的第六步先慷。

? ? ? ? ? ? 3饮笛、在第六步當(dāng)中，調(diào)用實(shí)時(shí)消息服務(wù)（mq）投遞一條更新會(huì)員賬戶(hù)的消息隊(duì)列失敗论熙，怎么處理福青？

? ? ? ? ? ? 答：消息恢復(fù)子系統(tǒng)就是來(lái)解決這種異常，它會(huì)去輪詢(xún)消息日志表脓诡，根據(jù)規(guī)則找出消息狀態(tài)為發(fā)送成功无午，但是還未被消費(fèi)掉的消息記錄，然后重新投遞一條消費(fèi)會(huì)員的隊(duì)列到實(shí)時(shí)消息服務(wù)（mq）中祝谚，然后執(zhí)行正向流程的第七步宪迟。

? ? ? ? ? 4、在第七步當(dāng)中交惯，如果會(huì)員賬戶(hù)已經(jīng)本地事物完成次泽，但是調(diào)用消息服務(wù)子系統(tǒng)更新?tīng)顟B(tài)為已被消費(fèi)這個(gè)動(dòng)作失敗了，該怎么處理席爽？

? ? ? ? ? ? 答：消息恢復(fù)子系統(tǒng)同樣會(huì)去輪詢(xún)消息日志表意荤，根據(jù)規(guī)則找出消息狀態(tài)為發(fā)送成功，但是還未被消費(fèi)掉的消息記錄只锻，然后重新投遞一條消費(fèi)會(huì)員的隊(duì)列到實(shí)時(shí)消息服務(wù)（mq）中玖像，會(huì)員系統(tǒng)監(jiān)聽(tīng)到隊(duì)列之后，本地需要做一個(gè)更新賬戶(hù)冪等性的判斷齐饮，判斷是否已經(jīng)被處理捐寥，如果是處理完成笤昨，則再次刪除消息隊(duì)列，并調(diào)用消息服務(wù)子系統(tǒng)握恳，告知已經(jīng)被消費(fèi)咬腋。

其它

? ? ? ? ? 可能會(huì)有讀者問(wèn)到為什么要單獨(dú)部署兩個(gè)定時(shí)任務(wù)的系統(tǒng)（消息狀態(tài)確認(rèn)子系統(tǒng)、消息恢復(fù)子系統(tǒng)）睡互？ 仔細(xì)研究會(huì)發(fā)現(xiàn)根竿，一個(gè)是用來(lái)確認(rèn)生產(chǎn)方的一個(gè)流程，一個(gè)是用來(lái)確認(rèn)并恢復(fù)消費(fèi)方的一個(gè)流程就珠，單獨(dú)部署可以做到低耦合寇壳。

? ? ? ? ? 后面會(huì)更新其它關(guān)于分布式事物解決的方案，例如 最大努力通知型妻怎、TCC階段提交壳炎。