3．分布式事务实战_《架构世界》2020微服务刊：微服务分布式事务实战-QQ阅读男生轻小说网

上QQ阅读APP看书，第一时间看更新

3．分布式事务实战

如何在项目中运用servicecomb-pack，需要进行以下步骤：

alpha-server配置

编译alpha-server

1．环境准备

• JDK1.8

• Maven3.x

2．源码获取

Github地址：https://github.com/apache/servicecomb-pack

$ git clone https://github.com/apache/servicecomb-pack.git

$ git checkout 0.4.0

3．修改配置文件

找到alpha-server/src/main/resource/application.yaml，修改datasource信息为本地信息即可

4．本地构建alpha-server

$ cd servicecomb-pack

$ mvn clean install -DskipTests-Pspring-boot-2

在执行玩命令之后，可在alpha/alpha-server/target/saga/alpha-server-${version}-exec.jar中找到alpha-server的可执行jar包

5．初始化数据库

可在alpha\alpha-server\src\main\resources目录下找到schema-mysql.sql和schema-postgresql.sql两个sql文件，可自行根据所选数据库进行初始化即可。

6．启动alpha-server

java -Dspring.profiles.active=prd

-D"spring.datasource.url=jdbc:postgresql://${host_address}:5432/saga?useS

SL=false" -jar alpha-server-${saga_version}-exec.jar

注意：请在执行命令前将${saga_version}和${host_address}更改为实际值

至此，alpha-server全局事务管理器已经启动成功。

替换postgresql为mysql

目前alpha-server支持pg和mysql两种数据库，默认为pg，如需改为mysql，需要进行如下操作：

1．安装并运行mysql

2．修改pom文件，添加依赖

alpha-server/pom.xml，添加mysql依赖

dependency>

<groupId>mysql</groupId>

<artifactId>mysql-connector-java</artifactId>

<scope>runtime</scope>

</dependency>

3．修改配置文件

找到alpha-server/src/main/resource/application.yaml，修改datasource信息为本地信息即可

spring:

profiles: mysql

datasource:

username: ${username}

password: ${password}

url: jdbc:mysql://${host_address}:${port}/${database_name}?serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=UTF-8&useSSL=false

platform: mysql

continue-on-error: false

driver-class-name: com.mysql.cj.jdbc.Driver

注意：${username}，${password}，${host_address}，${port}，${database_name}需替换为实际值

4．本地构建alpha-server（和上面步骤一致）

5．启动alpha-server

java -Dspring.profiles.active=mysql -Dloader.path=./plugins

-D"spring.datasource.url=jdbc:mysql://${host_address}:3306/${database_name}?

serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=UTF

-8&useSSL=false " -jar alpha-server-${saga_version}-exec.jar

注意：请在执行命令前将${saga_version}和${host_address}更改为实际值

自此，alpha-server端已经配置编译完成

Omega配置

配置完alpha-server之后，就相当于分布式事务的协调器已经配置完成，剩下的就是omega的配置，也就是在实际开发中如何运用servicecomb-pack去处理分布式事务。本次讲解会结合一个实际案例：购物系统中的下单流程和删除产品流程来分别讲解saga模式和tcc模式如何使用的。

环境准备

本次案例：购物系统是采用分布式微服务架构，整体分为三个微服务应用：orderManage订单管理应用、productManage产品管理应用、stockManage库存管理应用

1．添加依赖

分别在三个应用的pom文件中添加Omega所需的依赖：

<groupId>org.apache.servicecomb.pack</groupId>

<artifactId>omega-spring-starter</artifactId>

<version>${servicecomb-pack.version}</version>

</dependency>

<groupId>org.apache.servicecomb.pack</groupId>

<artifactId>omega-transport-resttemplate</artifactId>

<version>${servicecomb-pack.version}</version>

</dependency>

<groupId>org.apache.servicecomb.pack</groupId>

<artifactId>omega-spring-cloud-consul-starter</artifactId>

<version>${servicecomb-pack.version}</version>

</dependency>

<groupId>org.apache.servicecomb.pack</groupId>

<artifactId>omega-spring-cloud-eureka-starter</artifactId>

<version>${servicecomb-pack.version}</version>

</dependency>

注意：请将${servicecomb-pack.version}更改为实际的版本号（推荐版本为0.4.0）

注意：如需做集群，omega-spring-cloud-consul-starter和omega-spring-cloud-eureka-starter二选一，视项目的注册中心而定。

2．修改配置文件

分别在三个应用的application.yml配置文件中添加alpha-server配置，具体配置如下：

#配置alpha-server地址

alpha:

cluster:

address: 10.15.15.172:8080

omega:

enabled: true

注意：application.name一定不要过长，因为instanceId的格式是application.name+IP，并且长度为36，否则alpha-server事务持久化会报错

以上两个属性配置为必填，因为alpha-server会依据application.name去查找对应的Omega，其他应用配置自行添加，address可根据alpha-server中的配置实际添加

自此，环境准备已经完毕，下面开始进行应用代码编写

saga模式代码编写

在本次案例中，我们以一个下单流程来讲解saga模式下代码是如何编写的。下单流程包括：点击下单、查询库存、支付、更新库存；订单应用作为起始服务，调用库存应用和产品应用，这两个应用对应的服务作为参与服务（子事务），在订单应用下单，订单应用使用rest template向产品应用发起调用校验产品库存，然后订单应用向库存应用发起支付请求（子事务1），支付成功后订单应用再向库存应用发起请求更新库存（子事务2）。

1．@SagaStart

首先需要在应用代码中描述出saga事务的边界，作为分布式事务的起始点，因此我们需要在订单应用中的createOrder（）方法上添加该注解@SagaStart：

2．@ Compensable

@Compensable所代表的是本地子事务，因此需要在创建支付和更新库存的方法上添加此注解来标注该逻辑为子事务，并且在Compensable的compensationMethod属性中描述补偿方法。注意补偿方法和本地事务方法的参数必须一致，否则Omega在系统启动进行参数检查的时候报找不到恢复方法的错误：

支付：