SpringCloudAlibaba 之初识 Seata

前言

上一篇我们搭建好了seata的服务端，本篇来使用一下Seata处理微服务下的分布式事务。我们准备先准备两个工程一个 seata_order 和seata_storage 下面我就贴一下引用的maven注意所有的Alibaba的maven 版本是 2.2.3.RELEASE

开始整合

先给两个库中添加表结构

##这是库存服务的表 DROP TABLE IF EXISTS `storage_tbl`; 
CREATE TABLE `storage_tbl` ( `id` int(11) NOT NULL AUTO_INCREMENT, `commodity_code` varchar(255) DEFAULT NULL, `count` int(11) DEFAULT 0, PRIMARY KEY (`id`),
UNIQUE KEY (`commodity_code`) ) 
ENGINE=InnoDB DEFAULT CHARSET=utf8; ## 这是订单服务表 DROP TABLE IF EXISTS `order_tbl`;
CREATE TABLE `order_tbl` ( `id` int(11) NOT NULL AUTO_INCREMENT, `user_id` varchar(255) DEFAULT NULL, `commodity_code` varchar(255) DEFAULT NULL, `count` int(11) DEFAULT 0, `money` int(11) DEFAULT 0, PRIMARY KEY (`id`) )
ENGINE=InnoDB DEFAULT CHARSET=utf8; ## 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;

下面我贴一下maven的依赖

<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> <version>2.3.2.RELEASE</version> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> <dependency> <groupId>com.baomidou</groupId> <artifactId>mybatis-plus-boot-starter</artifactId> </dependency> <dependency> <groupId>org.projectlombok</groupId> <artifactId>lombok</artifactId> </dependency> <dependency> <!-- 连接池--> <groupId>com.alibaba</groupId> <artifactId>druid</artifactId> </dependency> <dependency> <!-- 远程调用 --> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-openfeign</artifactId> </dependency> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <version>8.0.17</version> </dependency> <dependency> <!-- nacos 注册中心--> <groupId>com.alibaba.cloud</groupId> <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId> </dependency> <dependency> <!--配置中心 读取seata 配置--> <groupId>com.alibaba.cloud</groupId> <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId> </dependency> <dependency> <!-- seata的依赖--> <groupId>com.alibaba.cloud</groupId> <artifactId>spring-cloud-starter-alibaba-seata</artifactId> </dependency>

下面我们来看看yml 文件中的配置，主要是配置一个seata 的通信地址和seata的事务分组，因为我们的seata-serve已经注册到了nacos中

maven 依赖

spring: datasource: username: root password: root url: jdbc:mysql://192.168.1.7:3306/seata_order?autoReconnect=true&useUnicode=true&nullCatalogMeansCurrent=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai
    driver-class-name: com.mysql.cj.jdbc.Driver type: com.alibaba.druid.pool.DruidDataSource initialSize: 5 minIdle: 5 maxActive: 20 # 配置获取连接等待超时的时间 maxWait: 60000 #上面都是数据库的链接信息没什么好说的 cloud: nacos: discovery: #注册服务到nacos中去 server-addr: 192.168.1.7:8848 alibaba: seata:#设置事务分支 默认就是 my_test_tx_group tx-service-group: my_test_tx_group application: name: bugvip-order #mybatis mybatis-plus: mapper-locations: classpath*:/mapper/***Mapper.xml
  map-underscore-to-camel-case: true global-config: #数据库相关配置 db-config: #主键类型  AUTO:"数据库ID自增", INPUT:"用户输入ID", ID_WORKER:"全局唯一ID (数字类型唯一ID)", UUID:"全局唯一ID UUID"; id-type: AUTO configuration: log-impl: org.apache.ibatis.logging.stdout.StdOutImpl seata: #设置seata的通讯地址 去nacos 找 seata服务端 TC的地址 registry: type: nacos nacos: server-addr: 192.168.1.7:8848 username: nacos password: nacos application: seata-server #服务name要和nacos中保持一致 默认就是seata-server

下面我们看看业务中是怎么使用seata（没错很简单就是一个注解 @GlobalTransactional）远程调用那些我们这里就不多说了

@GlobalTransactional @Override public void insert(Order order) { //在order服务中添加订单信息 orderMapper.insert(order); //远程待用库存服务进行库存扣减 stockService.reduct(1); //我们手动抛出一个异常看看能不能将order中的订单信息回滚 int i =10/0;
}