模拟场景
下载seata
下载地址：https://github.com/seata/seata/releases/v0.9.0/
修改配置文件
将下载得到的压缩包进行解压，进入conf目录，调整下面的配置文件：
registry.conf
registry { type = "nacos" nacos { serverAddr = "localhost" namespace = "public" cluster = "default" } } config { type = "nacos" nacos { serverAddr = "localhost" namespace = "public" cluster = "default" } }
nacos-config.txt
service.vgroup_mapping.service-product=default service.vgroup_mapping.service-order=default
这里的语法为： service.vgroup_mapping.${your-service-gruop}=default ，中间的
${your-service-gruop} 为自己定义的服务组名称， 这里需要我们在程序的配置文件bootstrap.yml中tx-service-group配置, 两个必须保持一致。
初始化seata在nacos的配置
# 初始化seata 的nacos配置 # 注意: 这里要保证nacos是已经正常运行的 cd conf nacos-config.sh 127.0.0.1
执行成功后可以打开Nacos的控制台，在配置列表中，可以看到初始化了很多Group为SEATA_GROUP
的配置。
启动seata服务
cd bin seata-server.bat -p 9000 -m file
启动后在 Nacos 的服务列表下面可以看到一个名为 serverAddr 的服务。
使用Seata实现事务控制
初始化数据表
在我们的数据库中加入一张undo_log表,这是Seata记录事务日志要用到的表
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 = utf8;
添加配置
添加依赖
<dependency> <groupId>com.alibaba.cloud</groupId> <artifactId>spring-cloud-starter-alibaba-seata</artifactId> </dependency> <dependency> <groupId>com.alibaba.cloud</groupId> <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId> </dependency>
定义DataSourceProxyConfig
Seata 是通过代理数据源实现事务分支的，所以需要配置 io.seata.rm.datasource.DataSourceProxy 的
Bean，且是 @Primary默认的数据源，否则事务不会回滚，无法实现分布式事务
@Configuration public class DataSourceProxyConfig { @Bean @ConfigurationProperties(prefix = "spring.datasource") public DruidDataSource druidDataSource() { return new DruidDataSource(); } @Primary @Bean public DataSourceProxy dataSource(DruidDataSource druidDataSource) { return new DataSourceProxy(druidDataSource); } }
registry.conf
在resources下添加Seata的配置文件 registry.conf
registry { type = "nacos" nacos { serverAddr = "localhost" namespace = "public" cluster = "default" } } config { type = "nacos" nacos { serverAddr = "localhost" namespace = "public" cluster = "default" } }
bootstrap.yaml
spring: application: name: service-product cloud: nacos: config: server-addr: localhost:8848 # nacos的服务端地址 namespace: public group: SEATA_GROUP alibaba: seata: tx-service-group: service-product # 这里要跟nacos-config.txt中修改的配置保持一致
@GlobalTransactional
再需要使用分布式全局事务的地方添加@GlobalTransactional注解即可
@GlobalTransactional//全局事务控制 public Order createOrder(Integer pid) { log.info("接收到{}号商品的下单请求,接下来调用商品微服务查询此商品信息", pid); //1 调用商品微服务,查询商品信息 Product product = productService.findByPid(pid); log.info("查询到{}号商品的信息,内容是:{}", pid, JSON.toJSONString(product)); //2 下单(创建订单) Order order = new Order(); order.setUid(1); order.setUsername("测试用户"); order.setPid(pid); order.setPname(product.getPname()); order.setPprice(product.getPprice()); order.setNumber(1); orderDao.save(order); log.info("创建订单成功,订单信息为{}", JSON.toJSONString(order)); //3 扣库存m productService.reduceInventory(pid, order.getNumber()); //4 向mq中投递一个下单成功的消息 rocketMQTemplate.convertAndSend("order-topic", order); return order; }
测试
在扣减库存的方法中模拟异常
@Transactional @Override public void reduceInventory(Integer pid, Integer number) { //查询 Product product = productDao.findById(pid).get(); //省略校验 //内存中扣减 product.setStock(product.getStock() - number); //模拟异常 int i = 1 / 0; //保存 productDao.save(product); }
下单, 如期 出现异常
查看订单和库存, 发现没有生成订单, 库存也没有减少, 全局事务控制住了
