springboot + springcloud alibaba seata 配置TCC模式
时间: 2023-10-06 07:12:20 浏览: 189
在 Spring Boot + Spring Cloud Alibaba Seata 中配置 TCC 模式,需要进行以下步骤:
1. 引入 Seata TCC 的依赖:
```xml
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-seata</artifactId>
<version>2.0.3.RELEASE</version>
</dependency>
```
2. 配置 Seata TCC 的相关参数:
```yaml
spring:
application:
name: demo-service # 应用名称
seata:
service:
group: my_test_tx_group # 事务分组名称
vgroup-mapping.my_test_tx_group: default # 分组所在的虚拟组
enable-degrade: false # 是否开启降级模式,默认为 false
use-jdk-proxy: false # 是否使用 JDK 代理,默认为 false
config:
type: nacos # 配置中心类型,可以是 file、nacos、apollo、zk
nacos:
namespace: seata # 命名空间
server-addr: localhost:8848 # Nacos 服务地址
group: SEATA_GROUP # 配置组
username: nacos # 用户名
password: nacos # 密码
file:
name: file.conf # 配置文件名
registry:
type: nacos # 注册中心类型,可以是 file、nacos、eureka、consul、zk
nacos:
server-addr: localhost:8848 # Nacos 服务地址
namespace: seata # 命名空间
group: SEATA_GROUP # 注册组
username: nacos # 用户名
password: nacos # 密码
tx-service-group: my_test_tx_group # 事务分组名称
```
3. 在需要使用 TCC 模式的方法上使用 @Tcc 注解:
```java
@Service
public class DemoServiceImpl implements DemoService {
@Autowired
private AccountService accountService;
@Autowired
private StorageService storageService;
/**
* TCC 模式下的分布式事务实现
*/
@Override
@GlobalTransactional(timeoutMills = 300000, name = "demo-service-tx")
public void tccTransaction(String userId, String commodityCode, Integer count) {
// 第一步:减少库存
storageService.decrease(commodityCode, count);
// 第二步:扣除账户余额
accountService.decrease(userId, count);
// 第三步:确认(提交)
// do nothing
// 第四步:取消(回滚)
// do nothing
}
}
```
4. 在 Seata 控制台中配置相应的 TCC 事务分组。
以上就是在 Spring Boot + Spring Cloud Alibaba Seata 中配置 TCC 模式的步骤。
阅读全文