Seata事务

1
 <!--添加seata依赖-->
2
        <dependency>
3
            <groupId>io.seata</groupId>
4
            <artifactId>seata-spring-boot-starter</artifactId>
5
        </dependency>
6
        <!--Seata完成分布式事务需要的两个相关依赖(Seata需要下面两个依赖中的资源)-->
7
        <dependency>
8
            <groupId>com.github.pagehelper</groupId>
9
            <artifactId>pagehelper-spring-boot-starter</artifactId>
10
        </dependency>
11
        <dependency>
12
            <groupId>com.alibaba</groupId>
13
            <artifactId>fastjson</artifactId>
14
        </dependency>

1
seata:
2
  tx-service-group: csmall_group  #定义分组名称，一般是为了区分项目
3
  service:
4
    vgroup-mapping:
5
      csmall_group: default #csmall_group组使用默认的Seata配置完成事务
6
    grouplist:
7
      default: localhost:8091 #设置Seata所在的地址，默认端口是8091

1
<!--添加seata依赖-->
2
        <dependency>
3
            <groupId>io.seata</groupId>
4
            <artifactId>seata-spring-boot-starter</artifactId>
5
        </dependency>

1
seata:
2
  tx-service-group: csmall_group  #定义分组名称，一般是为了区分项目
3
  service:
4
    vgroup-mapping:
5
      csmall_group: default #csmall_group组使用默认的Seata配置完成事务
6
    grouplist:
7
      default: localhost:8091 #设置Seata所在的地址，默认端口是8091s

1
@Service
2
@Slf4j //提供log对象，可以用于打印日志
3
public class BusinessServiceImpl implements IBusinessService {
4
​
5
    //需要利用dubbo调用order模块中的新增订单方法
6
    @DubboReference
7
    private IOrderService dubboOrderService;
8
​
9
    //一旦编写@GlobalTransactional，标记这个方法就是seata分布式事务的起点了，也就是TM
10
    //最终的效果就是由当前方法引发的所有远程调用对数据的操作，要么都成功，要么都失败
11
    @GlobalTransactional
12
    @Override
13
    public void buy() {
14
        //模拟购买业务
15
        //创建OrderAddDTO类，并赋值
16
        OrderAddDTO orderAddDTO = new OrderAddDTO();
17
        orderAddDTO.setUserId("UU100");
18
        orderAddDTO.setCommodityCode("PC100");
19
        orderAddDTO.setCount(5);
20
        orderAddDTO.setMoney(100);
21
        //调用order模块的方法
22
        dubboOrderService.orderAdd(orderAddDTO);
23
        //目前现在控制台输出
24
        log.info("新增订单的信息为：{}",orderAddDTO);
25
    }
26
}

1
@GlobalTransactional
2
    @Override
3
    public void buy() {
4
        //模拟购买业务
5
        //创建OrderAddDTO类，并赋值
6
        OrderAddDTO orderAddDTO = new OrderAddDTO();
7
        orderAddDTO.setUserId("UU100");
8
        orderAddDTO.setCommodityCode("PC100");
9
        orderAddDTO.setCount(5);
10
        orderAddDTO.setMoney(100);
11
        //调用order模块的方法
12
        dubboOrderService.orderAdd(orderAddDTO);
13
        //目前现在控制台输出
14
        log.info("新增订单的信息为：{}",orderAddDTO);
15
        //为了验证seata实现的分布式事务效果
16
        //我们在所有代码运行完毕之后，随机抛出异常，观察是否能回滚
17
        if (Math.random()<0.5){
18
            throw  new CoolSharkServiceException(ResponseCode.INTERNAL_SERVER_ERROR,
19
                    "发生随机异常，本次操作回滚");
20
        }
21
    }