分布式事务解决方案seata架构的安装摆设（AT模式）

1.介绍

seata官网：Seata 是什么？ | Apache Seata
Seata 是一款开源的分布式事务解决方案，致力于提供高性能和简朴易用的分布式事务服务。Seata 将为用户提供了 AT、TCC、SAGA 和 XA 事务模式，为用户打造一站式的分布式解决方案
在Seata的事务管理中有三个紧张的脚色：

• TC (Transaction Coordinator) - 事务协调者：维护全局和分支事务的状态，协调全局事务提交或回滚。
  
• TM (Transaction Manager) - 事务管理器：界说全局事务的范围、开始全局事务、提交或回滚全局事务。
  
• RM (Resource Manager) - 资源管理器：管理分支事务，与TC交谈以注册分支事务和报告分支事务的状态，并驱动分支事务提交或回滚。
  

其中，TM和RM可以理解为Seata的客户端部分，引入到参与事务的微服务依赖中即可。将来TM和RM就会帮忙微服务，实现本地分支事务与TC之间交互，实现事务的提交或回滚。而TC服务则是事务协调中心，是一个独立的微服务，需要单独摆设。

2.摆设TC服务

2.1 导入数据库表

Seata支持多种存储模式，但考虑到持久化的需要，我们一般选择基于数据库存储。因此需要创建一个数据库‘seata’，运行一下sql命令。

1. CREATE DATABASE IF NOT EXISTS `seata`;
2. USE `seata`;
5. CREATE TABLE IF NOT EXISTS `global_table`
6. (
7.     `xid`                       VARCHAR(128) NOT NULL,
8.     `transaction_id`            BIGINT,
9.     `status`                    TINYINT      NOT NULL,
10.     `application_id`            VARCHAR(32),
11.     `transaction_service_group` VARCHAR(32),
12.     `transaction_name`          VARCHAR(128),
13.     `timeout`                   INT,
14.     `begin_time`                BIGINT,
15.     `application_data`          VARCHAR(2000),
16.     `gmt_create`                DATETIME,
17.     `gmt_modified`              DATETIME,
18.     PRIMARY KEY (`xid`),
19.     KEY `idx_status_gmt_modified` (`status` , `gmt_modified`),
20.     KEY `idx_transaction_id` (`transaction_id`)
21. ) ENGINE = InnoDB
22.   DEFAULT CHARSET = utf8mb4;
25. CREATE TABLE IF NOT EXISTS `branch_table`
26. (
27.     `branch_id`         BIGINT       NOT NULL,
28.     `xid`               VARCHAR(128) NOT NULL,
29.     `transaction_id`    BIGINT,
30.     `resource_group_id` VARCHAR(32),
31.     `resource_id`       VARCHAR(256),
32.     `branch_type`       VARCHAR(8),
33.     `status`            TINYINT,
34.     `client_id`         VARCHAR(64),
35.     `application_data`  VARCHAR(2000),
36.     `gmt_create`        DATETIME(6),
37.     `gmt_modified`      DATETIME(6),
38.     PRIMARY KEY (`branch_id`),
39.     KEY `idx_xid` (`xid`)
40. ) ENGINE = InnoDB
41.   DEFAULT CHARSET = utf8mb4;
44. CREATE TABLE IF NOT EXISTS `lock_table`
45. (
46.     `row_key`        VARCHAR(128) NOT NULL,
47.     `xid`            VARCHAR(128),
48.     `transaction_id` BIGINT,
49.     `branch_id`      BIGINT       NOT NULL,
50.     `resource_id`    VARCHAR(256),
51.     `table_name`     VARCHAR(32),
52.     `pk`             VARCHAR(36),
53.     `status`         TINYINT      NOT NULL DEFAULT '0' COMMENT '0:locked ,1:rollbacking',
54.     `gmt_create`     DATETIME,
55.     `gmt_modified`   DATETIME,
56.     PRIMARY KEY (`row_key`),
57.     KEY `idx_status` (`status`),
58.     KEY `idx_branch_id` (`branch_id`),
59.     KEY `idx_xid_and_branch_id` (`xid` , `branch_id`)
60. ) ENGINE = InnoDB
61.   DEFAULT CHARSET = utf8mb4;
63. CREATE TABLE IF NOT EXISTS `distributed_lock`
64. (
65.     `lock_key`       CHAR(20) NOT NULL,
66.     `lock_value`     VARCHAR(20) NOT NULL,
67.     `expire`         BIGINT,
68.     primary key (`lock_key`)
69. ) ENGINE = InnoDB
70.   DEFAULT CHARSET = utf8mb4;
72. INSERT INTO `distributed_lock` (lock_key, lock_value, expire) VALUES ('AsyncCommitting', ' ', 0);
73. INSERT INTO `distributed_lock` (lock_key, lock_value, expire) VALUES ('RetryCommitting', ' ', 0);
74. INSERT INTO `distributed_lock` (lock_key, lock_value, expire) VALUES ('RetryRollbacking', ' ', 0);
75. INSERT INTO `distributed_lock` (lock_key, lock_value, expire) VALUES ('TxTimeoutCheck', ' ', 0);

复制代码

2.2.准备配置文件

创建一个seata文件夹，在该文件夹下创建一个application.yml文件，写入配置信息，例：

1. server:
2.   port: 7099
4. spring:
5.   application:
6.     name: seata-server
8. logging:
9.   config: classpath:logback-spring.xml
10.   file:
11.     path: ${user.home}/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. seata:
20.   config:
21.     # support: nacos 、 consul 、 apollo 、 zk  、 etcd3
22.     type: file
23.     nacos:
24.       server-addr: 127.0.0.1:8848
25.       namespace:
26.       group: SEATA_GROUP
27.       username:
28.       password:
29.       data-id: seataServer.properties
30.     consul:
31.       server-addr: 127.0.0.1:8500
32.       acl-token:
33.       key: seata.properties
34.     apollo:
35.       appId: seata-server
36.       apollo-meta: http://192.168.1.204:8801
37.       apollo-config-service: http://192.168.1.204:8080
38.       namespace: application
39.       apollo-access-key-secret:
40.       cluster: seata
41.     zk:
42.       server-addr: 127.0.0.1:2181
43.       session-timeout: 6000
44.       connect-timeout: 2000
45.       username:
46.       password:
47.       node-path: /seata/seata.properties
48.     etcd3:
49.       server-addr: http://localhost:2379
50.       key: seata.properties
51.   registry:
52.     # support: nacos 、 eureka 、 redis 、 zk  、 consul 、 etcd3 、 sofa
53.     type: file
54.     preferred-networks: 30.240.*
55.     nacos:
56.       application: seata-server
57.       server-addr: 127.0.0.1:8848
58.       group: SEATA_GROUP
59.       namespace:
60.       cluster: default
61.       username:
62.       password:
63.     eureka:
64.       service-url: http://localhost:8761/eureka
65.       application: default
66.       weight: 1
67.     redis:
68.       server-addr: localhost:6379
69.       db: 0
70.       password:
71.       cluster: default
72.       timeout: 0
73.     zk:
74.       cluster: default
75.       server-addr: 127.0.0.1:2181
76.       session-timeout: 6000
77.       connect-timeout: 2000
78.       username: ""
79.       password: ""
80.     consul:
81.       cluster: default
82.       server-addr: 127.0.0.1:8500
83.       acl-token:
84.     etcd3:
85.       cluster: default
86.       server-addr: http://localhost:2379
87.     sofa:
88.       server-addr: 127.0.0.1:9603
89.       application: default
90.       region: DEFAULT_ZONE
91.       datacenter: DefaultDataCenter
92.       cluster: default
93.       group: SEATA_GROUP
94.       address-wait-time: 3000
96.   server:
97.     service-port: 8091 #If not configured, the default is '${server.port} + 1000'
98.     max-commit-retry-timeout: -1
99.     max-rollback-retry-timeout: -1
100.     rollback-retry-timeout-unlock-enable: false
101.     enableCheckAuth: true
102.     retryDeadThreshold: 130000
103.     recovery:
104.       committing-retry-period: 1000
105.       asyn-committing-retry-period: 1000
106.       rollbacking-retry-period: 1000
107.       timeout-retry-period: 1000
108.     undo:
109.       log-save-days: 7
110.       log-delete-period: 86400000
111.   store:
112.     # support: file 、 db 、 redis
113.     mode: file
114.     session:
115.       mode: file
116.     lock:
117.       mode: file
118.     file:
119.       dir: sessionStore
120.       max-branch-session-size: 16384
121.       max-global-session-size: 512
122.       file-write-buffer-cache-size: 16384
123.       session-reload-read-size: 100
124.       flush-disk-mode: async
125.     db:
126.       datasource: druid
127.       db-type: mysql
128.       driver-class-name: com.mysql.jdbc.Driver
129.       url: jdbc:mysql://127.0.0.1:3306/seata?rewriteBatchedStatements=true
130.       user: mysql
131.       password: mysql
132.       min-conn: 5
133.       max-conn: 100
134.       global-table: global_table
135.       branch-table: branch_table
136.       lock-table: lock_table
137.       distributed-lock-table: distributed_lock
138.       query-limit: 100
139.       max-wait: 5000
140.     redis:
141.       mode: single
142.       database: 0
143.       min-conn: 1
144.       max-conn: 10
145.       password:
146.       max-total: 100
147.       query-limit: 100
148.       single:
149.         host: 127.0.0.1
150.         port: 6379
151.       sentinel:
152.         master-name:
153.         sentinel-hosts:
154.   metrics:
155.     enabled: false
156.     registry-type: compact
157.     exporter-list: prometheus
158.     exporter-prometheus-port: 9898

复制代码

本身更改端口号、nacos地址和数据库地址、暗码即可。将整个seata文件夹拷贝到假造机的/root目次
2.3 Docker摆设

需要注意，要确保nacos、mysql都在同一个Docker网络中。如果某个容器不在Docker网络，可以参考下面的命令将某容器加入指定网络：

1. docker network connect [网络名] [容器名]

复制代码

可以使用以下命令检查某个容器在哪个网络，

1. docker inspect [容器名]

复制代码

例如：我使用 docker inspect mysql ，，可以看到该容器在“elk”网络中

在假造机的/root目次执行下面的命令：,将Docker网络和上面配置信息的ip地址改成本身对应的

1. docker run --name seata \
2. -p 8099:8099 \
3. -p 7099:7099 \
4. -e SEATA_IP=172.0.0.1 \
5. -v ./seata:/seata-server/resources \
6. --privileged=true \
7. --network elk \
8. -d \
9. seataio/seata-server:1.5.2

复制代码

安装完成后可以通过欣赏器访问127.0.0.1:1099 进入seata界面，初次登录账号暗码都是admin

进入后可以看到事务的信息和一些锁的信息：

3.微服务集成Seata

3.1 引入依赖

为了方便各个微服务集成seata，我们需要把seata配置共享到nacos，因此模块不仅仅要引入seata依赖，还要引入nacos依赖:

1. <!--统一配置管理-->
2.   <dependency>
3.       <groupId>com.alibaba.cloud</groupId>
4.       <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
5.   </dependency>
6.   <!--读取bootstrap文件-->
7.   <dependency>
8.       <groupId>org.springframework.cloud</groupId>
9.       <artifactId>spring-cloud-starter-bootstrap</artifactId>
10.   </dependency>
11.   <!--seata-->
12.   <dependency>
13.       <groupId>com.alibaba.cloud</groupId>
14.       <artifactId>spring-cloud-starter-alibaba-seata</artifactId>
15.   </dependency>

复制代码

3.2 改造配置

在nacos上添加一个共享的seata配置，命名为shared-seata.yaml
将nacos ip地址改成本身的

1. seata:
2.   registry: # TC服务注册中心的配置，微服务根据这些信息去注册中心获取tc服务地址
3.     type: nacos # 注册中心类型 nacos
4.     nacos:
5.       server-addr: 127.0.0.1:8848 # nacos地址 ,ip改成自己服务器地址
6.       namespace: "" # namespace，默认为空
7.       group: DEFAULT_GROUP # 分组，默认是DEFAULT_GROUP
8.       application: seata-server # seata服务名称
9.       username: nacos
10.       password: nacos
11.   tx-service-group: hmall # 事务组名称
12.   service:
13.     vgroup-mapping: # 事务组与tc集群的映射关系
14.       hmall: "default"

复制代码

然后，改造模块，添加bootstrap.yaml

1. spring:
2.   application:
3.     name: trade-service # 服务名称
4.   profiles:
5.     active: dev
6.   cloud:
7.     nacos:
8.       server-addr: 172.0.0.1:8848 # nacos地址
9.       config:
10.         file-extension: yaml # 文件后缀名
11.         shared-configs: # 共享配置
12.           - dataId: shared-jdbc.yaml # 共享mybatis配置
13.           - dataId: shared-log.yaml # 共享日志配置
14.           - dataId: shared-swagger.yaml # 共享日志配置
15.           - dataId: shared-seata.yaml # 共享seata配置

复制代码

再改造application.yaml文件，将重复的部分删掉
3.3添加数据库

在涉及分布式事务的微服务的数据库中运行下面sql语句=>创建undo_log表格

1. -- for AT mode you must to init this sql for you business database. the seata server not need it.
2. CREATE TABLE IF NOT EXISTS `undo_log`
3. (
4.     `branch_id`     BIGINT       NOT NULL COMMENT 'branch transaction id',
5.     `xid`           VARCHAR(128) NOT NULL COMMENT 'global transaction id',
6.     `context`       VARCHAR(128) NOT NULL COMMENT 'undo_log context,such as serialization',
7.     `rollback_info` LONGBLOB     NOT NULL COMMENT 'rollback info',
8.     `log_status`    INT(11)      NOT NULL COMMENT '0:normal status,1:defense status',
9.     `log_created`   DATETIME(6)  NOT NULL COMMENT 'create datetime',
10.     `log_modified`  DATETIME(6)  NOT NULL COMMENT 'modify datetime',
11.     UNIQUE KEY `ux_undo_log` (`xid`, `branch_id`)
12. ) ENGINE = InnoDB
13.   AUTO_INCREMENT = 1
14.   DEFAULT CHARSET = utf8mb4 COMMENT ='AT transaction mode undo table';

复制代码

3.4实现方法：

在涉及分布式事务的业务代码上加上Seata提供的@GlobalTransactional注解即可
   @GlobalTransactional
  在配置文件中指定要采用的分布式事务模式。我们可以在Nacos中的共享shared-seata.yaml配置文件中设置：

1. seata:
2.   data-source-proxy-mode: XA

复制代码

 JDK17运行报错可以见：JDK17运行seata发生报错Error creating bean with name ‘globalTransactionScanner‘的解决方案-CSDN博客

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。