a提供XA模式实现分布式事务_下载启动Seata服务Seata提供XA模式实现分布式事务_转账功能实现上Seata提供XA模式实现分布式事务_转账功能实现下Seata提供XA模式实现分布式事务_业务说明

业务说明

本实例通过Seata中间件实现分布式事务模拟两个账户的转账交易

过程。

两个账户在两个不同的银行张三在bank1、李四在bank2bank1和bank2是两个微服务。

交易过程中张三给李四转账制定金额。

上述交易步骤要么一起成功要么一起失败必须是一个整体性的事务。

工程环境

服务名称服务版本数据库MySQL-5.7.25JDK1.8微服务框架Spring-boot-2.6.3、Spring-Cloud-2021.0.0、Spring-Cloud-Alibaba-2021.0.1.0Seata客户端RM、TMSpring-cloud-alibaba-seata-2021.0.1.0Seata服务端(TC)Seata-server-1.4.2服务注册NacosMybatis

plus3.5.1

account_info(id,account_name,account_no

,account_password,account_balance)

values

(2,张三,1,NULL,1000);bank2库包含李四账户

CREATE

account_info(id,account_name,account_no,account_password,account_balance)

values(3,李四,2,NULL,0);Seata提供XA模式实现分布式事务_下载启动Seata服务

下载seata服务器

下载地址:https://github.com/seata/seata/releases

解压并启动

其中9999为服务端口号file为启动模式,这里指seata服务将采用文件的方式存储信息。

查看启动日志

seata.logSeata提供XA模式实现分布式事务_搭建聚合父工程构建

tar

spring-boot.version2.6.3/springboot.version

spring.cloud.version2021.0.1/spring.cloud.v

ersion

spring.cloud.alibaba.version2021.0.1.0/spri

lombok.version1.18.22/lombok.version

pom

spring-cloudalibaba-dependencies

${spring.cloud.alibaba.version}

IDEA开启Dashboard

dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starterweb/artifactId/dependencydependencygroupIdcom.baomidou/groupIdartifactIdmybatis-plus-bootstarter/artifactIdversion3.5.1/version/dependencydependencygroupIdmysql/groupIdartifactIdmysql-connectorjava/artifactIdversion5.1.49/version/dependencydependencygroupIdorg.projectlombok/groupIdartifactIdlombok/artifactId/dependencydependencygroupIdcom.alibaba.cloud/groupIdartifactIdspring-cloud-starteralibaba-nacos-discovery/artifactId/dependency编写主启动类

//添加对mapper包扫描

{SpringApplication.run(SeataBank1Main6002.class

SeataBank1Main6002

192.168.66.101:8848datasource:url:

jdbc:mysql://localhost:3306/bank2?

useUnicodetruecharacterEncodingutf-

8useSSLfalseserverTimezoneUTCusername:

rootpassword:

dependencygroupIdcom.baomidou/groupIdartifactIdmybatis-plusgenerator/artifactIdversion3.5.2/version/dependency!--

模板引擎

--dependencygroupIdorg.apache.velocity/groupIdartifactIdvelocity-enginecore/artifactIdversion2.0/version/dependency

生成代码

com.baomidou.mybatisplus.generator.FastAutoGenerator;

import

com.baomidou.mybatisplus.generator.config.rules.NamingStrategy;

import

{FastAutoGenerator.create(jdbc:mysql://192.168.66.100:3306/bank2,

root,

注释日期格式.outputDir(System.getProperty(user.dir)

/xa-seata/bank2

//service包名}).strategyConfig(builder

{//

Arrays.asList(account_info);builder.addInclude(strings)

开始实体类配置

.naming(NamingStrategy.underline_to_camel)

//列名下划线转驼峰

.columnNaming(NamingStrategy.underline_to_camel

);}).execute();}

accountMapper.selectById(accountNo);accountInfo.setAccountBalance(accountInfo.getAccountBalance()

amount);accountMapper.updateById(accountInfo);}

}编写控制层

accountInfoService;//接收张三的转账GetMapping(/transfer)public

String

amount){//李四增加金额accountInfoService.updateAccountBalance(3,amount);return

bank2amount;}

dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-web/artifactId/dependencydependencygroupIdcom.baomidou/groupIdartifactIdmybatis-plus-bootstarter/artifactIdversion3.5.1/version/dependencydependencygroupIdmysql/groupIdartifactIdmysql-connectorjava/artifactIdversion5.1.49/version/dependencydependencygroupIdorg.projectlombok/groupIdartifactIdlombok/artifactId/dependencydependencygroupIdcom.alibaba.cloud/groupIdartifactIdspring-cloud-starteralibaba-nacos-discovery/artifactId/dependency!--

openfeign

--dependencygroupIdorg.springframework.cloud/groupIdartifactIdspring-cloud-starteropenfeign/artifactId/dependencydependency

groupIdorg.springframework.cloud/groupIdartifactIdspring-cloud-starterloadbalancer/artifactId/dependency

编写主启动类

{SpringApplication.run(SeataBank1Main6001.class,args);log.info(**************

SeataBank1Main6001

seata-bank1cloud:nacos:discovery:#

Nacos

192.168.66.101:8848datasource:url:

jdbc:mysql://localhost:3306/bank1?

useUnicodetruecharacterEncodingutf-

8useSSLtrueserverTimezoneUTCusername:

rootpassword:

id;//户主姓名TableField(account_name)private

String

accountName;//银行卡号TableField(account_no)private

String

accountNo;//账户密码TableField(account_password)private

String

accountPassword;//账户余额TableField(account_balance)private

Double

{//远程调用李四的微服务GetMapping(/bank2/transfer)String

Double

accountMapper;AutowiredBank2Client

void

(accountInfo.getAccountBalance()

amount){//扣减张三的金额accountInfo.setAccountBalance(accountInfo.getAccountBalance()-amount);int

result

accountMapper.updateById(accountInfo);if

(result!0){//调用李四微服务转账bank2Client.transfer(amount);}}}

}编写控制层

IAccountInfoService;//张三转账GetMapping(/transfer)public

String

amount){IAccountInfoService.updateAccountBalance(1,amount);return

bank1amount;}}