一倍踪、前言
分布式事務(wù)和分布式鎖是兩個(gè)完全不同的東西尝蠕。
分布式事務(wù)是保障一系列操作要么都成功海铆，要么都失敗。就比如轉(zhuǎn)賬：A轉(zhuǎn)賬100元給B逗载，先從A賬戶扣除100元哆窿，然后從B賬戶增加100元，假如從A賬戶里面已經(jīng)成功扣除了100元撕贞，但是增加B賬戶的錢的過(guò)程中發(fā)生了服務(wù)器故障更耻，導(dǎo)致沒有增加成功。這里就需要恢復(fù)A賬戶里面的錢(回滾)捏膨。整個(gè)轉(zhuǎn)賬過(guò)程就必須是事務(wù)操作秧均。
Seata官網(wǎng)地址：http://seata.io/zh-cn/index.html
Seata提供了AT、TCC号涯、SAGA 和 XA 事務(wù)模式目胡，這里是最簡(jiǎn)單對(duì)代碼無(wú)侵入的AT模式。
二链快、安裝配置
2.1 下載
下載地址：https://github.com/seata/seata/releases
2.2 Nacos配置中心中創(chuàng)建seataServer.properties
Nacos 配置中心中創(chuàng)建seataServer.properties配置文件誉己，然后填入下面內(nèi)容：
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
主要是數(shù)據(jù)庫(kù)相關(guān)配置
- 注意：Mysql6.0以上用
com.mysql.cj.jdbc.Driver驅(qū)動(dòng)
2.3 修改conf/registry.conf配置文件
修改下載好的seata包下的conf/registry.conf文件，主要就是修改注冊(cè)中心和配置中心域蜗，都是nacos巨双。注意配置參數(shù)和上一步一致。
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 導(dǎo)入Sql腳本
創(chuàng)建seata數(shù)據(jù)庫(kù)霉祸，導(dǎo)入sql筑累，生成global_table、branch_table丝蹭、lock_table三張表慢宗。
sql文件地址：https://github.com/seata/seata/blob/develop/script/server/db/mysql.sql
2.5 啟動(dòng)Seata
啟動(dòng)腳本在bin目錄下，啟動(dòng)成功后在Nacos服務(wù)列表中可以看到已經(jīng)注冊(cè)上來(lái)的seata-server服務(wù)奔穿。
2.6 業(yè)務(wù)數(shù)據(jù)庫(kù)創(chuàng)建undo_log表
undo_log 用于記錄回滾日志的镜沽，這里每一個(gè)需要用到分布式事務(wù)的數(shù)據(jù)庫(kù)都需要?jiǎng)?chuàng)建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 相關(guān)
seata.tx-service-group=test_group
seata.service.vgroup-mapping.test_group=default
3.3 方法上添加@GlobalTransactional注解
@GlobalTransactional此注解就可以實(shí)現(xiàn)事務(wù)了男摧，是不是很簡(jiǎn)單
3.4 示例
這里模擬下單操作宾舅，先減商品庫(kù)存數(shù)量，然后創(chuàng)建訂單彩倚。在創(chuàng)建訂單那里int i = 1 / 0;模擬拋出異常筹我，然后觸發(fā)回滾。
有條件的同學(xué)可以在創(chuàng)建訂單那里加個(gè)斷點(diǎn)帆离，可以看到創(chuàng)建訂單前數(shù)據(jù)庫(kù)商品數(shù)量已經(jīng)成功減少了蔬蕊，創(chuàng)建訂單過(guò)程中拋出異常觸發(fā)了回滾，商品數(shù)量又恢復(fù)了。
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 小虎哥的技術(shù)博客
*/
@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 {
// 先減商品庫(kù)存
boolean decreaseResult = productApi.decrease(productId, number);
if (decreaseResult) {
// 商品庫(kù)存減成功后 創(chuàng)建訂單
boolean createResult = orderApi.create(productId, number);
// 釋放鎖
lock.unlock();
return createResult;
}
} catch (Exception e) {
// 捕獲異常岸夯，釋放鎖麻献，否則會(huì)阻塞線程導(dǎo)致后續(xù)請(qǐng)求無(wú)法進(jìn)入
lock.unlock();
// 再次拋出異常，如果不拋出猜扮，事務(wù)就無(wú)法回滾
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 小虎哥的技術(shù)博客
*/
@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);
}
}
四勉吻、結(jié)語(yǔ)
源碼地址：https://github.com/tigerleeli/xiaohuge-blog/tree/master/spring-cloud-alibaba-seata
同步微信公眾號(hào)：小虎哥的技術(shù)博客
