分散式事務之解決方案（最大努力通知）

6.分散式事務解決方案之最大努力通知 6.1. 什麼是最大努力通知最大努力通知也是一種解決分散式事務的方案，下邊是一個是充值的例子：交互流程：1、賬戶系統調用充值系統介面2、充值系統完成支付處理向賬戶系統發起充值結果通知若通知失敗，則充值系統按策略進行重覆通知3、賬戶系統接收到充值結果通知修改充 ...

6.分散式事務解決方案之最大努力通知

6.1. 什麼是最大努力通知

最大努力通知也是一種解決分散式事務的方案，下邊是一個是充值的例子：
在這裡插入圖片描述
交互流程：
1、賬戶系統調用充值系統介面
2、充值系統完成支付處理向賬戶系統發起充值結果通知
若通知失敗，則充值系統按策略進行重覆通知
3、賬戶系統接收到充值結果通知修改充值狀態
4、賬戶系統未接收到通知會主動調用充值系統的介面查詢充值結果
通過上邊的例子我們總結最大努力通知方案的目標：
目標：發起通知方通過一定的機制最大努力將業務處理結果通知到接收方。
具體包括：
1、有一定的消息重覆通知機制。
因為接收通知方可能沒有接收到通知，此時要有一定的機制對消息重覆通知。
2、消息校對機制。
如果盡最大努力也沒有通知到接收方，或者接收方消費消息後要再次消費，此時可由接收方主動向通知方查詢消息信息來滿足需求。
最大努力通知與可靠消息一致性有什麼不同？
1、解決方案思想不同
可靠消息一致性，發起通知方需要保證將消息發出去，並且將消息發到接收通知方，消息的可靠性關鍵由發起通知方來保證。
最大努力通知，發起通知方盡最大的努力將業務處理結果通知為接收通知方，但是可能消息接收不到，此時需要接收通知方主動調用發起通知方的介面查詢業務處理結果，通知的可靠性關鍵在接收通知方。
2、兩者的業務應用場景不同
可靠消息一致性關註的是交易過程的事務一致，以非同步的方式完成交易。
最大努力通知關註的是交易後的通知事務，即將交易結果可靠的通知出去。
3、技術解決方向不同
可靠消息一致性要解決消息從發出到接收的一致性，即消息發出並且被接收到。
最大努力通知無法保證消息從發出到接收的一致性，只提供消息接收的可靠性機制。可靠機制是，最大努力的將消息通知給接收方，當消息無法被接收方接收時，由接收方主動查詢消費（業務處理結果）。

6.2. 解決方案

通過對最大努力通知的理解，採用MQ的ack機制就可以實現最大努力通知。
方案1 ：
在這裡插入圖片描述
本方案是利用MQ的ack機制由MQ向接收通知方發送通知，流程如下：
1、發起通知方將通知發給MQ。
使用普通消息機制將通知發給MQ。
註意：如果消息沒有發出去可由接收通知方主動請求發起通知方查詢業務執行結果。
2、接收通知方監聽MQ。
3、接收通知方接收消息，業務處理完成回應ack。
4、接收通知方若沒有回應ack則MQ會重覆通知。
MQ會按照間隔1min、5min、10min、30min、1h、2h、5h、10h的方式，逐步拉大通知間隔（如果MQ採用rocketMq，在broker中可進行配置），直到達到通知要求的時間視窗上限。
5、接收通知方可通過消息校對介面來校對消息的一致性。
方案2 ：
本方案也是利用MQ的ack機制，與方案1不同的是應用程式向接收通知方發送通知，如下圖：
在這裡插入圖片描述
交互流程如下：
1、發起通知方將通知發給MQ。
使用可靠消息一致方案中的事務消息保證本地事務與消息的原子性，最終將通知先發給MQ。
2、通知程式監聽MQ，接收MQ的消息。
方案1中接收通知方直接監聽MQ，方案2中由通知程式監聽MQ。
通知程式若沒有回應ack則MQ會重覆通知。
3、通知程式通過互聯網介面協議（如http、webservice）調用接收通知方案介面，完成通知。
通知程式調用接收通知方案介面成功就表示通知成功，即消費MQ消息成功，MQ將不再向通知程式投遞通知消息。
4、接收通知方可通過消息校對介面來校對消息的一致性。
方案1和方案2的不同點：
1、方案1中接收通知方與MQ介面，即接收通知方案監聽MQ，此方案主要應用與內部應用之間的通知。
2、方案2中由通知程式與MQ介面，通知程式監聽MQ，收到MQ的消息後由通知程式通過互聯網介面協議調用接收通知方。此方案主要應用於外部應用之間的通知，例如支付寶、微信的支付結果通知。

6.3.RocketMQ實現最大努力通知型事務

6.3.1.業務說明

本實例通過RocketMq中間件實現最大努力通知型分散式事務，模擬充值過程。
本案例有賬戶系統和充值系統兩個微服務，其中賬戶系統的資料庫是bank1資料庫，其中有張三賬戶。充值系統的資料庫使用bank1_pay資料庫，記錄了賬戶的充值記錄。
業務流程如下圖：
在這裡插入圖片描述
交互流程如下：
1、用戶請求充值系統進行充值。
2、充值系統完成充值將充值結果發給MQ。
3、賬戶系統監聽MQ，接收充值結果通知，如果接收不到消息，MQ會重覆發送通知。接收到充值結果通知賬戶系統增加充值金額。
4、賬戶系統也可以主動查詢充值系統的充值結果查詢介面，增加金額。

6.3.2.程式組成部分

本示常式序組成部分如下：
資料庫:MySQL-5.7.25
包括bank1和bank1_pay兩個資料庫。
JDK:64位 jdk1.8.0_201
rocketmq 服務端:RocketMQ-4.5.0
rocketmq 客戶端:RocketMQ-Spring-Boot-starter.2.0.2-RELEASE 微服務框架:spring-boot-2.1.3、spring-cloud-Greenwich.RELEASE
微服務及資料庫的關係 :
dtx/dtx-notifymsg-demo/dtx-notifymsg-demo-bank1 銀行1，操作張三賬戶，連接資料庫bank1 dtx/dtx-notifymsg-demo/dtx-notifymsg-demo-pay 銀行2，操作充值記錄，連接資料庫bank1_pay
在這裡插入圖片描述
交互流程如下：
1、用戶請求充值系統進行充值。
2、充值系統完成充值將充值結果發給MQ。
3、賬戶系統監聽MQ，接收充值結果通知，如果接收不到消息，MQ會重覆發送通知。接收到充值結果通知賬戶系統增加充值金額。
4、賬戶系統也可以主動查詢充值系統的充值結果查詢介面，增加金額。

6.3.3.創建資料庫

創建bank1庫，並導入以下表結構和數據（包含張三賬戶）

CREATE DATABASE `bank1` CHARACTER SET 'utf8' COLLATE 'utf8_general_ci';
DROP TABLE IF EXISTS `account_info`; CREATE TABLE `account_info` (
`id` bigint(20) NOT NULL AUTO_INCREMENT,
`account_name` varchar(100) CHARACTER SET utf8 COLLATE utf8_bin NULL DEFAULT NULL COMMENT '戶 主姓名',
`account_no` varchar(100) CHARACTER SET utf8 COLLATE utf8_bin NULL DEFAULT NULL COMMENT '銀行卡號',
`account_password` varchar(100) CHARACTER SET utf8 COLLATE utf8_bin NULL DEFAULT NULL COMMENT
'帳戶密碼',
`account_balance` double NULL DEFAULT NULL COMMENT '帳戶餘額', PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 5 CHARACTER SET = utf8 COLLATE = utf8_bin ROW_FORMAT = Dynamic;
INSERT INTO `account_info` VALUES (2, '張三的賬戶', '1', '', 10000);
DROP TABLE IF EXISTS `de_duplication`; CREATE TABLE `de_duplication` (
`tx_no` varchar(64) COLLATE utf8_bin NOT NULL, `create_time` datetime(0) NULL DEFAULT NULL, PRIMARY KEY (`tx_no`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8 COLLATE = utf8_bin ROW_FORMAT = Dynamic;

創建bank1_pay庫，並導入以下表結構:

 CREATE DATABASE `bank1_pay` CHARACTER SET 'utf8' COLLATE 'utf8_general_ci'; CREATE TABLE `account_pay` (
`id` varchar(64) COLLATE utf8_bin NOT NULL,
`account_no` varchar(100) CHARACTER SET utf8 COLLATE utf8_bin NULL DEFAULT NULL COMMENT '賬號', `pay_amount` double NULL DEFAULT NULL COMMENT '充值餘額',
`result` varchar(20) COLLATE utf8_bin DEFAULT NULL COMMENT '充值結果:success，fail',
PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 5 CHARACTER SET = utf8 COLLATE = utf8_bin ROW_FORMAT = Dynamic;

6.3.4.啟動RocketMQ

rocketMQ啟動方式與RocketMQ實現可靠消息最終一致性事務中完全一致

6.3.5.discover-server

discover-server是服務註冊中心，測試工程將自己註冊至discover-server。

6.3.6.工程概述

（1）父工程maven依賴說明
在dtx父工程中指定了SpringBoot和SpringCloud版本

<dependency> 
	<groupId>org.springframework.boot</groupId> 
	<artifactId>spring‐boot‐dependencies</artifactId>      					   <version>2.1.3.RELEASE</version>
<type>pom</type>
<scope>import</scope>
</dependency>
<dependency>