LCN分布式事務解決方案詳解

更新時間：2021年08月17日 17:35:51 作者：司天宏

這篇文章主要介紹了LCN分布式事務解決方案詳解,本篇文章通過簡要的案例,講解了該項技術的了解與使用,以下就是詳細內容,需要的朋友可以參考下

一、什么是分布式事務？

在這里插入圖片描述

二、lcn的實現(xiàn)思路

Lcn 的本質就是提供了一個全局的事務管理器
本地事務的提交還是回滾，由全局的事務管理器決定

在這里插入圖片描述

2.1 本地執(zhí)行的狀態(tài)怎么提交給全局事務？

使用切面攔截本地事務的執(zhí)行結果，使用tcp 發(fā)送給tx-manager

2.2 本地事務的提交或回滾怎么實現(xiàn)？

等待tx-manager通知自己

三、lcn的使用

3.1 下載lcn-manager （全局的事務管理器）

在這里插入圖片描述

3.2 配置lcn-manager

配置eureka 并且配置redis

在這里插入圖片描述

Redis：

在這里插入圖片描述

3.3 啟動lcn

在這里插入圖片描述

3.4 模擬轉賬服務

數(shù)據(jù)庫：

在這里插入圖片描述

3.4.1 add-service

在這里插入圖片描述

3.4.2 decr-service

在這里插入圖片描述

3.5 2 個微服務都需要添加依賴

<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-actuator</artifactId>
		</dependency>
		<dependency>
			<groupId>com.codingapi</groupId>
			<artifactId>transaction-springcloud</artifactId>
			<version>${lcn.last.version}</version>
			<exclusions>
				<exclusion>
					<groupId>org.slf4j</groupId>
					<artifactId>*</artifactId>
				</exclusion>
			</exclusions>
		</dependency>
		<dependency>
			<groupId>com.codingapi</groupId>
			<artifactId>tx-plugins-db</artifactId>
			<version>${lcn.last.version}</version>
			<exclusions>
				<exclusion>
					<groupId>org.slf4j</groupId>
					<artifactId>*</artifactId>
				</exclusion>
			</exclusions>
		</dependency>
		<!-- 依據(jù)druid 來實現(xiàn)的攔截功能 -->
		<dependency>
			<groupId>com.alibaba</groupId>
			<artifactId>druid</artifactId>
			<version>1.0.19</version>
		</dependency>

3.6 需要自定義數(shù)據(jù)庫的連接池

在2 個微服務的啟動類或配置類里面都可以添加

@Bean
	public DataSource dataSource() {
		DruidDataSource dataSource = new DruidDataSource();
		dataSource.setUrl(env.getProperty("spring.datasource.url"));
		dataSource.setUsername(env.getProperty("spring.datasource.username"));//用戶名
		dataSource.setPassword(env.getProperty("spring.datasource.password"));//密碼
		dataSource.setInitialSize(10);
		dataSource.setMaxActive(50);
		dataSource.setMinIdle(0);
		dataSource.setMaxWait(60000);
		dataSource.setValidationQuery("SELECT 1");
		dataSource.setTestOnBorrow(false);
		dataSource.setTestWhileIdle(true);
		dataSource.setPoolPreparedStatements(false);
		return dataSource;
	}