一、前言
分布式事务和分布式锁是两个完全不同的东西。
分布式事务是保障一系列操作要么都成功，要么都失败。就比如转账：A转账100元给B，先从A账户扣除100元，然后从B账户增加100元，假如从A账户里面已经成功扣除了100元，但是增加B账户的钱的过程中发生了服务器故障，导致没有增加成功。这里就需要恢复A账户里面的钱(回滚)。整个转账过程就必须是事务操作。
Seata官网地址：http://seata.io/zh-cn/index.html
Seata提供了AT、TCC、SAGA 和 XA 事务模式，这里是最简单对代码无侵入的AT模式。
二、安装配置
2.1 下载
下载地址：https://github.com/seata/seata/releases
2.2 Nacos配置中心中创建seataServer.properties
Nacos 配置中心中创建seataServer.properties配置文件，然后填入下面内容：
store.mode=db
store.publicKey=
store.db.datasource=druid
store.db.dbType=mysql
store.db.driverClassName=com.mysql.cj.jdbc.Driver
store.db.url=jdbc:mysql://localhost:3306/seata?useUnicode=true&rewriteBatchedStatements=true
store.db.user=root
store.db.password=123456
主要是数据库相关配置
- 注意：Mysql6.0以上用
com.mysql.cj.jdbc.Driver驱动
2.3 修改conf/registry.conf配置文件
修改下载好的seata包下的conf/registry.conf文件，主要就是修改注册中心和配置中心，都是nacos。注意配置参数和上一步一致。
registry {
type = "nacos"
nacos {
application = "seata-server"
serverAddr = "127.0.0.1:8848"
group = "SEATA_GROUP"
namespace = "83e9d384-d49e-4f40-84bf-c25612883dcc"
cluster = "default"
username = "nacos"
password = "nacos"
}
}
config {
type = "nacos"
nacos {
serverAddr = "127.0.0.1:8848"
namespace = "83e9d384-d49e-4f40-84bf-c25612883dcc"
group = "SEATA_GROUP"
username = "nacos"
password = "nacos"
dataId = "seataServer.properties"
}
}
2.4 导入Sql脚本
创建seata数据库，导入sql，生成global_table、branch_table、lock_table三张表。
sql文件地址：https://github.com/seata/seata/blob/develop/script/server/db/mysql.sql
2.5 启动Seata
启动脚本在bin目录下，启动成功后在Nacos服务列表中可以看到已经注册上来的seata-server服务。
2.6 业务数据库创建undo_log表
undo_log 用于记录回滚日志的，这里每一个需要用到分布式事务的数据库都需要创建undo_log表。
sql文件地址 https://github.com/seata/seata/blob/develop/script/client/at/db/mysql.sql
三、代码中使用Seata
3.1 maven依赖
pom.xml添加如下：
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-seata</artifactId>
</dependency>
3.2 application.properties
配置文件中添加如下，主要就是替换test_group。
# seata 相关
seata.tx-service-group=test_group
seata.service.vgroup-mapping.test_group=default
3.3 方法上添加@GlobalTransactional注解
@GlobalTransactional此注解就可以实现事务了，是不是很简单
3.4 示例
这里模拟下单操作，先减商品库存数量，然后创建订单。在创建订单那里int i = 1 / 0;模拟抛出异常，然后触发回滚。
有条件的同学可以在创建订单那里加个断点，可以看到创建订单前数据库商品数量已经成功减少了，创建订单过程中抛出异常触发了回滚，商品数量又恢复了。
ConsumerServiceImpl类
package com.llh.consumer.service.impl;
import com.llh.consumer.service.ConsumerService;
import com.llh.order.api.feign.OrderApi;
import com.llh.product.api.feign.ProductApi;
import io.seata.spring.annotation.GlobalTransactional;
import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
/**
* @author 小虎哥的技术博客
*/
@Service
public class ConsumerServiceImpl implements ConsumerService {
@Resource
private RedissonClient redissonClient;
@Resource
private ProductApi productApi;
@Resource
private OrderApi orderApi;
@Override
@GlobalTransactional
public Boolean buy(Long productId, Integer number) {
RLock lock = redissonClient.getLock("lock_key");
// 加锁
lock.lock();
try {
// 先减商品库存
boolean decreaseResult = productApi.decrease(productId, number);
if (decreaseResult) {
// 商品库存减成功后 创建订单
boolean createResult = orderApi.create(productId, number);
// 释放锁
lock.unlock();
return createResult;
}
} catch (Exception e) {
// 捕获异常，释放锁，否则会阻塞线程导致后续请求无法进入
lock.unlock();
// 再次抛出异常，如果不抛出，事务就无法回滚
throw e;
}
return false;
}
}
package com.llh.order.service.impl;
import cn.hutool.core.lang.Snowflake;
import cn.hutool.core.util.IdUtil;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.llh.order.api.entity.ProductOrder;
import com.llh.order.mapper.OrderMapper;
import com.llh.order.service.OrderService;
import org.springframework.stereotype.Service;
import java.time.LocalDateTime;
/**
* @author 小虎哥的技术博客
*/
@Service
public class OrderServiceImpl extends ServiceImpl<OrderMapper, ProductOrder> implements OrderService {
@Override
public Boolean create(Long productId, Integer number) {
ProductOrder productOrder = new ProductOrder();
// 生成唯一订单id
Snowflake snowflake = IdUtil.getSnowflake(1, 1);
long id = snowflake.nextId();
productOrder.setId(id);
productOrder.setProductId(productId);
productOrder.setNumber(number);
productOrder.setCreateTime(LocalDateTime.now());
// 模拟抛出异常
int i = 1 / 0;
return save(productOrder);
}
}
四、结语
源码地址：https://github.com/tigerleeli/xiaohuge-blog/tree/master/spring-cloud-alibaba-seata
同步微信公众号：小虎哥的技术博客
