- 我這里是Centos7薯定，第一步先安裝java環(huán)境髓棋；
- 下載steata包，下載地址：seata1.4.2
- 上傳到linux的/software/目錄后解壓
cd /software/
tar -zxvf seata-server-1.4.2.tar.gz
cd /seata/seata-server-1.4.2
4.修改registry.conf文件
registry {
# file 腰根、nacos 扯夭、eureka、redis梦抢、zk般贼、consul、etcd3奥吩、sofa
# 指定注冊(cè)中心為eureka哼蛆，以下只需要配置eureka相關(guān)配置參數(shù)即可
type = "eureka"
nacos {
application = "seata-server"
serverAddr = "127.0.0.1:8848"
group = "SEATA_GROUP"
namespace = ""
cluster = "default"
username = ""
password = ""
}
eureka {
#修改了宿主機(jī)的hosts，將注冊(cè)中心的ip統(tǒng)一為指定域名霞赫，方便維護(hù)
serviceUrl = "http://127.0.0.1:8761/eureka"
#自定義注冊(cè)中心服務(wù)名
application = "SEATA"
weight = "1"
}
redis {
serverAddr = "localhost:6379"
db = 0
password = ""
cluster = "default"
timeout = 0
}
zk {
cluster = "default"
serverAddr = "127.0.0.1:2181"
sessionTimeout = 6000
connectTimeout = 2000
username = ""
password = ""
}
consul {
cluster = "default"
serverAddr = "127.0.0.1:8500"
aclToken = ""
}
etcd3 {
cluster = "default"
serverAddr = "http://localhost:2379"
}
sofa {
serverAddr = "127.0.0.1:9603"
application = "default"
region = "DEFAULT_ZONE"
datacenter = "DefaultDataCenter"
cluster = "default"
group = "SEATA_GROUP"
addressWaitTime = "3000"
}
file {
name = "file.conf"
}
}
config {
# file腮介、nacos 、apollo端衰、zk叠洗、consul、etcd3
type = "file"
nacos {
serverAddr = "127.0.0.1:8848"
namespace = ""
group = "SEATA_GROUP"
username = ""
password = ""
dataId = "seataServer.properties"
}
consul {
serverAddr = "127.0.0.1:8500"
aclToken = ""
}
apollo {
appId = "seata-server"
## apolloConfigService will cover apolloMeta
apolloMeta = "http://192.168.1.204:8801"
apolloConfigService = "http://192.168.1.204:8080"
namespace = "application"
apolloAccesskeySecret = ""
cluster = "seata"
}
zk {
serverAddr = "127.0.0.1:2181"
sessionTimeout = 6000
connectTimeout = 2000
username = ""
password = ""
nodePath = "/seata/seata.properties"
}
etcd3 {
serverAddr = "http://localhost:2379"
}
file {
# 存儲(chǔ)模式的配置
name = "file.conf"
}
}
5.修改file.conf
## transaction log store, only used in seata-server
store {
## store mode: file旅东、db灭抑、redis
# 指定存儲(chǔ)模式為db，集群必須配置為db
mode = "db"
## file store property
file {
## store location dir
dir = "sessionStore"
# branch session size , if exceeded first try compress lockkey, still exceeded throws exceptions
maxBranchSessionSize = 16384
# globe session size , if exceeded throws exceptions
maxGlobalSessionSize = 512
# file buffer size , if exceeded allocate new buffer
fileWriteBufferCacheSize = 16384
# when recover batch read size
sessionReloadReadSize = 100
# async, sync
flushDiskMode = async
}
## database store property
# 第一步創(chuàng)建數(shù)據(jù)表的數(shù)據(jù)庫(kù)配置參數(shù)
db {
## the implement of javax.sql.DataSource, such as DruidDataSource(druid)/BasicDataSource(dbcp)/HikariDataSource(hikari) etc.
datasource = "druid"
## mysql/oracle/postgresql/h2/oceanbase etc.
dbType = "mysql"
driverClassName = "com.mysql.cj.jdbc.Driver"
## if using mysql to store the data, recommend add rewriteBatchedStatements=true in jdbc connection param
url = "jdbc:mysql://xxx:3306/test_seata"
user = "xxx"
password = "xxx"
minConn = 5
maxConn = 100
globalTable = "global_table"
branchTable = "branch_table"
lockTable = "lock_table"
queryLimit = 100
maxWait = 5000
}
## redis store property
redis {
## redis mode: single抵代、sentinel
mode = "single"
## single mode property
single {
host = "127.0.0.1"
port = "6379"
}
## sentinel mode property
sentinel {
masterName = ""
## such as "10.28.235.65:26379,10.28.235.65:26380,10.28.235.65:26381"
sentinelHosts = ""
}
password = ""
database = "0"
minConn = 1
maxConn = 10
maxTotal = 100
queryLimit = 100
}
}
- 啟動(dòng)
#在test_seata數(shù)據(jù)庫(kù)建以下幾張表腾节，建表語(yǔ)句：
drop table if exists `global_table`;
create table `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 AUTO_INCREMENT=1 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci;
drop table if exists `branch_table`;
create table `branch_table` (
`branch_id` bigint not null,
`xid` varchar(128) not null,
`transaction_id` bigint ,
`resource_group_id` varchar(32),
`resource_id` varchar(256) ,
`lock_key` varchar(128) ,
`branch_type` varchar(8) ,
`status` tinyint,
`client_id` varchar(64),
`application_data` varchar(2000),
`gmt_create` datetime,
`gmt_modified` datetime,
primary key (`branch_id`),
key `idx_xid` (`xid`)
)ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci;
drop table if exists `lock_table`;
create table `lock_table` (
`row_key` varchar(128) not null,
`xid` varchar(96),
`transaction_id` long ,
`branch_id` long,
`resource_id` varchar(256) ,
`table_name` varchar(32) ,
`pk` varchar(36) ,
`gmt_create` datetime ,
`gmt_modified` datetime,
primary key(`row_key`)
)ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci;
#后臺(tái)運(yùn)行
nohup ./bin/seata-server.sh -p 8091 -h 127.0.0.1 -m db &> ./logs/seata.log &
#查看日志，看到-Server started即成功，再打開(kāi)eureka是否有注冊(cè)上去
tail -f ./logs/seata.log
- -p 指定啟動(dòng)seata server的端口號(hào)禀倔；
- -h 指定seata server所綁定的主機(jī)榄融；
- -m 事務(wù)日志、事務(wù)執(zhí)行信息存儲(chǔ)的方式救湖，目前支持file（文件方式）愧杯、db（數(shù)據(jù)庫(kù)方式，建表語(yǔ)句請(qǐng)查看步驟6）
- 在項(xiàng)目中使用鞋既，添加依賴(lài)（seata-spring-boot-starter方式力九，可直接在application.yml/application.properties中進(jìn)行配置，但是需要手動(dòng)傳遞XID邑闺；而使用spring-cloud-alibaba-seata跌前，需要在每個(gè)微服務(wù)中添加registry.conf和file.conf文件，這里結(jié)合）：
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-alibaba-seata</artifactId>
<version>2.2.0.RELEASE</version>
</dependency>
<dependency>
<groupId>io.seata</groupId>
<artifactId>seata-spring-boot-starter</artifactId>
<version>1.3.0</version>
</dependency>
- application.yml中添加：
#seata 配置陡舅， 代替file.conf和registry.conf配置
seata:
enabled: true
# 你的服務(wù)名稱(chēng)
application-id: ${spring.application.name}
#自定義group
tx-service-group: test-seata
# 開(kāi)啟數(shù)據(jù)源自動(dòng)代理
enable-auto-data-source-proxy: true
service:
vgroup-mapping:
#這里對(duì)應(yīng)端的file.conf中vgroup_mapping.seata_server_group = "seata-server"
test-seata: SEATA
enable-degrade: false
disable-global-transaction: false
# Eureka配置
registry:
type: eureka
eureka:
service-url: http://127.0.0.1:8761/eureka
9.seata1.1.0以后抵乓，不需要手動(dòng)代理數(shù)據(jù)源，啟動(dòng)類(lèi)上@SpringBootApplication（exclude = DataSourceAutoConfiguration.class)：
自定義數(shù)據(jù)源
-
在你需要使用feign進(jìn)行微服務(wù)間調(diào)到的方法上添加注解@GlobalTransactional
注解 每個(gè)涉及到分布式事務(wù)的微服務(wù)的數(shù)據(jù)庫(kù)都要有一張undo_log日志表靶衍，sql如下：
DROP TABLE IF EXISTS `undo_log`;
CREATE TABLE `undo_log` (
`id` bigint(20) NOT NULL AUTO_INCREMENT,
`branch_id` bigint(20) NOT NULL,
`xid` varchar(100) NOT NULL,
`context` varchar(128) NOT NULL,
`rollback_info` longblob NOT NULL,
`log_status` int(11) NOT NULL,
`log_created` datetime NOT NULL,
`log_modified` datetime NOT NULL,
`ext` varchar(100) DEFAULT NULL,
PRIMARY KEY (`id`),
UNIQUE KEY `ux_undo_log` (`xid`,`branch_id`)
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci;
- 在需要微服務(wù)調(diào)用的微服務(wù)中進(jìn)行以上相同配置（7.8.9.10.12）,除了@GlobalTransactional注解灾炭，之后便可以?huà)伋霎惓？词欠窕貪L成功
-
注：seata集群只需要再以其他端口啟動(dòng)seata文件目錄即可
seata集群
- docker-compose編排部署：
version: "3"
services:
seata-server:
image: seataio/seata-server:1.4.2
container_name: seata-server
hostname: seata-server
networks:
- seata-server
ports:
- "8091:8091"
environment:
#宿主機(jī)ip
- SEATA_PORT=8091
# 指定seata-server的事務(wù)日志存儲(chǔ)方式, 支持db ,file（默認(rèn)）,redis
- STORE_MODE=db
#seata的被發(fā)現(xiàn)地址颅眶，該IP用于向注冊(cè)中心注冊(cè)時(shí)使用（也就是自身的ip）
- SEATA_IP=127.0.0.1
#給予權(quán)限
#- privileged=true
volumes:
- /software/docker/seata/config/registry.conf:/seata-server/resources/registry.conf
- /software/docker/seata/config/file.conf:/seata-server/resources/file.conf
- /software/docker/seata/mysql-connector-java-8.0.16.jar:/seata-server/libs/mysql-connector-java-8.0.16.jar
- /project/docker/seata/logs:/root/logs/seata
- /etc/localtime:/etc/localtime
networks:
seata-server:
driver: bridge
