seata 分布式事务 -- seata-two工程完整代码

2021-05-18 17:04:50 阅读：112 来源： 互联网

标签：seata -- two public org import com id

工程结构，启动类，数据库主键生成工具类（雪花算法）跟 seata-one 一致

入口 controller：

package com..controller;

import com..service.Rm_Two_Interface;
import com..service.Rm_Two_Service;
import io.seata.spring.annotation.GlobalTransactional;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class Rm_Two_Controller {


    @Autowired
    private Rm_Two_Service rm_two_service;

    @Autowired
    private Rm_Two_Interface rm_two_interface;


    @RequestMapping("/two_at")
    public String rm2(){

        String result = rm_two_service.rm2();
//        System.out.println(1/0);
        if(result.equals("err")){
            return "err";
        }
        return "success_"+result;

    }


    @RequestMapping("/two_tcc")
    @GlobalTransactional(rollbackFor = Exception.class)
    public String oneTcc() throws InterruptedException {
        rm_two_interface.rm2(null);
        return "success";
    }





}

数据库实体类：

package com..entity;


public class TbltwoInfo {
   
    private String id;

   
    private String name;

    
    public String getId() {
        return id;
    }

   
    public void setId(String id) {
        this.id = id;
    }

   
    public String getName() {
        return name;
    }

   
    public void setName(String name) {
        this.name = name == null ? null : name.trim();
    }
}

mapper：

package com..mapper;

import com..entity.TbltwoInfo;
import org.apache.ibatis.annotations.Mapper;
import org.springframework.stereotype.Component;

import java.util.List;

@Mapper
@Component(value = "TbltwoInfoMapper")
public interface TbltwoInfoMapper {
    
    int deleteByPrimaryKey(String id);

    int insert(TbltwoInfo record);

    TbltwoInfo selectByPrimaryKey(String id);

    List<TbltwoInfo> selectAll();

    int updateByPrimaryKey(TbltwoInfo record);
}

AT 模式实现类：

package com..service;

import com..entity.TbltwoInfo;
import com..mapper.TbltwoInfoMapper;
import com..sqlToJava.SnowFlake;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;


@Service
public class Rm_Two_Service {

    @Autowired
    TbltwoInfoMapper tbltwoInfoMapper;

    public String rm2(){

        long id = SnowFlake.nextId();
        TbltwoInfo tbltwoInfo = new TbltwoInfo();
        tbltwoInfo.setId(id+"");
        tbltwoInfo.setName("Rm_Two_"+id);

        int insert = tbltwoInfoMapper.insert(tbltwoInfo);


        if (insert==1){
            return id+"";
        }
        return "err";
    }
}

TCC模式接口 / 实现类：

接口：

package com.wondersgroup.service;

import io.seata.rm.tcc.api.BusinessActionContext;
import io.seata.rm.tcc.api.LocalTCC;
import io.seata.rm.tcc.api.TwoPhaseBusinessAction;

@LocalTCC
public interface Rm_Two_Interface {

    @TwoPhaseBusinessAction(name = "rm2TccAction",commitMethod = "rm2Commit",rollbackMethod = "rm2Rollback")
    public String rm2(BusinessActionContext businessActionContext);

    public boolean rm2Commit(BusinessActionContext businessActionContext);

    public boolean rm2Rollback(BusinessActionContext businessActionContext);


}

实现类：

package com..service;

import com..entity.TbltwoInfo;
import com..mapper.TbltwoInfoMapper;
import com..sqlToJava.SnowFlake;
import io.seata.rm.tcc.api.BusinessActionContext;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Transactional;

import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;

@Component
public class Rm_Two_InterfaceImpl implements Rm_Two_Interface{


    @Autowired
    TbltwoInfoMapper tbltwoInfoMapper;

    private static ConcurrentMap<String,String> maps = new ConcurrentHashMap<>();

    @Override
    @Transactional
    public String rm2(BusinessActionContext businessActionContext) {

        long id = SnowFlake.nextId();
        TbltwoInfo tbltwoInfo = new TbltwoInfo();
        tbltwoInfo.setId(id+"");
        tbltwoInfo.setName("Rm_Two_"+id);
        maps.put("id",id+"");
        int insert = tbltwoInfoMapper.insert(tbltwoInfo);

        System.out.println("rm2   try...."+insert);

        return null;
    }

    @Override
    @Transactional
    public boolean rm2Commit(BusinessActionContext businessActionContext) {

        System.out.println("rm2   rm2Commit....");
        return true;
    }

    @Override
    @Transactional
    public boolean rm2Rollback(BusinessActionContext businessActionContext) {

        String id = maps.get("id");
        int i = tbltwoInfoMapper.deleteByPrimaryKey(id);
        System.out.println("rm2   rm2Rollback...."+i);
        return true;
    }
}

application.yml ：

server:
  port: 8070

#应用名称及验证账号
spring:
  application:
    name: seata-two


  datasource:
    type: com.alibaba.druid.pool.DruidDataSource
    driver-class-name: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://localhost:3307/seata-rm-two?characterEncoding=UTF-8&serverTimezone=Asia/Shanghai
    username: root
    password: root
    dbcp2:
      initial-size: 5
      min-idle: 5
      max-total: 5
      max-wait-millis: 200
      validation-query: SELECT 1
      test-while-idle: true
      test-on-borrow: false
      test-on-return: false

mybatis:
  mapper-locations:
    - classpath:mapper/*.xml

eureka:
  client:
    prefer-ip-address: true
    service-url:
      defaultZone: http://localhost:7900/eureka/

数据库链接 TbloneInfoMapper.xml：

（项目地址需要根据情况补充）

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com..mapper.TbltwoInfoMapper">
  <resultMap id="BaseResultMap" type="com..entity.TbltwoInfo">
    <!--
      WARNING - @mbg.generated
      This element is automatically generated by MyBatis Generator, do not modify.
      This element was generated on Mon May 17 11:20:53 CST 2021.
    -->
    <id column="id" jdbcType="VARCHAR" property="id" />
    <result column="name" jdbcType="VARCHAR" property="name" />
  </resultMap>
  <delete id="deleteByPrimaryKey" parameterType="java.lang.String">
    <!--
      WARNING - @mbg.generated
      This element is automatically generated by MyBatis Generator, do not modify.
      This element was generated on Mon May 17 11:20:53 CST 2021.
    -->
    delete from tbl_two
    where id = #{id,jdbcType=VARCHAR}
  </delete>
  <insert id="insert" parameterType="com..entity.TbltwoInfo">
    <!--
      WARNING - @mbg.generated
      This element is automatically generated by MyBatis Generator, do not modify.
      This element was generated on Mon May 17 11:20:53 CST 2021.
    -->
    insert into tbl_two (id, name)
    values (#{id,jdbcType=VARCHAR}, #{name,jdbcType=VARCHAR})
  </insert>
  <update id="updateByPrimaryKey" parameterType="com..entity.TbltwoInfo">
    <!--
      WARNING - @mbg.generated
      This element is automatically generated by MyBatis Generator, do not modify.
      This element was generated on Mon May 17 11:20:53 CST 2021.
    -->
    update tbl_two
    set name = #{name,jdbcType=VARCHAR}
    where id = #{id,jdbcType=VARCHAR}
  </update>
  <select id="selectByPrimaryKey" parameterType="java.lang.String" resultMap="BaseResultMap">
    <!--
      WARNING - @mbg.generated
      This element is automatically generated by MyBatis Generator, do not modify.
      This element was generated on Mon May 17 11:20:53 CST 2021.
    -->
    select id, name
    from tbl_two
    where id = #{id,jdbcType=VARCHAR}
  </select>
  <select id="selectAll" resultMap="BaseResultMap">
    <!--
      WARNING - @mbg.generated
      This element is automatically generated by MyBatis Generator, do not modify.
      This element was generated on Mon May 17 11:20:53 CST 2021.
    -->
    select id, name
    from tbl_two
  </select>
</mapper>

pom：

（<groupId>com.</groupId> 需要根据情况补充）

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.4.5</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.</groupId>
    <artifactId>seata-two</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>seata-two</name>
    <description>seata-two</description>
    <properties>
        <java.version>1.8</java.version>
        <spring-cloud.version>2020.0.2</spring-cloud.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>

        <!-- euekea 依赖-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
        </dependency>
        <!-- mysql:MyBatis相关依赖-->
        <dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
            <version>2.0.0</version>
        </dependency>

        <!-- 整合MyBatis java类依赖 -->
        <dependency>
            <groupId>org.mybatis.generator</groupId>
            <artifactId>mybatis-generator-maven-plugin</artifactId>
            <version>1.4.0</version>
            <type>maven-plugin</type>
        </dependency>

        <!-- mysql:mysql驱动-->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
        </dependency>

        <!-- mysql:阿里巴巴数据库连接池 -->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid</artifactId>
            <version>1.1.12</version>
        </dependency>
        <!--  JSONObject  -->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>1.2.60</version>
        </dependency>

        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-alibaba-seata</artifactId>
            <version>2.2.0.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-commons</artifactId>
            <version>3.0.2</version>
        </dependency>
    </dependencies>
    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>${spring-cloud.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

标签：seata,--,two,public,org,import,com,id
来源： https://www.cnblogs.com/lifan12589/p/14781622.html

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

ICode9

seata 分布式事务 -- seata-two工程完整代码