Seata分布式事务

1. 分布式事务的问题

单体应用被拆分成微服务应用，原来的三个模块被拆分成三个独立的应用，分别使用三个独立的数据源，业务操作需要调用三个服务来完成。此时每个服务内部的数据一致性由本地事务来保证，但是全局的数据一致性问题没法保证。

一句话：一次业务操作需要跨多个数据源或需要跨多个系统进行远程调用，就会产生分布式事务问题。

2. 分布式事务1 3组件

Transaction ID XID：全局唯一的事务ID

3组件概念：

Transaction Coordinator (TC)：事务协调器，维护全局事务的运行状态，负责协调并驱动全局事务的提交或回滚；协调者

Transaction Manager (TM)：控制全局事务的边界，负责开启一个全局事务，并最终发起全局提交或全局回滚的决议；大事务

Resource Manager (RM)：控制分支事务，负责分支注册、状态汇报，并接收事务协调器的指令，驱动分支（本地）事务的提交和回滚。小事务

 

3. 注解

本地@Transactional

全局@GlobalTransactional

下订单->减库存->扣余额->改(订单)状态

TM：订单；RM：订单，库存，支付

4.代码，

订单服务：

OrderDao

1.  
   package com.atguigu.springcloud.alibaba.dao;
2.  
    
3.  
   import com.atguigu.springcloud.alibaba.domain.Order;
4.  
   import org.apache.ibatis.annotations.Mapper;
5.  
   import org.apache.ibatis.annotations.Param;
6.  
    
7.  
   import javax.naming.Name;
8.  
    
9.  
   /**
10.  
     * @auther zzyy
11.  
     * @create 2019-12-11 16:46
12.  
     */
13.  
    @Mapper
14.  
    public interface OrderDao {
15.  
     
16.  
        /**
17.  
         * 创建订单
18.  
         */
19.  
        void create(Order order);
20.  
     
21.  
        /**
22.  
         * 修改订单金额
23.  
         */
24.  
        void update(@Param("userId") Long userId, @Param("status") Integer status);
25.  
    }
26.  
     
27.  
     
28.  
     

OrderMapper.xml

1.  
   <?xml version="1.0" encoding="UTF-8" ?>
2.  
   <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
3.  
    
4.  
   <mapper namespace="com.atguigu.springcloud.alibaba.dao.OrderDao">
5.  
    
6.  
       <resultMap id="BaseResultMap" type="com.atguigu.springcloud.alibaba.domain.Order">
7.  
           <id column="id" property="id" jdbcType="BIGINT"/>
8.  
           <result column="user_id" property="userId" jdbcType="BIGINT"/>
9.  
           <result column="product_id" property="productId" jdbcType="BIGINT"/>
10.  
            <result column="count" property="count" jdbcType="INTEGER"/>
11.  
            <result column="money" property="money" jdbcType="DECIMAL"/>
12.  
            <result column="status" property="status" jdbcType="INTEGER"/>
13.  
        </resultMap>
14.  
     
15.  
        <insert id="create">
16.  
            INSERT INTO `t_order` (`id`, `user_id`, `product_id`, `count`, `money`, `status`)
17.  
            VALUES (NULL, #{userId}, #{productId}, #{count}, #{money}, 0);
18.  
        </insert>
19.  
     
20.  
        <update id="update">
21.  
            UPDATE `t_order`
22.  
            SET status = 1
23.  
            WHERE user_id = #{userId} AND status = #{status};
24.  
        </update>
25.  
    </mapper>
26.  
     

OrderServiceImpl -> OrderService

1.  
   package com.atguigu.springcloud.alibaba.service.impl;
2.  
    
3.  
   import com.atguigu.springcloud.alibaba.dao.OrderDao;
4.  
   import com.atguigu.springcloud.alibaba.domain.Order;
5.  
   import com.atguigu.springcloud.alibaba.service.AccountService;
6.  
   import com.atguigu.springcloud.alibaba.service.OrderService;
7.  
   import com.atguigu.springcloud.alibaba.service.StorageService;
8.  
   import io.seata.spring.annotation.GlobalTransactional;
9.  
   import lombok.extern.slf4j.Slf4j;
10.  
    import org.springframework.beans.factory.annotation.Autowired;
11.  
    import org.springframework.stereotype.Service;
12.  
    import org.slf4j.Logger;
13.  
    import org.slf4j.LoggerFactory;
14.  
     
15.  
    import javax.annotation.Resource;
16.  
     
17.  
    /**
18.  
     * @auther zzyy
19.  
     * @create 2019-12-11 16:50
20.  
     */
21.  
    @Service
22.  
    @Slf4j
23.  
    public class OrderServiceImpl implements OrderService
24.  
    {
25.  
        @Resource
26.  
        private OrderDao orderDao;
27.  
     
28.  
        @Resource
29.  
        private StorageService storageService;
30.  
     
31.  
        @Resource
32.  
        private AccountService accountService;
33.  
     
34.  
        /**
35.  
         * 创建订单->调用库存服务扣减库存->调用账户服务扣减账户余额->修改订单状态
36.  
         * 简单说：
37.  
         * 下订单->减库存->减余额->改状态
38.  
         */
39.  
        @Override
40.  
        @GlobalTransactional(name = "fsp-create-order",rollbackFor = Exception.class)
41.  
        public void create(Order order) {
42.  
            log.info("------->下单开始");
43.  
            //本应用创建订单
44.  
            orderDao.create(order);
45.  
     
46.  
            //远程调用库存服务扣减库存
47.  
            log.info("------->order-service中扣减库存开始");
48.  
            storageService.decrease(order.getProductId(),order.getCount());
49.  
            log.info("------->order-service中扣减库存结束");
50.  
     
51.  
            //远程调用账户服务扣减余额
52.  
            log.info("------->order-service中扣减余额开始");
53.  
            accountService.decrease(order.getUserId(),order.getMoney());
54.  
            log.info("------->order-service中扣减余额结束");
55.  
     
56.  
            //修改订单状态为已完成
57.  
            log.info("------->order-service中修改订单状态开始");
58.  
            orderDao.update(order.getUserId(),0);
59.  
            log.info("------->order-service中修改订单状态结束");
60.  
     
61.  
            log.info("------->下单结束");
62.  
        }
63.  
    }
64.  
     
65.  
     
66.  
     

OrderController

1.  
   package com.atguigu.springcloud.alibaba.controller;
2.  
    
3.  
   import com.atguigu.springcloud.alibaba.domain.CommonResult;
4.  
   import com.atguigu.springcloud.alibaba.domain.Order;
5.  
   import com.atguigu.springcloud.alibaba.service.OrderService;
6.  
   import org.springframework.beans.factory.annotation.Autowired;
7.  
   import org.springframework.web.bind.annotation.*;
8.  
    
9.  
   /**
10.  
     * @auther zzyy
11.  
     * @create 2019-12-11 16:55
12.  
     */
13.  
    @RestController
14.  
    public class OrderController {
15.  
     
16.  
        @Autowired
17.  
        private OrderService orderService;
18.  
     
19.  
        /**
20.  
         * 创建订单
21.  
         */
22.  
        @GetMapping("/order/create")
23.  
        public CommonResult create( Order order) {
24.  
            orderService.create(order);
25.  
            return new CommonResult(200, "订单创建成功!");
26.  
        }
27.  
    }

库存服务：略

账户服务：略

5. Seata的模式

5.1 AT模式（默认）需要undolog表，相当于TCC的rollback

5.2 TCC模式

5.3 SAGA模式（长事务）

5.4 XA模式

6. AT模式2阶段提交（如何做到对业务的无侵入）

整体流程：整个过程有点像乐观锁CAS

一阶段加载：spring-aop思想

二阶段提交：try-catch思想 

二阶段回滚：回退反写机制

7. 总结：Seata控制分布式事务步骤

 1）、每一个微服务必须创建undo_Log
 2）、安装事务协调器：seate-server
 3）、整合
     1、导入依赖
     2、解压并启动seata-server：
         registry.conf:注册中心配置    修改 registry ： nacos
     3、所有想要用到分布式事务的微服务使用seata DataSourceProxy 代理自己的数据源
     4、每个微服务，都必须导入   registry.conf   file.conf
         vgroup_mapping.{application.name}-fescar-server-group = "default"
     5、启动测试分布式事务
     6、给分布式大事务的入口标注@GlobalTransactional
     7、每一个远程的小事务用@Transactional

这篇好文章是转载于：学新通技术网