seata实现分布式事务

阿超

发布于 2022-08-16 19:24:09

3540

发布于 2022-08-16 19:24:09

文章被收录于专栏：快乐阿超

尽管世界和人生是坏透了，其中却有一件东西永远是好，那便是青春——显克维奇

首先是下载seata1.4.1

然后解压

先修改conf下的registry.conf

把type改为nacos

进入bin

打开控制台运行seata-server.bat

然后在项目中引入依赖，记得需要分布式式事务的服务都要配置

<!--    seata 分布式事务    -->
<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-seata</artifactId>
</dependency>

配置类

package com.ruben.config;

import com.alibaba.druid.pool.DruidDataSource;
import com.zaxxer.hikari.HikariDataSource;
import io.seata.rm.datasource.DataSourceProxy;
import org.apache.commons.lang3.StringUtils;
import org.springframework.boot.autoconfigure.jdbc.DataSourceProperties;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import javax.annotation.Resource;
import javax.sql.DataSource;
import java.util.Optional;

/**
 * @ClassName: SeataConfig
 * @Description: 我还没有写描述
 * @Date: 2021/3/14 0014 16:53
 * *
 * @author: <achao1441470436@gmail.com>
 * @version: 1.0
 * @since: JDK 1.8
 */
@Configuration
public class SeataConfig {


    @Bean
    @ConfigurationProperties(prefix = "spring.datasource")
    public DataSource druidDataSource(){
        return new DruidDataSource();
    }

}

然后是项目中的配置文件

seata:
  enabled: true
  application-id: ${spring.application.name}
  tx-service-group: ruben
  config:
    type: file
    file:
      name: file.conf
  service:
    disable-global-transaction: false

如果之后启动一直报没配置disableGlobalTransaction

就需要新建一个file.conf到resources目录下

内容为

service{
    disableGlobalTransaction = false
}

接下来是编写两个接口

首先是调用方

controller

@RestController
@RequestMapping("user")
public class UserController {
    @Resource
    private UserService userService;
    
    @GetMapping("order")
    public AjaxJson order() {
        return userService.order();
    }
}

service

@Slf4j
@Service
public class UserServiceImpl implements UserService {
    
    @Resource
    private MpOrderMapper mpOrderMapper;
    @Resource
    private ConsumerService consumerService;
    
    @Override
    @Transactional
    @GlobalTransactional
    public AjaxJson order() {
        consumerService.dropWare();
        mpOrderMapper.insert(OrderPO.builder().id(1L).build());
        return AjaxJson.success();
    }
}

ConsumerService是使用feign远程调用另一个接口

package com.ruben.feign;

import com.ruben.pojo.dto.PageDTO;
import com.ruben.utils.AjaxJson;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestBody;

@FeignClient("ruben-consumer")
public interface ConsumerService {

    @GetMapping("ware")
    AjaxJson dropWare();
}

MpOrderMapper是mybatis-plus调用数据库的方法

package com.ruben.dao;

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.ruben.pojo.po.OrderPO;
import org.apache.ibatis.annotations.Mapper;

@Mapper
public interface MpOrderMapper extends BaseMapper<OrderPO> {
}

然后是调用的ruben-consumer

首先也是引入依赖

其次是配置

seata:
  enabled: true
  application-id: ${spring.application.name}
  tx-service-group: SEATA_GROUP
  config:
    type: file
    file:
      name: file.conf
  service:
    disable-global-transaction: false

package com.ruben.rubenproducerdemo.config;

import com.alibaba.druid.pool.DruidDataSource;
import com.zaxxer.hikari.HikariDataSource;
import io.seata.rm.datasource.DataSourceProxy;
import org.apache.commons.lang3.StringUtils;
import org.springframework.boot.autoconfigure.jdbc.DataSourceProperties;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import javax.annotation.Resource;
import javax.sql.DataSource;
import java.util.Optional;

/**
 * @ClassName: SeataConfig
 * @Description: 我还没有写描述
 * @Date: 2021/3/14 0014 16:53
 * *
 * @author: <achao1441470436@gmail.com>
 * @version: 1.0
 * @since: JDK 1.8
 */
@Configuration
public class SeataConfig {


    @Bean
    @ConfigurationProperties(prefix = "spring.datasource")
    public DataSource druidDataSource(){
        return new DruidDataSource();
    }

}

然后是接口

package com.ruben.rubenproducerdemo.controller;

import com.ruben.rubenproducerdemo.service.WareService;
import com.ruben.rubenproducerdemo.utils.AjaxJson;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.annotation.Resource;

/**
 * @ClassName: WareController
 * @Description: 我还没有写描述
 * @Date: 2021/3/13 0013 22:10
 * *
 * @author: <achao1441470436@gmail.com>
 * @version: 1.0
 * @since: JDK 1.8
 */
@RestController
@RequestMapping("ware")
public class WareController {
    @Resource
    private WareService wareService;

    @GetMapping
    public AjaxJson dropWare() {
        return wareService.dropWare();
    }
}

service

package com.ruben.rubenproducerdemo.service.impl;

import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ruben.dao.WareMapper;
import com.ruben.rubenproducerdemo.pojo.po.WarePO;
import com.ruben.rubenproducerdemo.service.WareService;
import com.ruben.rubenproducerdemo.utils.AjaxJson;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.Optional;

/**
 * @ClassName: WareServiceImpl
 * @Description: 我还没有写描述
 * @Date: 2021/3/13 0013 22:14
 * *
 * @author: <achao1441470436@gmail.com>
 * @version: 1.0
 * @since: JDK 1.8
 */
@Service
public class WareServiceImpl extends ServiceImpl<WareMapper, WarePO> implements WareService {

    @Override
    @Transactional
    public AjaxJson dropWare() {
        WarePO ware = this.getById("1");
        Optional.ofNullable(ware).map(WarePO::getWare).filter(w -> w <= 0).ifPresent(wi -> {
            throw new RuntimeException("卖光啦！");
        });
        Optional.ofNullable(ware).ifPresent(w -> this.updateById(WarePO.builder().id("1").ware(w.getWare() - 1).build()));
        return AjaxJson.success("成功");
    }
}

我们开始测试

往数据库放条数据