spring cloud整合seata

1. 下载seata-server

1.从 https://github.com/seata/seata/releases,下载服务器软件包，将其解压缩。

2. 建表

全局事务过程中，会涉及3块内容：

全局事务 global_table分支事务 branch_table全局锁 lock_table

-- -------------------------------- The script used when storeMode is 'db' --------------------------------
-- the table to store GlobalSession data
CREATE TABLE IF NOT EXISTS `global_table`
 `xid` VARCHAR(128) NOT NULL,
 `transaction_id` BIGINT,
 `status` TINYINT NOT NULL,
 `application_id` VARCHAR(32),
 `transaction_service_group` VARCHAR(32),
 `transaction_name` VARCHAR(128),
 `timeout` INT,
 `begin_time` BIGINT,
 `application_data` VARCHAR(2000),
 `gmt_create` DATETIME,
 `gmt_modified` DATETIME,
 PRIMARY KEY (`xid`),
 KEY `idx_gmt_modified_status` (`gmt_modified`, `status`),
 KEY `idx_transaction_id` (`transaction_id`)
) ENGINE = InnoDB
 DEFAULT CHARSET = utf8;
-- the table to store BranchSession data
CREATE TABLE IF NOT EXISTS `branch_table`
 `branch_id` BIGINT NOT NULL,
 `xid` VARCHAR(128) NOT NULL,
 `transaction_id` BIGINT,
 `resource_group_id` VARCHAR(32),
 `resource_id` VARCHAR(256),
 `branch_type` VARCHAR(8),
 `status` TINYINT,
 `client_id` VARCHAR(64),
 `application_data` VARCHAR(2000),
 `gmt_create` DATETIME(6),
 `gmt_modified` DATETIME(6),
 PRIMARY KEY (`branch_id`),
 KEY `idx_xid` (`xid`)
) ENGINE = InnoDB
 DEFAULT CHARSET = utf8;
-- the table to store lock data
CREATE TABLE IF NOT EXISTS `lock_table`
 `row_key` VARCHAR(128) NOT NULL,
 `xid` VARCHAR(96),
 `transaction_id` BIGINT,
 `branch_id` BIGINT NOT NULL,
 `resource_id` VARCHAR(256),
 `table_name` VARCHAR(32),
 `pk` VARCHAR(36),
 `gmt_create` DATETIME,
 `gmt_modified` DATETIME,
 PRIMARY KEY (`row_key`),
 KEY `idx_branch_id` (`branch_id`)
) ENGINE = InnoDB
 DEFAULT CHARSET = utf8;

### 3. 修改seata-server配置
#### 3.1 配置registry.conf

//注册中心配置
registry {
# file 、nacos 、eureka、redis、zk、consul、etcd3、sofa
type = "eureka"
eureka {
 serviceUrl = "http://192.xx.xx.xx:8761/eureka"
 application = "fsp_tx" //tc注册时服务名
 weight = "1"
//配置中心配置
config {
# file、nacos 、apollo、zk、consul、etcd3
type = "file"
file {
 name = "file.conf"
}

3.2 配置file.conf

## transaction log store, only used in seata-server
store {
 ## store mode: file、db
 mode = "db"
 ## database store property
 db {
 ## the implement of javax.sql.DataSource, such as DruidDataSource(druid)/BasicDataSource(dbcp) etc.
 datasource = "druid"
 ## mysql/oracle/postgresql/h2/oceanbase etc.
 dbType = "mysql"
 driverClassName = "com.mysql.jdbc.Driver"
 url = "jdbc:mysql://192.168.173.95:3306/seata-server" //tc的数据库,可自定义命名，对应就好
 user = "mysql"
 password = "runlion@123"
 minConn = 5
 maxConn = 30
 globalTable = "global_table"
 branchTable = "branch_table"
 lockTable = "lock_table"
 queryLimit = 100
 maxWait = 5000
}

4. 启动seata-server 注册到eurekalinux

nohup sh seata-server.sh -h xx.xx.xx.xx -p 8091 -m db -n 1 

windows

seata-server.bat

这里是以nohup的方式后台启动，参数可选：

-h: 注册到注册中心的ip
-p: Server rpc 监听端口
-m: 全局事务会话信息存储模式，file、db，优先读取启动参数
-n: Server node，多个Server时，需区分各自节点，用于生成不同区间的transactionId，以免冲突
-e: 多环境配置参考 http://seata.io/en-us/docs/ops/multi-configuration-isolation.html
高可用部署可参考：https://seata.io/zh-cn/docs/ops/deploy-ha.html

5. 服务引入seata依赖

 !--seata-- 
 dependency 
 groupId com.alibaba.cloud /groupId 
 artifactId spring-cloud-starter-alibaba-seata /artifactId 
 version 2.2.0.RELEASE /version 
//如果内嵌最新版本starter，我们不用排除再引入 
 exclusions 
 exclusion 
 groupId io.seata /groupId 
 artifactId seata-spring-boot-starter /artifactId 
 /exclusion 
 /exclusions 
 /dependency 
 dependency 
 groupId io.seata /groupId 
 artifactId seata-spring-boot-starter /artifactId 
 version 1.2.0 /version 
 /dependency 

6. 服务配置文件

# -----------seata--------------
seata:
 enabled: true
 application-id: order-server #服务名
 tx-service-group: default # default是自定义的事务分组名称
 enable-auto-data-source-proxy: true # 启用自动数据源代理
 use-jdk-proxy: false
 # excludes-for-auto-proxying:
 # client:
 # rm:
 # async-commit-buffer-limit: 1000
 # report-retry-count: 5
 # table-meta-check-enable: false
 # report-success-enable: false
 # saga-branch-register-enable: false
 # lock:
 # retry-interval: 10
 # retry-times: 30
 # retry-policy-branch-rollback-on-conflict: true
 # tm:
 # commit-retry-count: 5
 # rollback-retry-count: 5
 # undo:
 # data-validation: true
 # log-serialization: jackson
 # log-table: undo_log
 # log:
 # exceptionRate: 100
 service:
 vgroup-mapping:
 default: seata-server # default是自定义的事务分组名称，fsp_tx是tc注册到注册中心的服务名称
 # grouplist:
 # default: 127.0.0.1:8091 # 仅注册中心为file时使用
 enable-degrade: false # 是否启用降级
 disable-global-transaction: false # 是否禁用全局事务
 # transport:
 # shutdown:
 # wait: 3
 # thread-factory:
 # boss-thread-prefix: NettyBoss
 # worker-thread-prefix: NettyServerNIOWorker
 # server-executor-thread-prefix: NettyServerBizHandler
 # share-boss-worker: false
 # client-selector-thread-prefix: NettyClientSelector
 # client-selector-thread-size: 1
 # client-worker-thread-prefix: NettyClientWorkerThread
 # worker-thread-size: default
 # boss-thread-size: 1
 # type: TCP
 # server: NIO
 # heartbeat: true
 # serialization: seata
 # compressor: none
 # enable-client-batch-send-request: true
 config:
 type: file # 配置中心为file模式
 # consul:
 # server-addr: 127.0.0.1:8500
 # apollo:
 # apollo-meta: http://192.168.1.204:8801
 # app-id: seata-server
 # namespace: application
 # etcd3:
 # server-addr: http://localhost:2379
 # nacos:
 # namespace:
 # serverAddr: localhost
 # group: SEATA_GROUP
 # userName: ""
 # password: ""
 # zk:
 # server-addr: 127.0.0.1:2181
 # session-timeout: 6000
 # connect-timeout: 2000
 # username: ""
 # password: ""
 registry:
 type: eureka # 注册中心为eureka
 eureka:
 weight: 1
 service-url: http://127.0.0.1:50024/eureka # 注册中心地址
# consul:
# server-addr: 127.0.0.1:8500
# etcd3:
# serverAddr: http://localhost:2379
# nacos:
# application: seata-server
# server-addr: localhost
# namespace:
# userName: ""
# password: ""
# redis:
# server-addr: localhost:6379
# db: 0
# password:
# timeout: 0
# sofa:
# server-addr: 127.0.0.1:9603
# region: DEFAULT_ZONE
# datacenter: DefaultDataCenter
# group: SEATA_GROUP
# addressWaitTime: 3000
# application: default
# zk:
# server-addr: 127.0.0.1:2181
# session-timeout: 6000
# connect-timeout: 2000
# username: ""
# password: ""
# -----------seata--------------

7. 使用

@GlobalTransaction 全局事务注解

本文转自网络，原文链接：https://developer.aliyun.com/article/786918
本站部分内容转载于网络，版权归原作者所有，转载之目的在于传播更多优秀技术内容，如有侵权请联系QQ/微信：153890879删除，谢谢！