分散式事務LCN使用-01
阿新 • • 發佈：2020-07-13
關於分散式事務其他的就不多做介紹了、下面建立一個分散式事務的案例；
什麼是LCN？
LCN分散式事務系統通過代理資料資源，通TxManager(事務管理器)協調來完成對事務的統⼀控制，這樣的操控⽅式使得框架對業務嵌⼊性⾮常低，在對本地代理資源的同時也通過排它鎖防⽌其他⼈的 訪問，從⽽也保障了事務的隔離性。 TC: Transaction Client代表事務客戶端，對應流程中是對事務發起⽅與事務參與⽅的泛指。 TM: TransactionManager，也簡稱為TxManager是事務管理器。 執行流程：按照LCN5.X的快速開始文件
官方文件教程在這裡-----------------》》》》》》》。https://www.codingapi.com/docs/txlcn-start/
搭建TM服務
建表
DROP TABLE IF EXISTS `t_tx_exception`; CREATE TABLE `t_tx_exception` ( `id` bigint(20) NOT NULL AUTO_INCREMENT, `group_id` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL, `unit_id` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULTNULL, `mod_id` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL, `transaction_state` tinyint(4) NULL DEFAULT NULL, `registrar` tinyint(4) NULL DEFAULT NULL COMMENT '-1 未知 0 Manager 通知事務失敗， 1 client詢問事務狀態失敗2 事務發起方關閉事務組失敗', `ex_state` tinyint(4) NULL DEFAULT NULL COMMENT '0 待處理 1已處理', `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;
使用git拉去tc_lcn原始碼
git clone https://github.com/codingapi/tx-lcn.git
修改配置資訊(txlcn-tm\src\main\resources\application.properties)
#給出的都是預設值
spring.application.name=tx-manager server.port=7970 spring.datasource.driver-class-name=com.mysql.jdbc.Driver spring.datasource.url=jdbc:mysql://127.0.0.1:3306/tx-manager?characterEncoding=UTF-8 spring.datasource.username=root spring.datasource.password=root mybatis.configuration.map-underscore-to-camel-case=true mybatis.configuration.use-generated-keys=true #tx-lcn.logger.enabled=true # TxManager Host Ip #tx-lcn.manager.host=127.0.0.1 # TxClient連線請求埠 #tx-lcn.manager.port=8070 # 心跳檢測時間(ms) #tx-lcn.manager.heart-time=15000 # 分散式事務執行總時間 #tx-lcn.manager.dtx-time=30000 #引數延遲刪除時間單位ms #tx-lcn.message.netty.attr-delay-time=10000 #tx-lcn.manager.concurrent-level=128 # 開啟日誌 #tx-lcn.logger.enabled=true #logging.level.com.codingapi=debug #redisIp #spring.redis.host=127.0.0.1 #redis\u7AEF\u53E3 #spring.redis.port=6379 #redis\u5BC6\u7801 #spring.redis.password=
提示為打成jar包啟動，我這裡修改了資料庫連線之後使用idea直接啟動了