Spring Alibaba Cloud使用Seata实现分布式事务，Nacos做为配置中心(一)
本文目录:java
- 需求
- 什么是分布式事务
- 分布式事务解决方案
- Seata 是什么?
- 准备工做
- 代码实战演示
- 启动服务功能演示
- Seata 事务分组说明
- Seata 分布式事务原理解释
- 项目源码地址
后端工具和环境node
- IDE:IDEA
- 注册中心:nacos 1.1.3
- Spring Cloud:Greenwich.SR3
- Speing Alibaba Cloud:2.1.1.RELEASE
- Seata:0.9.0
- MybatisPlus:3.2.0
一. 需求
在开发个人开源项目 prex 时,加入工做流,解决工做流用户与当前系统用户同步问题时,涉及到远程调用操做两个数据库所产生的事务问题,好比系统用户在增长用户同步工做流用户时,系统用户添加成功,工做流用户没有添加成功,则形成数据不一致问题,本地事务没法回滚,那么则使用分布式事务解决方案。
开源项目:gitee.com/kaiyuantuan…mysql
二. 什么是分布式事务?
指一次大的操做由不一样的小操做组成的，这些小的操做分布在不一样的服务器上，分布式事务须要保证这些小操做要么所有成功，要么所有失败。从本质上来讲，分布式事务就是为了保证不一样数据库的数据一致性。
通俗一点说就是单体应用被拆分红微服务应用，原来的一个模块被拆分红三个独立的应用，分别使用独立的数据源，业务操做须要调用三个服务来完成。git
三. 分布式事务解决方案
分布式事务做为微服务应用中的大难题，在现有的解决方案中，我的认为 Seata 是目前最轻量的解决方案github
四. Seata 是什么?
Seata 是一款开源的分布式事务解决方案，致力于提供高性能和简单易用的分布式事务服务。Seata 将为用户提供了 AT、TCC、SAGA 和 XA 事务模式，为用户打造一站式的分布式解决方案。redis
AT 模式
前提
- 基于支持本地 ACID 事务的关系型数据库。
- Java 应用，经过 JDBC 访问数据库。
总体机制
两阶段提交协议的演变：spring
- 一阶段：业务数据和回滚日志记录在同一个本地事务中提交，释放本地锁和链接资源。
- 二阶段：
- 提交异步化，很是快速地完成。
- 回滚经过一阶段的回滚日志进行反向补偿。
写隔离
- 一阶段本地事务提交前，须要确保先拿到全局锁 。
- 拿不到 全局锁 ，不能提交本地事务。
- 拿 全局锁 的尝试被限制在必定范围内，超出范围将放弃，并回滚本地事务，释放本地锁。
以一个示例来讲明：
两个全局事务 tx1 和 tx2，分别对 a 表的 m 字段进行更新操做，m 的初始值 1000。sql
tx1 先开始，开启本地事务，拿到本地锁，更新操做 m = 1000 - 100 = 900。本地事务提交前，先拿到该记录的 全局锁 ，本地提交释放本地锁。 tx2 后开始，开启本地事务，拿到本地锁，更新操做 m = 900 - 100 = 800。本地事务提交前，尝试拿该记录的 全局锁 ，tx1 全局提交前，该记录的全局锁被 tx1 持有，tx2 须要重试等待 全局锁 。数据库
tx1 二阶段全局提交，释放 全局锁 。tx2 拿到 全局锁 提交本地事务。后端
若是 tx1 的二阶段全局回滚，则 tx1 须要从新获取该数据的本地锁，进行反向补偿的更新操做，实现分支的回滚。
此时，若是 tx2 仍在等待该数据的 全局锁，同时持有本地锁，则 tx1 的分支回滚会失败。分支的回滚会一直重试，直到 tx2 的 全局锁 等锁超时，放弃 全局锁 并回滚本地事务释放本地锁，tx1 的分支回滚最终成功。
由于整个过程 全局锁 在 tx1 结束前一直是被 tx1 持有的，因此不会发生 脏写 的问题。
读隔离
在数据库本地事务隔离级别 读已提交（Read Committed） 或以上的基础上，Seata（AT 模式）的默认全局隔离级别是 读未提交（Read Uncommitted） 。
若是应用在特定场景下，必须要求全局的 读已提交 ，目前 Seata 的方式是经过 SELECT FOR UPDATE 语句的代理。
SELECT FOR UPDATE 语句的执行会申请 全局锁 ，若是 全局锁 被其余事务持有，则释放本地锁（回滚 SELECT FOR UPDATE 语句的本地执行）并重试。这个过程当中，查询是被 block 住的，直到 全局锁 拿到，即读取的相关数据是 已提交 的，才返回。
出于整体性能上的考虑，Seata 目前的方案并无对全部 SELECT 语句都进行代理，仅针对 FOR UPDATE 的 SELECT 语句。
工做机制
以一个示例来讲明整个 AT 分支的工做过程。
业务表：product
| Field | Type | Key |
|---|---|---|
| id | bigint(20) | PRI |
| name | varchar(100) | |
| since | varchar(100) |
AT 分支事务的业务逻辑：
update product set name = 'GTS' where name = 'TXC';
一阶段
过程：
- 解析 SQL：获得 SQL 的类型（UPDATE），表（product），条件（where name = 'TXC'）等相关的信息。
- 查询前镜像：根据解析获得的条件信息，生成查询语句，定位数据。
select id, name, since from product where name = 'TXC';
复制代码
获得前镜像：
id name since 1 TXC 2014
- 执行业务 SQL：更新这条记录的 name 为 'GTS'。
- 查询后镜像：根据前镜像的结果，经过 主键 定位数据。
select id, name, since from product where id = 1`;
复制代码
获得后镜像：
id name since 1 GTS 2014
- 插入回滚日志：把先后镜像数据以及业务 SQL 相关的信息组成一条回滚日志记录，插入到 UNDO_LOG 表中。
{
"branchId": 641789253,
"undoItems": [{
"afterImage": {
"rows": [{
"fields": [{
"name": "id",
"type": 4,
"value": 1
}, {
"name": "name",
"type": 12,
"value": "GTS"
}, {
"name": "since",
"type": 12,
"value": "2014"
}]
}],
"tableName": "product"
},
"beforeImage": {
"rows": [{
"fields": [{
"name": "id",
"type": 4,
"value": 1
}, {
"name": "name",
"type": 12,
"value": "TXC"
}, {
"name": "since",
"type": 12,
"value": "2014"
}]
}],
"tableName": "product"
},
"sqlType": "UPDATE"
}],
"xid": "xid:xxx"
}
复制代码
- 提交前，向 TC 注册分支：申请 product 表中，主键值等于 1 的记录的 全局锁 。
- 本地事务提交：业务数据的更新和前面步骤中生成的 UNDO LOG 一并提交。
- 将本地事务提交的结果上报给 TC。
二阶段-回滚
- 收到 TC 的分支回滚请求，开启一个本地事务，执行以下操做。
- 经过 XID 和 Branch ID 查找到相应的 UNDO LOG 记录。
- 数据校验：拿 UNDO LOG 中的后镜与当前数据进行比较，若是有不一样，说明数据被当前全局事务以外的动做作了修改。这种状况，4. 须要根据配置策略来作处理，详细的说明在另外的文档中介绍。 根据 UNDO LOG 中的前镜像和业务 SQL 的相关信息生成并执行回滚的语句：
update product set name = 'TXC' where id = 1;
复制代码
- 提交本地事务。并把本地事务的执行结果（即分支事务回滚的结果）上报给 TC。
二阶段-提交
- 收到 TC 的分支提交请求，把请求放入一个异步任务的队列中，立刻返回提交成功的结果给 TC。
- 异步任务阶段的分支提交请求将异步和批量地删除相应 UNDO LOG 记录。
附录
回滚日志表
UNDO_LOG Table：不一样数据库在类型上会略有差异。
以 MySQL 为例：
| Field | Type |
|---|---|
| branch_id | bigint PK |
| xid | varchar(100) |
| context | varchar(128) |
| rollback_info | longblob |
| log_status | tinyint |
| log_created | datetime |
| log_modified | datetime |
-- 注意此处0.7.0+ 增长字段 context
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,
PRIMARY KEY (`id`),
UNIQUE KEY `ux_undo_log` (`xid`,`branch_id`)
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;
复制代码
TCC 模式
回顾总览中的描述：一个分布式的全局事务，总体是 两阶段提交 的模型。全局事务是由若干分支事务组成的，分支事务要知足 两阶段提交 的模型要求，即须要每一个分支事务都具有本身的：
- 一阶段 prepare 行为
- 二阶段 commit 或 rollback 行为
根据两阶段行为模式的不一样，咱们将分支事务划分为 Automatic (Branch) Transaction Mode 和 Manual (Branch) Transaction Mode.
AT 模式（参考连接 TBD）基于 支持本地 ACID 事务 的 关系型数据库：
- 一阶段 prepare 行为：在本地事务中，一并提交业务数据更新和相应回滚日志记录。
- 二阶段 commit 行为：立刻成功结束，自动 异步批量清理回滚日志。
- 二阶段 rollback 行为：经过回滚日志，自动 生成补偿操做，完成数据回滚。
相应的，TCC 模式，不依赖于底层数据资源的事务支持：
- 一阶段 prepare 行为：调用 自定义 的 prepare 逻辑。
- 二阶段 commit 行为：调用 自定义 的 commit 逻辑。
- 二阶段 rollback 行为：调用 自定义 的 rollback 逻辑。 所谓 TCC 模式，是指支持把 自定义 的分支事务归入到全局事务的管理中
Saga 模式
Saga 模式是 SEATA 提供的长事务解决方案，在 Saga 模式中，业务流程中每一个参与者都提交本地事务，当出现某一个参与者失败则补偿前面已经成功的参与者，一阶段正向服务和二阶段补偿服务都由业务开发实现。
理论基础：Hector & Kenneth 发表论⽂ Sagas （1987）
适用场景：
- 业务流程长、业务流程多
- 参与者包含其它公司或遗留系统服务，没法提供 - TCC 模式要求的三个接口
优点：
- 一阶段提交本地事务，无锁，高性能
- 事件驱动架构，参与者可异步执行，高吞吐
- 补偿服务易于实现
缺点：
- 不保证隔离性（应对方案见用户文档）
五. 准备工做
- 这里咱们使用
Nacos做为注册中心，Nacos 的安装及使用能够参考 - 咱们从官网下载
seata-server，这里下载的是 seata-server-0.9.0.zip，下载地址：github.com/seata/seata…
github 地址下载速度很慢,能够在公众号后台回复seata安装包快速获取百度云下载连接 - 下载完成后解压 seata-server 安装包到指定目录
解压完成后咱们获得了几个文件夹
- bin
存放各个系统的 seata server 启动脚本 - conf
存在 seata server 启动时所须要的配置信息、数据库模式下所须要的建表语句 - lib
运行 seata server 所须要的依赖包列表
配置 Seata Server
seata server全部的配置都在 conf 文件夹内，该文件夹内有两个文件咱们必需要详细介绍下。
seata server默认使用 file（文件方式）进行存储事务日志、事务运行信息，咱们能够经过-m db 脚本参数的形式来指定，目前仅支持 file、db 这两种方式。
- file.conf
该文件用于配置存储方式、透传事务信息的 NIO 等信息，默认对应 registry.conf 文件内的 file 方式配置 - registry.conf
seata server 核心配置文件，能够经过该文件配置服务注册方式、配置读取方式。
注册方式目前支持 file 、nacos 、eureka、redis、zk、consul、etcd三、sofa 等方式，默认为 file，对应读取 file.conf 内的注册方式信息。
读取配置信息的方式支持 file、nacos 、apollo、zk、consul、etcd3 等方式，默认为 file，对应读取 file.conf 文件内的配置。
修改 conf 目录下的 file.conf 配置文件，主要修改自定义事务组名称，事务日志存储模式及数据库链接信息
transport {
...省略
}
service {
#vgroup->rgroup
vgroup_mapping.prex_tx_group = "default" #修改事务组名称为：prex_tx_group，和客户端自定义的名称对应
#only support single node
default.grouplist = "127.0.0.1:8091"
#degrade current not support
enableDegrade = false
#disable
disable = false
#unit ms,s,m,h,d represents milliseconds, seconds, minutes, hours, days, default permanent
max.commit.retry.timeout = "-1"
max.rollback.retry.timeout = "-1"
}
## transaction log store
store {
## store mode: file、db
mode = "db" #修改此处将事务信息存储到db数据库中
## database store
db {
## the implement of javax.sql.DataSource, such as DruidDataSource(druid)/BasicDataSource(dbcp) etc.
datasource = "druid"
## mysql/oracle/h2/oceanbase etc.
db-type = "mysql"
driver-class-name = "com.mysql.jdbc.Driver"
url = "jdbc:mysql://localhost:3306/seat" #修改数据库链接地址
user = "root" #修改数据库用户名
password = "root" #修改数据库密码
min-conn = 1
max-conn = 3
global.table = "global_table"
branch.table = "branch_table"
lock-table = "lock_table"
query-limit = 100
}
}
复制代码
说明:
- 存储事务日志可使用 file 文件和 db 数据库两种方式
- 因为咱们使用了 db 模式存储事务日志，因此咱们须要建立一个 seat 数据库，建表 sql 在 seata-server 的/conf/db_store.sql 中
- 修改 conf 目录下的
registry.conf配置文件，指明注册中心为 nacos，及修改 nacos 链接信息便可；
registry {
# file 、nacos 、eureka、redis、zk、consul、etcd三、sofa
type = "nacos"
nacos {
serverAddr = "localhost:8848"
namespace = ""
cluster = "default"
}
... 省略
}
}
复制代码
配置完成后启动 Seata
启动 seata server 的脚本位于 bin 文件内，Linux/Mac 环境使用 seata-server.sh 脚本启动，Windows 环境使用 seata-server.bat 脚本启动。
Linux/Mac启动方式示例以下所示：
nohup sh seata-server.sh -p 8091 -h 127.0.0.1 -m db &> seata.log &
复制代码
经过 nohup 命令让 seata server 在系统后台运行。
脚本参数：
- -p
指定启动 seata server 的端口号。 - -h
指定 seata server 所绑定的主机，这里配置要注意指定的主机 IP 要与业务服务内的配置文件保持一致，如：-h 192.168.1.10，业务服务配置文件内应该配置 192.168.1.10，即便在同一台主机上也要保持一致。 - -m
事务日志、事务执行信息存储的方式，目前支持 file（文件方式）、db（数据库方式，建表语句请查看 config/db_store.sql、config/db_undo_log.sql）
查看启动日志
当咱们看到-Server started 时并未发现其余错误信息，咱们的 seata server 已经启动成功
六. 实战演示
让咱们从一个微服务示例开始 用户购买商品的业务逻辑。整个业务逻辑由 3 个微服务提供支持：
- 仓储服务：对给定的商品扣除仓储数量。
- 订单服务：根据采购需求建立订单。
- 账户服务：从用户账户中扣除余额。
架构图
数据库
建立业务数据库
db-order：存储订单的数据库
db-storage：存储库存的数据库
db-account：存储帐户信息的数据库
order 订单表:
DROP TABLE IF EXISTS `order`;
CREATE TABLE `order` (
`id` int(20) NOT NULL AUTO_INCREMENT COMMENT '主键Id',
`user_id` int(20) DEFAULT NULL COMMENT '用户Id',
`pay_money` decimal(11,0) DEFAULT NULL COMMENT '付款金额',
`product_id` int(20) DEFAULT NULL COMMENT '商品Id',
`status` int(11) DEFAULT NULL COMMENT '状态',
`count` int(11) DEFAULT NULL COMMENT '商品数量',
PRIMARY KEY (`id`) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=latin1 ROW_FORMAT=DYNAMIC COMMENT='订单表';
SET FOREIGN_KEY_CHECKS = 1;
复制代码
product 商品表:
DROP TABLE IF EXISTS `product`;
CREATE TABLE `product` (
`id` int(20) NOT NULL COMMENT '主键',
`product_id` int(11) DEFAULT NULL COMMENT '商品Id',
`price` decimal(11,0) DEFAULT NULL COMMENT '价格',
`count` int(11) DEFAULT NULL COMMENT '库存数量',
PRIMARY KEY (`id`) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=latin1 ROW_FORMAT=DYNAMIC COMMENT='仓储服务';
-- ----------------------------
-- Records of product
-- ----------------------------
BEGIN;
INSERT INTO `product` VALUES (1, 1, 50, 100);
COMMIT;
SET FOREIGN_KEY_CHECKS = 1;
复制代码
account 帐户表:
DROP TABLE IF EXISTS `account`;
CREATE TABLE `account` (
`id` int(20) NOT NULL AUTO_INCREMENT COMMENT '主键Id',
`user_id` int(20) DEFAULT NULL COMMENT '用户Id',
`balance` decimal(11,0) DEFAULT NULL COMMENT '余额',
PRIMARY KEY (`id`) USING BTREE
) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=latin1 ROW_FORMAT=DYNAMIC;
-- ----------------------------
-- Records of account
-- ----------------------------
BEGIN;
INSERT INTO `account` VALUES (1, 1, 100);
COMMIT;
SET FOREIGN_KEY_CHECKS = 1;
复制代码
建立日志回滚表
须要在每一个数据库中建立日志回滚表，建表 sql 在 seata-server 的/conf/db_undo_log.sql 中。
分布式事务问题产生
三个服务，一个订单服务，一个仓储服务，一个帐户服务。当用户下单时，会在订单服务中建立一个订单，而后经过远程调用库存服务来扣减下单商品的库存，再经过远程调用帐户服务来扣减用户帐户里面的余额，最后在订单服务中修改订单状态为已完成。该操做跨越三个数据库，有两次远程调用，很明显会有分布式事务问题
复制代码
工程结构
nacos-seata-account-server 帐户服务
nacos-seata-order-server 订单服务
nacos-seata-storage-server 仓储服务
客户端配置
-
对 nacos-seata-account-server、nacos-seata-order-server 和 nacos-seata-storage-server 三个 seata 的客户端进行配置，它们配置大体相同，咱们下面以 nacos-seata-account-server 的配置为例；
-
修改 application.yml 文件，自定义事务组的名称
spring:
cloud:
alibaba:
seata:
tx-service-group: prex_tx_group #自定义事务组名称须要与seata-server中的对应
复制代码
- 添加并修改 file.conf 配置文件，主要是修改自定义事务组名称
service {
#vgroup->rgroup
vgroup_mapping.prex_tx_group = "default" #修改自定义事务组名称
#only support single node
default.grouplist = "127.0.0.1:8091"
#degrade current not support
enableDegrade = false
#disable
disable = false
#unit ms,s,m,h,d represents milliseconds, seconds, minutes, hours, days, default permanent
max.commit.retry.timeout = "-1"
max.rollback.retry.timeout = "-1"
disableGlobalTransaction = false
}
复制代码
添加并修改 registry.conf 配置文件，主要是将注册中心改成 nacos
registry {
# file 、nacos 、eureka、redis、zk
type = "nacos" #修改成nacos
nacos {
serverAddr = "localhost:8848" #修改成nacos的链接地址
namespace = ""
cluster = "default"
}
}
复制代码
代码只展现核心代码 具体代码文章尾部连接
- 在启动类中取消数据源的自动建立
@EnableDiscoveryClient
@SpringBootApplication(exclude = DataSourceAutoConfiguration.class)
@MapperScan("com.xd.example.seata.mapper")
public class NacosSeataAccountServerApplication {
public static void main(String[] args) {
SpringApplication.run(NacosSeataAccountServerApplication.class, args);
}
}
复制代码
- 配置 MybatisPlus 使用 Seata 对数据源进行代理
MyBatisPlusConfig:
/**
* @Classname MyBatisPlusConfig
* @Description 配置MybatisPlus使用Seata对数据源进行代理
* @Author Created by Lihaodong (alias:小东啊) im.lihaodong@gmail.com
* @Date 2019-11-25 11:21
* @Version 1.0
*/
@Configuration
public class MyBatisPlusConfig {
@Value("${mybatis-plus.mapper-locations}")
private String mapperLocations;
/**
* @param sqlSessionFactory SqlSessionFactory
* @return SqlSessionTemplate
*/
@Bean
public SqlSessionTemplate sqlSessionTemplate(SqlSessionFactory sqlSessionFactory) {
return new SqlSessionTemplate(sqlSessionFactory);
}
/**
* 从配置文件获取属性构造datasource，注意前缀，这里用的是druid，根据本身状况配置,
* 原生datasource前缀取"spring.datasource"
*
* @return
*/
@Bean
@ConfigurationProperties(prefix = "spring.datasource.hikari")
public DataSource hikariDataSource() {
return new HikariDataSource();
}
/**
* 构造datasource代理对象，替换原来的datasource
*
* @param hikariDataSource
* @return
*/
@Primary
@Bean("dataSource")
public DataSourceProxy dataSourceProxy(DataSource hikariDataSource) {
return new DataSourceProxy(hikariDataSource);
}
@Bean(name = "sqlSessionFactory")
public SqlSessionFactory sqlSessionFactoryBean(DataSourceProxy dataSourceProxy) throws Exception {
MybatisSqlSessionFactoryBean bean = new MybatisSqlSessionFactoryBean();
bean.setDataSource(dataSourceProxy);
ResourcePatternResolver resolver = new PathMatchingResourcePatternResolver();
bean.setMapperLocations(resolver.getResources(mapperLocations));
SqlSessionFactory factory = null;
try {
factory = bean.getObject();
} catch (Exception e) {
throw new RuntimeException(e);
}
return factory;
}
/**
* MP 自带分页插件
*
* @return
*/
@Bean
public PaginationInterceptor paginationInterceptor() {
PaginationInterceptor page = new PaginationInterceptor();
page.setDialectType("mysql");
return page;
}
}
复制代码
- 使用@GlobalTransactional 注解开启分布式事务
package com.xd.example.seata.service.impl;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.xd.example.seata.domain.Order;
import com.xd.example.seata.mapper.OrderMapper;
import com.xd.example.seata.service.IOrderService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.xd.example.seata.service.RemoteAccountService;
import com.xd.example.seata.service.RemoteStorageService;
import io.seata.core.context.RootContext;
import io.seata.spring.annotation.GlobalTransactional;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
/**
* <p>
* 订单表 服务实现类
* </p>
*
* @author lihaodong
* @since 2019-11-25
*/
@Slf4j
@Service
public class OrderServiceImpl extends ServiceImpl<OrderMapper, Order> implements IOrderService {
@Autowired
private RemoteStorageService remoteStorageService;
@Autowired
private RemoteAccountService remoteAccountService;
@GlobalTransactional(rollbackFor = Exception.class)
@Override
public void createOrder(Order order) {
log.info("下单开始,用户:{},商品:{},数量:{},金额:{}", order.getUserId(), order.getProductId(), order.getCount(), order.getPayMoney());
//建立订单
order.setStatus(0);
boolean save = save(order);
log.info("保存订单{}", save ? "成功" : "失败");
log.info("当前 XID: {}", RootContext.getXID());
//远程调用库存服务扣减库存
log.info("扣减库存开始");
remoteStorageService.decrease(order.getProductId(), order.getCount());
log.info("扣减库存结束");
//远程调用帐户服务扣减余额
log.info("扣减余额开始");
remoteAccountService.decrease(order.getUserId(), order.getPayMoney());
log.info("扣减余额结束");
//修改订单状态为已完成
log.info("修改订单状态开始");
update(Wrappers.<Order>lambdaUpdate().set(Order::getStatus, 1).eq(Order::getUserId, order.getUserId()));
log.info("修改订单状态结束");
log.info("下单结束");
}
}
复制代码
七. 启动服务功能演示
-
分别运行 nacos-seata-order-server、nacos-seata-storage-server 和 nacos-seata-account-server 三个服务
-
查询数据库初始数据信息
-
打开浏览器/Postman 调用接口进行下单操做:http://localhost:8081/order/create?userId=1&productId=1&count=1&payMoney=50
结果:
仓储服务:
帐户服务:
- 再次数据库查询
- 咱们在 nacos-seata-account-server 中制造一个超时异常后(其余异常也行)，调用下单接口
package com.xd.example.seata.service.impl;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.xd.example.seata.domain.Account;
import com.xd.example.seata.mapper.AccountMapper;
import com.xd.example.seata.service.IAccountService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import io.seata.core.context.RootContext;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import java.math.BigDecimal;
import java.util.Optional;
/**
* <p>
* 服务实现类
* </p>
*
* @author lihaodong
* @since 2019-11-25
*/
@Slf4j
@Service
public class AccountServiceImpl extends ServiceImpl<AccountMapper, Account> implements IAccountService {
@Override
public boolean reduceBalance(Integer userId, BigDecimal balance) throws Exception {
log.info("当前 XID: {}", RootContext.getXID());
checkBalance(userId, balance);
log.info("开始扣减用户 {} 余额", userId);
//模拟超时异常
try {
Thread.sleep(10 * 1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
Integer record = baseMapper.reduceBalance(userId, balance);
log.info("结束扣减用户 {} 余额结果:{}", userId, record > 0 ? "操做成功" : "扣减余额失败");
return record > 0;
}
private void checkBalance(Integer userId, BigDecimal price) throws Exception {
log.info("检查用户 {} 余额", userId);
Optional<Account> account = Optional.ofNullable(baseMapper.selectOne(Wrappers.<Account>lambdaQuery().eq(Account::getUserId, userId)));
if (account.isPresent()) {
BigDecimal balance = account.get().getBalance();
if (balance.compareTo(price) == -1) {
log.warn("用户 {} 余额不足，当前余额:{}", userId, balance);
throw new Exception("余额不足");
}
}
}
}
复制代码
修改完会重启帐户服务,再次发送请求
能够看到订单正常,扣除库存正常,帐户服务读取超时异常
-
发现下单后数据库数据并无任何改变
-
咱们在 seata-order-service 中注释掉@GlobalTransactional 来看看会发生什么
// @GlobalTransactional(name = "prex-create-order",rollbackFor = Exception.class)
@Override
public void createOrder(Order order) {
log.info("当前 XID: {}", RootContext.getXID());
log.info("下单开始,用户:{},商品:{},数量:{},金额:{}", order.getUserId(), order.getProductId(), order.getCount(), order.getPayMoney());
//建立订单
order.setStatus(0);
boolean save = save(order);
log.info("保存订单{}", save ? "成功" : "失败");
... 省略代码
}
复制代码
保存重启订单服务,再次请求接口 因为 nacos-seata-account-server 的超时会致使当库存和帐户金额扣减后订单状态并无设置为已经完成
八. Seata 事务分组
下一篇更新
Seata 分布式事务原理解释
下一篇更新
项目源码地址
参考资料:
seata.io/zh-cn/
相关文章
- 1. Spring Cloud 使用 Seata 实现分布式事务，Nacos 做为 Seata 配置中心
- 2. Spring Alibaba Cloud使用Seata实现分布式事务，Nacos做为配置中心(一)
- 3. Spring Cloud Alibaba Seata + Nacos + Jooq + RestTemplate实现分布式事务
- 4. Spring Cloud Alibaba Nacos做为配置中心
- 5. spring cloud Alibaba : Nacos做为配置中心
- 6. seata分布式事务启用nacos作配置中心
- 7. Spring Cloud Alibaba基础：使用Nacos做为配置中心
- 8. Spring Cloud Alibaba基础教程：使用Nacos做为配置中心
- 9. Spring Cloud Alibaba（2）使用nacos做为配置中心 带源码
- 10. Spring Cloud Alibaba使用Nacos做为配置中心_三
- 更多相关文章...
- • Hibernate事务的配置 - Hibernate教程
- • Spring声明式事务管理（基于XML方式实现） - Spring教程
- • Spring Cloud 微服务实战(三) - 服务注册与发现
- • 常用的分布式事务解决方案
相关标签/搜索
每日一句
-
每一个你不满意的现在，都有一个你没有努力的曾经。
最新文章
- 1. 升级Gradle后报错Gradle‘s dependency cache may be corrupt (this sometimes occurs
- 2. Smarter, Not Harder
- 3. mac-2019-react-native 本地环境搭建(xcode-11.1和android studio3.5.2中Genymotion2.12.1 和VirtualBox-5.2.34 )
- 4. 查看文件中关键字前后几行的内容
- 5. XXE萌新进阶全攻略
- 6. Installation failed due to: ‘Connection refused: connect‘安卓studio端口占用
- 7. zabbix5.0通过agent监控winserve12
- 8. IT行业UI前景、潜力如何？
- 9. Mac Swig 3.0.12 安装
- 10. Windows上FreeRDP-WebConnect是一个开源HTML5代理，它提供对使用RDP的任何Windows服务器和工作站的Web访问
欢迎关注本站公众号,获取更多信息
相关文章
- 1. Spring Cloud 使用 Seata 实现分布式事务，Nacos 做为 Seata 配置中心
- 2. Spring Alibaba Cloud使用Seata实现分布式事务，Nacos做为配置中心(一)
- 3. Spring Cloud Alibaba Seata + Nacos + Jooq + RestTemplate实现分布式事务
- 4. Spring Cloud Alibaba Nacos做为配置中心
- 5. spring cloud Alibaba : Nacos做为配置中心
- 6. seata分布式事务启用nacos作配置中心
- 7. Spring Cloud Alibaba基础：使用Nacos做为配置中心
- 8. Spring Cloud Alibaba基础教程：使用Nacos做为配置中心
- 9. Spring Cloud Alibaba（2）使用nacos做为配置中心 带源码
- 10. Spring Cloud Alibaba使用Nacos做为配置中心_三