分布式事务seata详细安装和使用教程
Seata安装Seata 本地化部署直接部署：在RELEASE页面下载相应版本并解压直接启动在 Linux/Mac 下$ sh ./bin/seata-server.sh在 Windows 下bin\seata-server.bat高可用部署：Seata 的高可用依赖于注册中心、配置中心和数据库来实现。使用nacos和redis为例解压seata-server-1.4.2安装包。1、修改regis
Seata安装
Seata 本地化部署
直接部署：
- 在RELEASE页面下载相应版本并解压
- 直接启动
在 Linux/Mac 下
$ sh ./bin/seata-server.sh
在 Windows 下
bin\seata-server.bat
高可用部署：
Seata 的高可用依赖于注册中心、配置中心和数据库来实现。使用nacos和redis为例
解压seata-server-1.4.2安装包。
1、修改registry.conf
修改conf文件夹中registry.conf的注册中心和配置中心配置
需要修改的参数：
serverAddr： nacos的地址， 端口 可不设置，默认8848
namespace：nacos中的命名空间
dataId：nacos中添加的配置文件名称
registry {
# file 、nacos 、eureka、redis、zk、consul、etcd3、sofa
type = "nacos"
nacos {
application = "seata-server"
serverAddr = "127.0.0.1:8848"
group = "SEATA_GROUP"
namespace = "seata"
cluster = "default"
username = ""
password = ""
}
}
config {
# file、nacos 、apollo、zk、consul、etcd3
type = "nacos"
nacos {
serverAddr = "127.0.0.1:8848"
namespace = "seata"
group = "SEATA_GROUP"
username = ""
password = ""
dataId = "seataServer.properties"
}
}
2、Nacos中添加配置文件
- 新增seata命名空间
进入命名空间管理页面，新增命名空间，命名空间ID建议手写，配置文件中会用到。详细配置信息参考下图所示：
- nacos中添加配置文件
进入配置管理-配置列表，切换到新建的命名空间中，点击新建配置，DataId为seataServer.properties 分组为SEATA_GROUP
需要添加到配置中心的以下几个配置(含db与redis,二者选其一 注:redis需seata-server 1.3版本及以上)
service.vgroupMapping.my_tx_group=default
store.mode=redis
-----db-----
store.db.datasource=druid
store.db.dbType=mysql
store.db.driverClassName=com.mysql.jdbc.Driver
store.db.url=jdbc:mysql://127.0.0.1:3306/seata?useUnicode=true
store.db.user=root
store.db.password=root
----redis----
store.redis.host=127.0.0.1
store.redis.port=6379
store.redis.maxConn=10
store.redis.minConn=1
store.redis.database=0
store.redis.password=123456
store.redis.queryLimit=100
----client----
client.undo.logTable=undo_log
- db模式需要在数据库创建
- global_table、branch_table、lock_table表
建表sql资源目录： https://github.com/seata/seata/tree/1.4.0/script/server/db
3、启动
-
windows：bin目录下双击seata-server.bat启动
-
linux：命令行启动 seata-server.sh -h 127.0.0.1 -p 8091
启动参数：
-h: 注册到注册中心的ip
-p: Server rpc 监听端口
-m: 全局事务会话信息存储模式，file、db、redis，优先读取启动参数 (Seata-Server 1.3及以上版本支持redis)
-n: Server node，多个Server时，需区分各自节点，用于生成不同区间的transactionId，以免冲突
-e: 环境配置
Docker部署
拉取1.4.2版本镜像：
docker pull seataio/seata-server:1.4.2
直接部署：
docker run --name seata-server -p 8091:8091 seataio/seata-server:1.4.2
高可用部署：
依赖于注册中心、配置中心和数据库来实现。
存储模式：redis、注册中心：nacos、配置中心：nacos
1、自定义配置文件：
创建registry.conf
registry {
# file 、nacos 、eureka、redis、zk、consul、etcd3、sofa
type = "nacos"
nacos {
application = "seata-server"
serverAddr = "nacos:8848"
group = "SEATA_GROUP"
namespace = "SEATA"
cluster = "default"
username = ""
password = ""
}
}
config {
# file、nacos 、apollo、zk、consul、etcd3
type = "nacos"
nacos {
serverAddr = "nacos:8848"
namespace = "SEATA"
group = "SEATA_GROUP"
username = ""
password = ""
dataId = "seataServer.properties"
}
}
修改nacos的地址，而命名空间、分组、配置文件dataId使用默认即可。
上传 registry.conf 到服务器到自定义路径 如 /opt/seata/config
2、nacos中添加配置文件
- nacos中添加命名 seata
- 添加配置文件seataServer.properties
使用新建的seata命名空间，分组为SEATA_GROUP。
service.vgroupMapping.my_tx_group=default
store.mode=redis
-----db-----
store.db.datasource=druid
store.db.dbType=mysql
store.db.driverClassName=com.mysql.jdbc.Driver
store.db.url=jdbc:mysql://127.0.0.1:3306/seata?useUnicode=true
store.db.user=root
store.db.password=root
----redis----
store.redis.host=redis
store.redis.port=6379
store.redis.maxConn=10
store.redis.minConn=1
store.redis.database=0
store.redis.password=root
store.redis.queryLimit=100
----client----
client.undo.logTable=undo_log
修改redis/db的地址、密码等参数
3、启动seata
自定义配置文件需要通过挂载文件的方式实现，将宿主机上的 registry.conf 和 file.conf 挂载到容器中相应的目录
使用自定义配置文件时必须指定环境变量 SEATA_CONFIG_NAME, 并且值需要以file:开始, 如: file:/root/seata-config/registry
指定seata-server IP 为服务器IP，若服务器外部网络无法穿透服务器访问docker，将seata-server IP指定为服务器IP。该IP用于向注册中心注册时使用, 如nacos等
docker run -d --name seata-server \
-p 8091:8091 \
--link nacos:nacos \
--link redis:redis \
-e SEATA_CONFIG_NAME=file:/root/seata-config/registry \
-e SEATA_IP=192.168.127.48 \
-v /root/seata/config:/root/seata-config \
seataio/seata-server:1.4.2
其中 -e 用于配置环境变量， -v 用于挂载宿主机的目录
容器命令行及查看日志
$ docker exec -it seata-server sh
$ docker logs -f seata-server
分布式事务使用案例
springboot项目配置
微服务环境：添加依赖
<dependency>
<groupId>io.seata</groupId>
<artifactId>seata-spring-boot-starter</artifactId>
<version>最新版</version>
</dependency>
<dependency>
<groupId>com.alibaba.nacos</groupId>
<artifactId>nacos-client</artifactId>
<version>1.2.0及以上版本</version>
</dependency>
项目yml中添加seata配置
seata:
enabled: true
enable-auto-data-source-proxy: false
application-id: ${spring.application.name}
tx-service-group: my_tx_group
service:
vgroup-mapping:
my_tx_group: default
config:
type: nacos
nacos:
server-addr: 127.0.0.1:8848
group: "SEATA_GROUP"
namespace: "seata"
dataId: "seataServer.properties"
username: ""
password: ""
registry:
type: nacos
nacos:
application: seata-server
server-addr: 127.0.0.1:8848
group: "SEATA_GROUP"
namespace: "seata"
username: ""
password: ""
数据库中添加回滚日志表。
- 数据源连接的每个数据库中添加 undo_log 表
CREATE TABLE `sys_seata_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,
PRIMARY KEY (`id`),
UNIQUE KEY `ux_undo_log` (`xid`,`branch_id`)
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;
注意：
-
1、nacos注册中心配置group项,Server和Client端的值需一致。
-
2、使用多数据源需要：
关闭seata的数据源代理 seata.enable-auto-data-source-proxy=false，使用多数据源代理
开启多数据源对seata的支持spring.datasource.dynamic.seata=true
-
3、默认的AT模式需要在数据库中添加回滚日志表"sys_seata_undo_log"
-
4、已支持从一个Nacos dataId中获取所有配置信息,你只需要额外添加一个dataId配置项。此处dataId为seataServer.properties。
注：当client配置了seata.config，client端会优先去nacos读取"seataServer.properties"中的配置参数，在yml配置的service、client等参数不再生效。
故若在yml中修改seata server相关参数，请注释掉seata.config ，再添加配置。
nacos详细参数配置：https://seata.io/zh-cn/docs/user/configurations.html
- 5、seataServer.properties 中service.vgroupMapping.default_tx_group=default
这个配置为事务组名称。其中“default_tx_group”与“default”都可以自定义，但是客户端与服务端的这个配置项必须一致，否则会报错。
客户端配置如下面所示，其中 seata.tx-service-group的值，要与default_tx_group一致；seata.service.vgroup-mapping.default_tx_group的值，要与default一致。
seata:
tx-service-group: default_tx_group
service:
vgroup-mapping:
default_tx_group: default
AT模式使用
在需要发起全局事务的service方法上添加注解 @GlobalTransactional，
使用Fiegn、restTemplate等方式发送请求，提供方只添加@Transactional保证本地事务
Seata全局事务中涉及三个身份
TC 事务协调者，对应seata服务
TM事务管理者，对应base服务中发起全局事务的方法
RM资源管理者，对应工作流服务
注意问题：
- seata通过线程变量 XID 判断TC与RM是否在同一事务下，现支持使用restTemplate与Feign方式发送请求自动携带xid到被调用方，
使用其他方式可将xid放入请求头中，key为"TX_XID"，RM会在请求头中自动获取。若采用其他方式需自行保证xid的传递。
- 被调用方产生异常却没有回滚：
当被调用方RM产生异常时，为了调用方TM可以正确接收到异常状态码，使Feign能抛出异常发起全局事务回滚，RM最好不要添加异常处理去拦截异常。
若RM异常被拦截，需要TM通过Feign返回的自定义的状态码判断被调用方是否产生异常，并手动抛出异常。如下：
ApiResponse apiResponse = feignClientService.clientB();
if(apiResponse.getCode()!= 10000){
throw new RuntimeException(apiResponse.getMsg());
}
- AT模式基于数据库本地事务实现，分布式事务的参与各方，都需要在各自添加回滚日志表（undo_log）。
可修改nacos中seataServer.properties文件client.undo.logTable=表名 自定义回滚日志表名。
使用Demo
服务A调用服务B，作为调用方A添加@GlobalTransaction注解
@Service
public class AService {
@GlobalTransactional
public ApiResponse insertSomething() {
log.info("===================================");
log.info("AService XID: "+ RootContext.getXID());
aMapper.insertSomething(); // A对数据库进行插入操作
ApiResponse apiResponse = feignClientService.clientB(); // 通过Feign 调用服务B
// 若被调用方异常状态码被拦截， 判断自定义状态码手动抛出异常
if(apiResponse.getCode()!= 10000){
throw new RuntimeException(apiResponse.getMsg());
}
// error(); // 放开此注解，抛出异常
return ApiResponse.success();
}
}
B服务作为被调用方，添加@Transactional保证本地事务
@Service
public class BService {
@Transactional
public ApiResponse insertSomething() {
log.info("==========================================");
log.info("XID: "+ RootContext.getXID());
bMapper.insertSomething();
// error(); // 放开此注解，抛出异常。
return ApiResponse.success();
}
}
TCC模式使用
实际上，Seata的AT模式基本上能满足我们使用分布式事务80%的需求，但涉及不支持事务的数据库与中间件（如redis）等的操作，或AT模式暂未支持的数据库（目前AT支持Mysql、Oracle与PostgreSQL）、跨公司服务的调用、跨语言的应用调用或有手动控制整个二阶段提交过程的需求，则需要结合TCC模式。不仅如此，TCC模式还支持与AT模式混合使用。
一、TCC模式的概念
一个分布式的全局事务，整体是两阶段提交Try-[Comfirm/Cancel] 的模型。在Seata中，AT模式与TCC模式事实上都是两阶段提交的具体实现。他们的区别在于：
AT 模式基于支持本地 ACID 事务 的 关系型数据库（目前支持Mysql、Oracle与PostgreSQL）：
一阶段 prepare 行为：在本地事务中，一并提交业务数据更新和相应回滚日志记录。 二阶段 commit 行为：马上成功结束，自动异步批量清理回滚日志。 二阶段 rollback 行为：通过回滚日志，自动生成补偿操作，完成数据回滚。
相应的，TCC 模式，不依赖于底层数据资源的事务支持：
一阶段 prepare 行为：调用 自定义 的 prepare 逻辑。 二阶段 commit 行为：调用 自定义的 commit 逻辑。 二阶段 rollback 行为：调用 自定义的 rollback 逻辑。
所谓 TCC 模式，是指支持把 自定义 的分支事务纳入到全局事务的管理中。
简单点概括，SEATA的TCC模式就是手工的AT模式，它允许你自定义两阶段的处理逻辑而不依赖AT模式的undo_log。
二、前提准备
- 注册中心 nacos
- seata服务端(TC）
本章着重讲TCC模式的实现，项目的搭建看前面文档
三、TM与TCC-RM搭建
3.1 定义TCC接口
由于我们使用的是 SpringCloud + Feign，Feign的调用基于http，因此此处我们使@LocalTCC便可。值得注意的是，@LocalTCC一定需要注解在接口上，此接口可以是寻常的业务接口，只要实现了TCC的两阶段提交对应方法便可，TCC相关注解如下：
-
@LocalTCC适用于SpringCloud+Feign模式下的TCC
-
@TwoPhaseBusinessAction注解prepare方法，其中name为当前tcc方法的bean名称，写方法名便可（全局唯一），commitMethod指向提交方法，rollbackMethod指向事务回滚方法。指定好三个方法之后，seata会根据全局事务的成功或失败，去帮我们自动调用提交方法或者回滚方法。
-
@BusinessActionContextParameter注解可以将参数传递到二阶段（commitMethod/rollbackMethod）的方法。
-
BusinessActionContext便是指TCC事务上下文
@LocalTCC
public interface TccService{
/**
* 定义两阶段提交
* name = 该tcc的bean名称,全局唯一
* commitMethod = commit 为二阶段确认方法
* rollbackMethod = rollback 为二阶段取消方法
* BusinessActionContextParameter注解 传递参数到二阶段中
* @param params -入参
* @return String
*/
@TwoPhaseBusinessAction(name = "prepare", commitMethod = "commit", rollbackMethod = "rollback")
String prepare(
@BusinessActionContextParameter(paramName = "params") Map<String, String> params
);
/**
* 确认方法、可以另命名，但要保证与commitMethod一致
* context可以传递try方法的参数
* @param context 上下文
* @return boolean
*/
@Override
boolean commit(BusinessActionContext context);
/**
* 二阶段取消方法
* @param context 上下文
* @return boolean
*/
@Override
boolean rollback(BusinessActionContext context);
}
3.2 TCC接口的业务实现
在方法prepare中使用@Transational可以直接通过本地事务回滚关系型数据库中的操作，而非关系型数据库等中间件的回滚操作可以交给rollbackMethod方法处理。
使用context.getActionContext(“params”)便可以得到一阶段try中定义的参数，在二阶段对此参数进行业务回滚操作。
注意1：此处亦不可以捕获异常（同理切面处理异常），否则TCC将识别该操作为成功，二阶段直接执行commitMethod。
注意2：TCC模式要开发者自行保证幂等和事务防悬挂
注意3： commit()与rollback()方法返回值必须为true，当返回值不为true或在方法中抛出异常，seata会不断回调commit或rollback方法，直到返回值为true。
public class TccServiceImpl implements TccService {
private static Logger log = LoggerFactory.getLogger(TccServiceImpl.class);
@Autowired
TccDAO tccDAO;
@Override
@Transational
public String prepare(Map<String, String> params) {
log.info("xid = " + RootContext.getXID());
//todo 实际的操作，或操作MQ、redis等
tccDAO.insert(params);
//放开以下注解抛出异常
//throw new RuntimeException("服务tcc测试回滚");
return "success";
}
@Override
public boolean commit(BusinessActionContext context) {
log.info("xid = " + context.getXid() + "提交成功");
//todo 若一阶段资源预留，这里则要提交资源
return true;
}
@Override
public boolean rollback(BusinessActionContext context) {
//todo 这里写中间件、非关系型数据库的回滚操作
System.out.println("please manually rollback this data:" + context.getActionContext("params"));
return true;
}
}
@RestController
@RequestMapping("/at")
public class AtController {
@Autowired
AtService atService;
@PostMapping("/at-insert")
public String insert(@RequestBody Map<String, String> params) {
return atService.insert(params);
}
}
@Override
@DSTransactional
public String insert(Map<String, String> params) {
log.info("------------------> xid = " + RootContext.getXID());
// 调用master分支
atDAO.insert(params);
atDAO.insert(params);
atDAO.insert(params);
atDAO.insert(params);
// 调用slave分支
params.put("name", "B服务测试");
studentMapper.insert(params);
studentMapper.insert(params);
studentMapper.insert(params);
studentMapper.insert(params);
return "success";
}
@Mapper
@DS("master")
public interface AtDAO {
@Insert("insert into service_at (name) value (#{name})")
int insert(Map<String, String> map);
}
@Mapper
@DS("slave")
public interface StudentMapper {
@Insert("insert into student (name) value (#{name})")
int insert(Map<String, String> map);
}
为开发者提供学习成长、分享交流、生态实践、资源工具等服务，帮助开发者快速成长。
更多推荐
1
1- 0
已为社区贡献4条内容
所有评论(0)