SpringBoot+Dubbo+Seata分布式事务实战详解

CREATE TABLE `t_order` (
 `id` int(11) NOT NULL AUTO_INCREMENT,
 `order_no` varchar(255) DEFAULT NULL,
 `user_id` varchar(255) DEFAULT NULL,
 `commodity_code` varchar(255) DEFAULT NULL,
 `count` int(11) DEFAULT '0',
 `amount` double(14,2) DEFAULT '0.00',
 PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=38 DEFAULT CHARSET=utf8;

CREATE TABLE `t_storage` (
 `id` int(11) NOT NULL AUTO_INCREMENT,
 `commodity_code` varchar(255) DEFAULT NULL,
 `name` varchar(255) DEFAULT NULL,
 `count` int(11) DEFAULT '0',
 PRIMARY KEY (`id`),
 UNIQUE KEY `commodity_code` (`commodity_code`)
) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8;
另外还需要一个回滚日志表：
CREATE TABLE `undo_log` (
 `id` bigint(20) NOT NULL AUTO_INCREMENT,
 `branch_id` bigint(20) NOT NULL,
 `xid` varchar(100) 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,
 `context` varchar(100) DEFAULT NULL,
 PRIMARY KEY (`id`),
 UNIQUE KEY `ux_undo_log` (`xid`,`branch_id`)
) ENGINE=InnoDB AUTO_INCREMENT=67 DEFAULT CHARSET=utf8;

<dependency>
 <groupId>org.apache.dubbo</groupId>
 <artifactId>dubbo</artifactId>
 <version>2.7.1</version>
</dependency>
<dependency>
 <groupId>org.apache.dubbo</groupId>
 <artifactId>dubbo-spring-boot-starter</artifactId>
 <version>2.7.1</version>
</dependency>
Dubbo的服务要注册到Zookeeper，引入curator客户端。
<dependency>
 <groupId>org.apache.curator</groupId>
 <artifactId>curator-framework</artifactId>
 <version>2.13.0</version>
</dependency>
<dependency>
 <groupId>org.apache.curator</groupId>
 <artifactId>curator-recipes</artifactId>
 <version>2.13.0</version>
</dependency>

<dependency>
 <groupId>io.seata</groupId>
 <artifactId>seata-all</artifactId>
 <version>0.6.1</version>
</dependency>

server.port=8011

spring.datasource.url=jdbc:mysql://127.0.0.1:3306/seata
spring.datasource.username=root
spring.datasource.password=root

dubbo.application.name=order-service
dubbo.registry.address=zookeeper://127.0.0.1:2181
dubbo.protocol.name=dubbo
dubbo.protocol.port=20881
dubbo.consumer.timeout=9999999
dubbo.consumer.check=false

@Bean
public DataSourceProxy dataSourceProxy(DataSource dataSource) {
 return new DataSourceProxy(dataSource);
}

@Bean
public GlobalTransactionScanner globalTransactionScanner() {
 return new GlobalTransactionScanner("springboot-order", "my_test_tx_group");
}

registry {
 type = "file"
 file {
  name = "file.conf"
 }
}
config {
 # file、nacos 、apollo、zk、consul
 type = "file"
 file {
  name = "file.conf"
 }
}

service {
 #vgroup->rgroup
 vgroup_mapping.my_test_tx_group = "default"
 #only support single node
 default.grouplist = "127.0.0.1:8091"
 #degrade current not support
 enableDegrade = false
 #disable
 disable = false
}

<update id="decreaseStorage">
 update t_storage set count = count-${count} where commodity_code = #{commodityCode}
</update>

@GlobalTransactional
public void createOrder(OrderDTO orderDTO) {

 System.out.println("开始全局事务。XID="+RootContext.getXID());
 StorageDTO storageDTO = new StorageDTO();
 storageDTO.setCount(orderDTO.getCount());
 storageDTO.setCommodityCode(orderDTO.getCommodityCode());
 
 //1、扣减库存
 storageDubboService.decreaseStorage(storageDTO);
 
 //2、创建订单
 orderDTO.setId(order_id.incrementAndGet());
 orderDTO.setOrderNo(UUID.randomUUID().toString());
 Order order = new Order();
 BeanUtils.copyProperties(orderDTO,order);
 orderMapper.createOrder(order);

 throw new RuntimeException("分布式事务异常..."+orderDTO.getOrderNo());
}

INSERT INTO table_name VALUES (值1, 值2,....)

INSERT INTO table_name (列1, 列2,...) VALUES (值1, 值2,....)