企业🤖AI智能体构建引擎,智能编排和调试,一键部署,支持私有化部署方案 广告
步骤如下: **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`开启分布式事务后,发生异常对数据库没有任何影响。