分布式事务 —— SpringCloud Alibaba Seata

Seata 简介

传统的单体应用中，业务操作使用同一条连接操作不同的数据表，一旦出现异常就可以整体回滚。随着公司的快速发展、业务需求的变化，单体应用被拆分成微服务应用，原来的单体应用被拆分成多个独立的微服务，分别使用独立的数据源，业务操作需要调用三个服务来完成。此时每个服务内部的数据一致性由本地事务来保证，但是全局的数据一致性问题无法保证。在微服务架构中，一次业务请求需要操作多个数据源或需要进行远程调用，就会产生分布式事务问题。
Seata 是一款开源的分布式事务解决方案，致力于提供高性能和简单易用的分布式事务服务，Seata 为用户提供 AT、TCC、SAGA 和 XA 事务模式，为用户打造一站式的分布式解决方案。AT 模式是 Seata 默认的工作模式，该模式是 XA 协议的演变。
关于分布式事务的知识可以参考：https://zhuanlan.zhihu.com/p/263555694

Seata 服务端

通过 https://github.com/seata/seata/releases 地址下载 Seata 安装包，本文使用的 Seata 版本是 seata-server-1.7.1
解压 seata-server-1.7.1 安装包，修改 conf/application.conf 文件

1. server:
2.   port: 7091
4. spring:
5.   application:
6.     name: seata-server
8. logging:
9.   config: classpath:logback-spring.xml
10.   file:
11.     path: D:\seata-server-1.7.1\logs\seata
12.   extend:
13.     logstash-appender:
14.       destination: 127.0.0.1:4560
15.     kafka-appender:
16.       bootstrap-servers: 127.0.0.1:9092
17.       topic: logback_to_logstash
19. console:
20.   user:
21.     username: seata
22.     password: seata
23. seata:
24.   config:
25.     # 使用nacos作为配置中心,seata将从nacos获取配置
26.     type: nacos
27.     nacos:
28.       server-addr: 127.0.0.1:8848
29.       namespace: 0178e474-2cfb-47c3-bded-da7cfa260f99
30.       group: springcloud-project
31.       data-id: seata-server.properties
32.   registry:
33.     # 使用nacos作为注册中心,seata将自身服务注册到nacos
34.     type: nacos
35.     nacos:
36.       server-addr: 127.0.0.1:8848
37.       namespace: 0178e474-2cfb-47c3-bded-da7cfa260f99
38.       group: springcloud-project
39.       application: seata-server
40.       cluster: default
41.   store:
42.     # 存储模式:
43.     # file模式为单机模式,全局事务会话信息内存中读写并持久化本地文件 rootdata,性能较高
44.     # db模式为高可用模式,全局事务会话信息通过db共享,相应性能会差
45.     # redis模式性能较高,存在事务信息丢失风险,需要提前配置适合当前场景的redis持久化配置
46.     mode: file
47. #  server:
48. #    service-port: 8091 #If not configured, the default is '${server.port} + 1000'
49.   security:
50.     secretKey: SeataSecretKey0c382ef121d778043159209298fd40bf3850a017
51.     tokenValidityInMilliseconds: 1800000
52.     ignore:
53.       urls: /,/**/*.css,/**/*.js,/**/*.html,/**/*.map,/**/*.svg,/**/*.png,/**/*.jpeg,/**/*.ico,/api/v1/auth/login

复制代码

在 Nacos 控制台创建配置文件 seata-server.properties，注意分组和命名空间要与上述配置保持一致
具体配置项是从 script/config-center/config.txt 粘贴修改而来，这里只使用对我们有用的配置，主要是数据库配置信息

1. #Transaction storage configuration, only for the server.
2. store.mode=db
3. store.lock.mode=db
4. store.session.mode=db
6. #These configurations are required if the `store mode` is `db`.
7. store.db.datasource=druid
8. store.db.dbType=mysql
9. store.db.driverClassName=com.mysql.cj.jdbc.Driver
10. store.db.url=jdbc:mysql://127.0.0.1:3306/test_db?useSSL=false&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true&useAffectedRows=true
11. store.db.user=root
12. store.db.password=123
13. store.db.minConn=5
14. store.db.maxConn=30
15. store.db.globalTable=global_table
16. store.db.branchTable=branch_table
17. store.db.distributedLockTable=distributed_lock
18. store.db.queryLimit=100
19. store.db.lockTable=lock_table
20. store.db.maxWait=5000

复制代码

在上面配置的数据库内，执行 script/server/db 目录下的 sql 脚本，创建服务端所需的表
完成以后，即可进入 bin 目录使用脚本启动 Seata

Seata 客户端

为客户端微服务添加依赖

1. <dependency>
2.     <groupId>com.alibaba.cloud</groupId>
3.     <artifactId>spring-cloud-starter-alibaba-seata</artifactId>
4. </dependency>

复制代码

配置文件添加如下配置

1. seata:
2.   enabled: true
3.   tx-service-group: test-seata-group # 自定义事务组名称,需要与下面service.vgroup-mapping中的一个映射保持一致
4.   service:
5.     vgroup-mapping:
6.       test-seata-group: default
7.   registry:
8.     type: nacos
9.     nacos:
10.       server-addr: 127.0.0.1:8847/nacos
11.       namespace: 0178e474-2cfb-47c3-bded-da7cfa260f99
12.       group: springcloud-project
13.       application: seata-server

复制代码

Seata 默认使用 AT 模式，该模式需求每个客户端库内都存在一张 undo_log 表，用于回滚事务时临时记录数据

1. CREATE TABLE `undo_log` (
2.   `id` bigint(20) NOT NULL AUTO_INCREMENT,
3.   `branch_id` bigint(20) NOT NULL,
4.   `xid` varchar(100) NOT NULL,
5.   `context` varchar(128) NOT NULL,
6.   `rollback_info` longblob NOT NULL,
7.   `log_status` int(11) NOT NULL,
8.   `log_created` datetime NOT NULL,
9.   `log_modified` datetime NOT NULL,
10.   `ext` varchar(100) DEFAULT NULL,
11.   PRIMARY KEY (`id`),
12.   UNIQUE KEY `ux_undo_log` (`xid`,`branch_id`)
13. ) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;

复制代码

在需要使用分布式事务的方法上添加注解 @GlobalTransactional，当方法内发生异常时，就可以带动所调用微服务进行回滚

1. @GlobalTransactional
2. public void create(Order order) {
4.     log.info("下单开始");
5.     orderDao.create(order);
6.     log.info("下单结束");
8.     log.info("开始扣减余额");
9.     server02FeignClient.accountIncrUsed(order.getUserId(), order.getMoney());
10.     log.info("扣减余额结束");
12.     log.info("开始扣减库存");
13.     server03FeignClient.storageIncrUsed(order.getProductId(), order.getCount());
14.     log.info("扣减库存结束");
16.     log.info("开始修改订单状态");
17.     orderDao.updateStatus(1, order.getId());
18.     log.info("修改订单状态结束");
19. }

复制代码

配置完成，启动服务，即可开始测试


免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！