首页 > 其他分享> 文章详细

分布式事务具体实现seata

2021-10-12 14:06:10 阅读：214 来源： 互联网

标签：info 事务 seata nacos 订单 ----- order 分布式

1.seata是什么？

seata 是一款开源的分布式事务解决方案，致力于提供高性能和简单易用的分布式事务服务。Seata 将为用户提供了 AT、TCC、SAGA 和 XA 事务模式，为用户打造一站式的分布式解决方案。

2.本文中主要讲解seata的AT事务模式，参考文档，为官方文档，这里不讲解原理，有兴趣自己去看

https://seata.io/zh-cn/docs/overview/what-is-seata.html

3.下载和安装seata

3.1下载地址

https://github.com/seata/seata/releases

3.2按照图片下载对应的版本，我这里下载windows版的

如果是linux，解压命令是ar -xvzf xxx.tar.gz

3.3更改配置文件，解压文件之后可以在seata目录的conf目录下看到两个文件

3.4更改file.conf文件

3. 4.1 更改store里的mode为db

3.4.2更改db里的数据库连接参数，讲下面的用户名和密码更换为自己的用户名和密码

如果数据库是mysql8以上的，按以下方式更改

url更改为

jdbc:mysql://localhost:3306/seata?characterEncoding=utf8&useSSL=false&serverTimezone = GMT

数据库驱动driverClassName 更改为

com.mysql.cj.jdbc.Driver

其次，如果是seata的低版本还要将mysql的驱动包替换

将这个包替换到lib目录下

3.5更改registry.conf配置文件

3.6 1.0以后的版本去到以下网址下载配置文件

https://github.com/seata/seata/tree/develop/script/config-center

下载以下几个配置文件，config.txt，nacos-config.sh，nacos-config.py

其中nacos的点击nacos进去下载

然后更改配置config.txt里的配置，主要是数据库的四项

还有事务分组的配置，其中fsp_tx_group可以随便写，但是在项目中需要填一致

然后修改nacos-config.sh配置，将红圈中的修改为绝对路径，当然是windows下才这样，linux不需要

最后启动nacos，打开git的 Git Bash Here执行sh nacos-config.sh命令，将配置加载进nacos

3.7进入数据库，创建一个seata的数据库，执行以下连接里的sql

https://github.com/seata/seata/tree/develop/script/server/db

会得到以下三张表，走到这里基本上环境算是搭建好了

上一个简单的业务让大家用一下

新建三个工程，分别是订单（seata-order-service2001），仓储（seata-storage-service2002），账户（seata-account-service2003）

导入以下主要的pom依赖

<!--seata-->
<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-seata</artifactId>
    <exclusions>
        <exclusion>
            <artifactId>seata-all</artifactId>
            <groupId>io.seata</groupId>
        </exclusion>
    </exclusions>
</dependency>
<dependency>
    <groupId>io.seata</groupId>
    <artifactId>seata-all</artifactId>
    <version>1.4.1</version>
</dependency>

上面的版本换成自己下载的版本号

将file.conf和registry.conf放入类路径下

修改application.yml文件，在以下位置填上之前配置中填写的分组名称

编写代码，这里dao什么sql我就不贴了，主要看主业务逻辑

在订单创建的业务代码上加上一个注解

@GlobalTransactional(name = "fsp-create-order",rollbackFor = Exception.class)

就可以解决分布式事务问题，代码如下，其中name可填可不填，最好填上唯一标识，方便查找问题

/**
 * 创建订单->调用库存服务扣减库存->调用账户服务扣减账户余额->修改订单状态
 * 简单说：下订单->扣库存->减余额->改状态
 */
@Override
@GlobalTransactional(name = "fsp-create-order",rollbackFor = Exception.class)
public void create(Order order)
{
    log.info("----->开始新建订单");
    //1 新建订单
    orderDao.create(order);

    //2 扣减库存
    log.info("----->订单微服务开始调用库存，做扣减Count");
    storageService.decrease(order.getProductId(),order.getCount());
    log.info("----->订单微服务开始调用库存，做扣减end");

    //3 扣减账户
    log.info("----->订单微服务开始调用账户，做扣减Money");
    accountService.decrease(order.getUserId(),order.getMoney());
    log.info("----->订单微服务开始调用账户，做扣减end");

    //4 修改订单状态，从零到1,1代表已经完成
    log.info("----->修改订单状态开始");
    orderDao.update(order.getUserId(),0);
    log.info("----->修改订单状态结束");

    log.info("----->下订单结束了，O(∩_∩)O哈哈~");

}

库存调用的是接口，我这里用的openFeign

@FeignClient(value = "seata-storage-service")
public interface StorageService
{
    @PostMapping(value = "/storage/decrease")
    CommonResult decrease(@RequestParam("productId") Long productId, @RequestParam("count") Integer count);
}
还有账户的接口

@FeignClient(value = "seata-account-service")
public interface AccountService
{
    @PostMapping(value = "/account/decrease")
    CommonResult decrease(@RequestParam("userId") Long userId, @RequestParam("money") BigDecimal money);
}

调用的其他业务逻辑我就不贴了，到这个程度，大家应该都会写，就是简单的一个项目，@GlobalTransactional注解只需要加在事务发起者上，其他的都不需要加注解

标签：info,事务,seata,nacos,订单,-----,order,分布式
来源： https://blog.csdn.net/weixin_49100429/article/details/120703767

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

分布式事务具体实现seata