步骤如下:
**1. 先启动nacos,后启动seata**
**2. 启动三个微服务模块**
![](https://img.kancloud.cn/b0/2c/b02cf0938a548bd58875c98ff5d24332_1189x89.png)
**3. 数据库初始状态**
:-: ![](https://img.kancloud.cn/41/35/4135cbe2b4aba0838faf90d6a46f6527_1257x102.png)
账户余额
![](https://img.kancloud.cn/6e/98/6e98828500e5c341659f8838273c0673_1215x53.png)
订单
![](https://img.kancloud.cn/bc/11/bc116e006c268ef55006cf272e97352d_1380x83.png)
库存
**4. 下订单**
(1)正常下订单。
http://localhost:2001/order/create?userId=1&productId=1&count=10&money=100
:-: ![](https://img.kancloud.cn/d0/74/d0742534ad93017694e688d750a08e26_1377x67.png)
账户余额:被用于了100
![](https://img.kancloud.cn/7b/14/7b141af7fcc3214abd02354e2bc9d1cf_1376x66.png)
订单
![](https://img.kancloud.cn/81/43/81432a6003129ab39cce5216b4ae79f8_1378x81.png)
库存:被用去了10件
(2)异常下订单。
让程序发生异常,而且没有添加全局事务注解`@GlobalTransactional`。在 seata-account-service2003 模块中添加超时异常。
*`com.atguigu.springcloud.alibaba.service.impl.AccountServiceImpl`*
```java
public void decrease(Long userId, BigDecimal money) {
log.info("账户扣除余额开始---");
try {
//openfeign响应时间默认为1s,超过1s就会抛出异常
TimeUnit.SECONDS.sleep(20);
} catch (InterruptedException e) {
e.printStackTrace();
}
accountDao.decrease(userId, money);
log.info("账户扣除余额结束---");
}
```
下订单: [http://localhost:2001/order/create?userId=1&productId=1&count=10&money=100](http://localhost:2001/order/create?userId=1&productId=1&count=10&money=100) ,数据库状态如下。
:-: ![](https://img.kancloud.cn/15/c4/15c45fdd244910bd2f47dd48621a4619_1366x68.png)
账户余额:又被用去了100
![](https://img.kancloud.cn/be/6d/be6dc84219f05c123e328f0c8d01579d_1374x95.png)
订单:新增一条订单,但处于未支付状态
![](https://img.kancloud.cn/74/8d/748d5f8ca3a2a64f5d25321afd2f9b7f_1368x80.png)
库存:又被减少了10件
存在的问题是:订单状态`status=0`为未支付状态,但是你看库存已经被减少,而且已经被扣款。并且由于feign的重试机制,账户余额还有可能被多次扣减。这就是没有添加分布式事务所产生的不合理问题。
(3)添加分布式事务注解`@GlobalTransactional`。
:-: ![](https://img.kancloud.cn/3d/e9/3de9a77402c3817185fb2547d4bf28b0_868x473.png)
分布式事务处理过程
让程序继续发生异常。
* 注解`@GlobalTransactional`添加位置:在入口模块的业务层中。
*`com.atguigu.springcloud.alibaba.service.impl.OrderServiceImpl`*
```java
//属于seata-order-service2001模块
@Service
public class OrderServiceImpl implements OrderService {
...
/**
* name:可选,可以随便定义,但要保证全局唯一
* rollbackFor:可选,指定哪些异常会触发事务
*/
@GlobalTransactional(name = "fsp-create-order", rollbackFor = Exception.class)
@Override
public void create(Order order) {
log.info("-------->开始创建新订单");
orderDao.create(order);
...
}
}
```
下订单: [http://localhost:2001/order/create?userId=1&productId=1&count=10&money=100](http://localhost:2001/order/create?userId=1&productId=1&count=10&money=100) ,经过测试,添加注解`@GlobalTransactional`开启分布式事务后,发生异常对数据库没有任何影响。
- 微服务
- 微服务是什么?
- 微服务架构
- 微服务优缺点
- 微服务技术栈
- 微服务框架对比
- SpringCloud
- SpringCloud是什么
- SpringCloud与SpringBoot对比
- SpringCloud与Dubbo对比
- Rest微服务案例
- 总体介绍
- 父工程构建步骤
- 公共模块构建步骤
- 服务端模块构建步骤
- 消费端模块构建步骤
- Eureka服务注册与发现
- Eureka是什么
- Eureka原理
- Eureka注册服务中心构建
- 向Eureka注册已有微服务
- Eureka的自我保护机制
- Eureka服务发现
- Eureka集群配置
- Eureka与Zookeeper对比
- Ribbon负载均衡
- Ribbon是什么
- Ribbon负载均衡演示
- 构建服务端模块
- 构建消费端模块
- Ribbon核心组件IRule
- 自定义负载均衡策略
- Ribbon均衡策略优先级
- 轮询策略算法
- OpenFeign负载均衡
- OpenFeign是什么
- 负载均衡演示
- 日志打印功能
- 导出功能
- Hystrix断路器
- Hystrix是什么
- 服务熔断
- Hystrix服务端构建
- 服务熔断演示
- 服务熔断类型
- HystrixProperty配置汇总
- 服务降级
- Hystrix客户端构建
- 服务降级演示
- fallbackFactory
- 熔断与降级
- 服务监控
- 网关服务Zuul
- Zuul是什么
- Zuul路由服务构建
- 设置访问映射规则
- Config分布式配置中心
- Config分布式配置中心是什么
- Config服务端与Git通信
- Config客户端获取配置
- Config客户端动态刷新
- Bus消息总线
- Bus消息总线是什么
- Bus消息总线原理
- 广播通知设计思想
- 广播通知演示
- 定点通知演示
- Stream消息驱动
- 为什么要引入Stream
- Stream消息驱动是什么
- Stream设计思想
- Stream流程和注解
- Stream案例演示
- 重复消费问题
- 消息持久化
- Sleuth分布式链路跟踪
- Sleuth是什么
- 搭建链路监控
- SpringCloud Alibaba
- Nacos注册与配置中心
- Nacos是什么
- 安装并运行Nacos
- Nacos注册中心
- 服务端入住Nacos
- 消费端入住Nacos
- Nacos负载均衡演示
- 服务注册中心对比
- Nacos的AP和CP转化
- Nacos配置中心
- 基础配置演示
- Nacos分类配置
- Nacos集群搭建
- Sentinel实现熔断与限流
- Sentinel是什么
- Sentinel环境搭建
- Sentinel监控微服务演示
- Sentinel流控规则
- 流量监控的作用
- 设置流控规则
- Sentinel降级规则
- 熔断降级作用
- 设置降级规则
- Sentinel热点限流
- 什么是热点
- 设置热点限流
- Sentinel系统限流
- @SentinelResource
- @SentinelResource属性
- @SentinelResource限流演示
- @SentinelResource熔断演示
- 规则持久化
- 熔断框架比较
- Seata分布式事务
- 分布式事务问题
- Seata是什么
- Seata分布式事务过程
- Seata环境搭建
- 演示示例
- 业务说明
- 数据库环境准备
- 微服务环境准备
- 测试
- Consul服务注册与发现
- Consul是什么
- Consul能做什么
- 环境搭建
- Windows平台
- 服务端入住Consul
- 消费端入住Consul
- 注册中心对比
- Zookeeper服务注册与发现
- Zookeeper是什么
- 环境搭建
- 服务端入住Zookeeper
- 消费端入住Zookeeper
- 网关服务Gateway
- Gateway是什么
- Gateway能做什么
- Gateway对比Zuul
- 三大核心概念
- Gateway工作流
- 环境搭建
- 网关路由配置方式
- 配置文件配置
- 代码中配置
- 动态路由
- Predicate断言
- 断言是什么
- 常用断言
- Filter过滤器
- 过滤器是什么
- 过滤器种类
- 自定义过滤器