? ? ? ? 什么叫做獨(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)用失?。詹坏椒答伣Y(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階段提交。