一、前言
Seata出现前,大部分公司使用的都是TCC或者MQ(RocketMq)等来解决分布式事务的问题,TCC代码编写复杂,每个业务均需要实现三个入口,侵入性强,RocketMQ保证的是最终一致性。
二、环境准备
1、nacos:(这里采用最新版本2.1.1)
下载地址:https://github.com/alibaba/nacos/releases
官方文档:https://nacos.io/zh-cn/docs/what-is-nacos.html
2、seata:(这里采用最新版本1.5.2)
下载地址:https://github.com/seata/seata/releases
官方文档:http://seata.io/zh-cn/docs/overview/what-is-seata.html
3、其它:
redis、maven、mysql等(自行安装)
三、项目搭建(这里仅作本地测试,均采用单机模式)
1、mysql 自行下载、安装,创建数据库seata、nacos、seata-user、seata-order(后面两个是接入seata的微服务的数据库)
2、nacos
①解压压缩包,进入nacos目录
②进入conf目录,拷贝nacos-mysql.sql到数据库nacos初始化
③打开application.properties,找到如下配置,放开注释,修改为本地连接
### If use MySQL as datasource:
spring.datasource.platform=mysql
db.num=1
db.url.0=jdbc:mysql://127.0.0.1:3306/nacos?characterEncoding=utf8&connectTimeout=1000&socketTimeout=3000&autoReconnect=true&useUnicode=true&useSSL=false&serverTimezone=UTC
db.user.0=nacos
db.password.0=nacos
④进入bin目录,执行cmd命令," .\startup.cmd -m standalone",观察到如下日志,无报错,即启动成功
⑤上图标出的即为nacos管理界面的地址,账号密码均为nacos,登录成功
⑥新建命令空间,我这里加的"yhc",大家可以自定义,不过后面seata和server的配置需要对应上,后文也会提到。
⑦新建配置"seata.yml",这个配置可以从seata官网demo中找到,注意只用修改db连接即可。
metrics:
enabled: false
exporterList: prometheus
exporterPrometheusPort: 9898
registryType: compact
server:
maxCommitRetryTimeout: -1
maxRollbackRetryTimeout: -1
recovery:
asynCommittingRetryPeriod: 1000
committingRetryPeriod: 1000
rollbackingRetryPeriod: 1000
timeoutRetryPeriod: 1000
rollbackRetryTimeoutUnlockEnable: false
undo:
logDeletePeriod: 86400000
logSaveDays: 7
store:
db:
branchTable: branch_table
datasource: druid
dbType: mysql
driverClassName: com.mysql.cj.jdbc.Driver
globalTable: global_table
lockTable: lock_table
maxConn: 30
maxWait: 5000
minConn: 5
password: root
queryLimit: 100
url: jdbc:mysql://127.0.0.1:3306/seata?useUnicode=true&rewriteBatchedStatements=true&useSSL=false
user: root
mode: db
transport:
compressor: none
serialization: seata
3、seata
①解压压缩包,进入seata目录
②进入/script/server/db目录,拷贝mysql.sql到数据库seata初始化
③进入/conf目录,修改application.yml配置文件,配置中心和注册中心改为nacos
seata:
config:
# support: nacos, consul, apollo, zk, etcd3
type: nacos
nacos:
server-addr: localhost:8848
namespace: c23f9030-953e-46bb-8c6e-0bf4a8227a8c
group: yhc
username: nacos
password: nacos
data-id: seata.yml
registry:
# support: nacos, eureka, redis, zk, consul, etcd3, sofa
type: nacos
nacos:
application: seata-server
server-addr: localhost:8848
namespace: c23f9030-953e-46bb-8c6e-0bf4a8227a8c
group: yhc
username: nacos
password: nacos
④进入/bin目录,双击执行seata-server.bat启动
⑤打开nacos列表,观察seata服务注册成功
4、服务接入
①引入依赖
<dependency>
<groupId>io.seata</groupId>
<artifactId>seata-spring-boot-starter</artifactId>
<version>1.5.2</version>
</dependency>
②添加seata配置(注意替换nacos配置)
seata:
enabled: true
# Seata 应用编号,默认为 ${spring.application.name}
application-id: ${spring.application.name}
# Seata 事务组编号,用于 TC 集群名
tx-service-group: ${spring.application.name}-group
# 关闭自动代理
enable-auto-data-source-proxy: true
# 服务配置项
service:
# 虚拟组和分组的映射
vgroup-mapping:
seata-user-group: default
registry:
# support: nacos, eureka, redis, zk, consul, etcd3, sofa
type: nacos
nacos:
application: seata-server
server-addr: 127.0.0.1:8848
namespace: 1238c7de-5821-452d-8586-639ccca55768
group: yhc
③在需要事务管理的地方添加seata注解@GlobalTransactional
④在seata-user数据库初始化undo_log表
⑤另一个微服务seata-order也按如上操作配置,源码地址:https://gitee.com/yhc910/seata-demo.git
⑥启动redis服务、seata-user服务、seata-order服务
四、测试
UserServiceImpl类里,修改如下判断值,验证事务回滚。
1、数据正常提交
结果:账户余额减少,交易记录正常保存
2、修改判断值为true,抛出异常
结果:账户不动,无交易记录,说明事务已回滚
3、修改判断值为false,重复操作1
结果:发现id有间隔(注意:我们的业务表的主键id是自增),是因为seata是先将数据插入后,事务回滚做的删除,所以该删除数据的id无记录。
此次接入有比较多的注意点,这里我列下:
1、nacos单机启动命令,需添加 -m standalone 指定模式
2、接入seata的配置,tx-service-group的值与vgroup-mapping需保持一致
3、A服务调用B服务,B服务获取xid为null,是因为xid没被透传,需自定义Feign的RequestInterceptor处理。
String xid = RootContext.getXID();
template.header(RootContext.KEY_XID, xid);
下篇会整合shardingpshere,有兴趣的可以先看看这篇文章:https://www.cnblogs.com/yhc-910/p/16543293.html
手机扫一扫
移动阅读更方便
你可能感兴趣的文章