分布式事務框架 TX-LCN 使用

本文轉載自查看原文 2020-03-13 15:26 1570 數據一致性/ 分布式大數據

TX-LCN 是一個分布式事務框架，很好用，原理簡單實用簡單，但是已經停止更新一年多了。

　　支持多種分布式事務的方案，這次直說最核心的LCN 方式。

名詞解釋

　　TM: 事務管理中心

　　TC:就是我們的服務

原理：TC-A 發起一個基於本地事務的分布式事務，這時候產生一個隨機Id 標志這個 TC-A 調用 TC-B 的時候，通過請求頭，X-Group-ID 吧這個參數帶過去。

　　　 TC-B 查詢到單前事務有這個 X-Group-ID ，和告訴TM 事務B 加入這個 X-Group-ID 標記的事務組，那么做完本地事務以后不會立即提交，而是告訴 TM 事務B 已經可以提交了，知道所有的事務都到達可以提交的地步，TM通知所有事務一起提交。如果有后面的事務失敗，那么 TM 會通知前面的事務回滾，發起分布式事務的那個事務 A 需要依賴 api 調用異常回滾（如果吞了這個異常，發起分布式事務的本地事務不會回滾）。

使用：

1 下載 TM 的代碼，修改配置，需要 mysql 和 redis ，mysql需要初始化數據庫和表。然后編譯啟動 TM

修改配置：

spring.application.name=TransactionManager
server.port=7970
spring.datasource.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.url=jdbc:mysql://118.24.0.161:6033/tx-manager?characterEncoding=UTF-8
spring.datasource.username=****
spring.datasource.password=****
spring.jpa.database-platform=org.hibernate.dialect.MySQL5InnoDBDialect
spring.jpa.hibernate.ddl-auto=update


#redis ä¸»æº
spring.redis.host=118.24.0.161
#redis ç«¯å£
spring.redis.port=9736
#redis å¯ç 
spring.redis.password=***

初始化sql

CREATE DATABASE IF NOT EXISTS  `tx-manager` DEFAULT CHARSET utf8 COLLATE utf8_general_ci;
USE `tx-manager`;

SET NAMES utf8mb4;
SET FOREIGN_KEY_CHECKS = 0;

-- ----------------------------
-- Table structure for t_tx_exception
-- ----------------------------
DROP TABLE IF EXISTS `t_tx_exception`;
CREATE TABLE `t_tx_exception`  (
  `id` bigint(20) NOT NULL AUTO_INCREMENT,
  `group_id` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL,
  `unit_id` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL,
  `mod_id` varchar(128) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL,
  `transaction_state` tinyint(4) NULL DEFAULT NULL,
  `registrar` tinyint(4) NULL DEFAULT NULL,
  `ex_state` tinyint(4) NULL DEFAULT NULL COMMENT '0 待處理 1已處理',
  `remark` varchar(10240) NULL DEFAULT NULL COMMENT '備注',
  `create_time` datetime(0) NULL DEFAULT NULL,
  PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 967 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT = Dynamic;

SET FOREIGN_KEY_CHECKS = 1;

2 修改每一個 TC

　　1 引入 maven 依賴

 <dependency>
            <groupId>com.codingapi.txlcn</groupId>
            <artifactId>txlcn-tc</artifactId>
            <version>5.0.2.RELEASE</version>
        </dependency>

        <dependency>
            <groupId>com.codingapi.txlcn</groupId>
            <artifactId>txlcn-txmsg-netty</artifactId>
            <version>5.0.2.RELEASE</version>
        </dependency>

　2 在啟動類上開啟分布式事務： @EnableDistributedTransaction