程序员经验分享-hwhale

seata1.3.0 系列学习（二、nacos+seata使用）

2023-11-07

上篇文章讲了如何安装seata,这篇文章主要讲如何使用，分布讲解什么情况回滚，不回滚

一、新建父级maven

pom.xml文件导入

<?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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <groupId>nacosprovider</groupId>
    <artifactId>minenacos</artifactId>
    <version>1.0-SNAPSHOT</version>


    <modules>
        <module>nacosprovider</module>
        <module>consumer</module>
        <module>alibabaconfig</module>
        <module>nacosprovidertwo</module>
    </modules>

    <properties>
        <spring-cloud-starter-alibaba-nacos-discovery.version>2.2.0.RELEASE</spring-cloud-starter-alibaba-nacos-discovery.version>
    </properties>
    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
                <version>2.2.4.RELEASE</version>
            </dependency>
            <dependency>
                <groupId>com.alibaba.cloud</groupId>
                <artifactId>spring-cloud-alibaba-dependencies</artifactId>
                <version>2.2.1.RELEASE</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>
    <dependencies>
        <!-- https://mvnrepository.com/artifact/com.alibaba.cloud/spring-cloud-starter-alibaba-nacos-discovery -->
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
            <!--<scope>provided</scope>-->
            <!--<version>${spring-cloud-starter-alibaba-nacos-discovery.version}</version>-->
        </dependency>

        <!-- https://mvnrepository.com/artifact/com.alibaba.nacos/nacos-client -->
        <dependency>
            <groupId>com.alibaba.nacos</groupId>
            <artifactId>nacos-client</artifactId>
            <!--<version>1.2.0-beta.1</version>-->
        </dependency>

        <dependency>
             <groupId>org.springframework.cloud</groupId>
             <artifactId>spring-cloud-starter-openfeign</artifactId>
             <version>2.2.2.RELEASE</version>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
            <version>2.2.4.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.apache.httpcomponents</groupId>
            <artifactId>httpclient</artifactId>
            <version>4.5.11</version>
        </dependency>
    </dependencies>

</project>

二、整合nacos服务提供者

接着上篇文章的代码，加入mybatis和feign

目录结构

pom.xml导入了seata

<?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>nacosprovider</groupId>
        <artifactId>minenacos</artifactId>
        <version>1.0-SNAPSHOT</version>
        <relativePath/>
    </parent>
    <groupId>com.apiprovider</groupId>
    <artifactId>nacosprovider</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>nacosprovider</name>
    <description>Demo project for Spring Boot</description>

    <properties>
        <java.version>1.8</java.version>
    </properties>

    <dependencies>
        <!-- https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-data-jpa -->
        <!--<dependency>-->
            <!--<groupId>org.springframework.boot</groupId>-->
            <!--<artifactId>spring-boot-starter-data-jpa</artifactId>-->
            <!--<version>2.2.5.RELEASE</version>-->
        <!--</dependency>-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
            <version>2.3.1.RELEASE</version>
        </dependency>

        <dependency>
            <groupId>io.seata</groupId>
            <artifactId>seata-spring-boot-starter</artifactId>
            <version>1.3.0</version>
        </dependency>

        <dependency>
            <groupId>com.fasterxml.jackson.datatype</groupId>
            <artifactId>jackson-datatype-jsr310</artifactId>
            <version>2.11.2</version>
        </dependency>
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>8.0.20</version>
        </dependency>
        <!--mybatis-->
        <dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
            <version>2.1.0</version>
            <exclusions>
            <exclusion>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-jdbc</artifactId>
            </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-jdbc</artifactId>
            <version>2.3.1.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
            <version>2.3.1.RELEASE</version>
            <exclusions>
                <exclusion>
                    <groupId>org.junit.vintage</groupId>
                    <artifactId>junit-vintage-engine</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-compiler-plugin</artifactId>
                <configuration>
                    <source>6</source>
                    <target>6</target>
                </configuration>
            </plugin>
        </plugins>
    </build>

</project>

启动类

package com.apiprovider.nacosprovider;

import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.openfeign.EnableFeignClients;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;

@SpringBootApplication
@EnableDiscoveryClient
@MapperScan("com.apiprovider.nacosprovider.Mapper")//使用MapperScan批量扫描所有的Mapper接口；
@EnableFeignClients    //feigin扫描
public class NacosproviderApplication {

    public static void main(String[] args) {
        SpringApplication.run(NacosproviderApplication.class, args);
    }

}

其中usercontroller代码

package com.apiprovider.nacosprovider.Controller;


import com.apiprovider.nacosprovider.Entity.User;
import com.apiprovider.nacosprovider.Service.UserService;
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;
import sun.nio.ch.ThreadPool;

import java.util.List;

@RestController
@RequestMapping("/user")
public class UserController {
    @Autowired
    private UserService userService;

    @Autowired
    IUserCreateService UserCreateService;

    @RequestMapping("/findAll")
    public List<User> findAll(){
        return userService.findAll();
    }

    @RequestMapping("/getUserByID")
    public User getUserByID(Integer id){
        return userService.getUserByID(id);
    }

    @RequestMapping("/CreateUser")
    @GlobalTransactional(name = "my_test_tx_group",rollbackFor = Exception.class)
    public  void CreateUser(User user) throws Exception
    {
        userService.CreateUser(user);
        String name = user.getUsername()+"111111";
        user.setUsername(name);
        UserCreateService.CreateUser(user);
    }

    @RequestMapping("/DeleteUser")
    public  void DeleteUser(Integer id)
    {
        userService.DeleteUser(id);

    }

    @RequestMapping("/UpdateUser")
    public  void  UpdateUser(User user)
    {
        userService.UpdateUser(user);
    }
}

@GlobalTransactional(name = "my_test_tx_group",rollbackFor = Exception.class)注解作用为开启seata事务

新增application.yml

spring:
  cloud:
    nacos:
      discovery:
        server-addr: 127.0.0.1:8848
  application:
    name: service-provider
    #数据库连接配置
  datasource:
    driver-class-name: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://192.168.0.10:3306/test?characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=false&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=GMT%2B8&allowMultiQueries=true&allowPublicKeyRetrieval=true
    username: root
    password: piaost123
server:
  port: 4444


#mybatis的相关配置
mybatis:
  #mapper配置文件
  mapper-locations: classpath:mapper/*.xml
  type-aliases-package: com.apiprovider.nacosprovider.Entity
  #开启驼峰命名
  configuration:
    map-underscore-to-camel-case: true

seata:
  enabled: true
  # 应用 id 为唯一便于区分
  application-id: order
  # 事务分组，这个是默认分组
  tx-service-group: my_test_tx_group
  config:
    type: nacos
    nacos:
      namespace:
      serverAddr: 127.0.0.1:8848
      group: SEATA_GROUP
      username: ""
      password: ""
      cluster: default
  registry:
    type: nacos
    nacos:
      application: seata-server
      server-addr: 127.0.0.1:8848
      group : DEFAULT_GROUP
      namespace:
      username: ""
      password: ""
      cluster: default

此时需要，往你数据库中新增一张表，安装Seata时提供的

注解：

tx-service-group: my_test_tx_group为

config下的group为注册再nacos中的group

registry的配置来源也是安装时的配置

三、复制第二个服务，新建成第三个

只修改applicaiton.yml

spring:
  cloud:
    nacos:
      discovery:
        server-addr: 127.0.0.1:8848
  application:
    name: service-providertwo
    #数据库连接配置
  datasource:
    driver-class-name: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://192.168.0.10:3306/test?characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=false&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=GMT%2B8&allowMultiQueries=true&allowPublicKeyRetrieval=true
    username: root
    password: piaost123
server:
  port: 4445


#mybatis的相关配置
mybatis:
  #mapper配置文件
  mapper-locations: classpath:mapper/*.xml
  type-aliases-package: com.nacosprovidertwo.nacosprovidertwo.Entity
  #开启驼峰命名
  configuration:
    map-underscore-to-camel-case: true

seata:
  enabled: true
  # 应用 id 为唯一便于区分
  application-id: order
  # 事务分组，这个是默认分组
  tx-service-group: my_test_tx_group
  config:
    type: nacos
    nacos:
      namespace:
      serverAddr: 127.0.0.1:8848
      group: SEATA_GROUP
      username: ""
      password: ""
      cluster: default
  registry:
    type: nacos
    nacos:
      application: seata-server
      server-addr: 127.0.0.1:8848
      group : DEFAULT_GROUP
      namespace:
      username: ""
      password: ""
      cluster: default

和usercontroller

package com.nacosprovidertwo.nacosprovidertwo.Controller;


import com.nacosprovidertwo.nacosprovidertwo.Entity.User;
import com.nacosprovidertwo.nacosprovidertwo.Service.UserService;
import io.seata.spring.annotation.GlobalTransactional;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.List;

@RestController
@RequestMapping("/user")
public class UserController {
    @Autowired
    private UserService userService;

    @RequestMapping("/findAll")
    public List<User> findAll(){
        return userService.findAll();
    }

    @RequestMapping("/getUserByID")
    public User getUserByID(Integer id){
        return userService.getUserByID(id);
    }

    @RequestMapping("/CreateUser")
    @GlobalTransactional(name = "my_test_tx_group",rollbackFor = Exception.class)
    public  void CreateUser(@RequestBody User user) throws Exception
    {
        userService.CreateUser(user);
       throw  new Exception("分布式事务回滚");
    }

    @RequestMapping("/DeleteUser")
    public  void DeleteUser(Integer id)
    {
        userService.DeleteUser(id);

    }

    @RequestMapping("/UpdateUser")
    public  void  UpdateUser(User user)
    {
        userService.UpdateUser(user);
    }
}

ok，到此位置搭建完毕

开始启动服务

NacosproviderApplication，
NacosprovidertwoApplication

当前在第二个服务手动抛了异常

此时数据库为空

使用postman发送数据请求服务1

实现预期效果，服务二抛出异常

此时数据被回滚

为再次确认，我们去掉第二个手动抛异常的代码，预测新增两条数据

请求后正常返回

再看数据库正常新增了两条数据，此时初步实现了seata管理分布式事务

我们去掉第二个服务中的事务注解试一下会不会回滚，此时清空数据库，注释注解，抛出异常

在此纠正一个问题：除了发起时需要添加注解@GlobalTransactional，被调服务只要添加Transactional即可

再次启动服务

如期，抛出异常，再看数据库

很明显第二条没有回滚掉，说明不加事务回滚注解，是不行的

初步认知到此为止，在实验的过程中我发现个问题，第一次启动时，请求，第一个服务插入一条数据（没问题），但是第二个服务会往数据库插入两条相同的数据

如：我们重启服务，清空数据库，不抛异常

此时请求，返回成功

我们去看数据库

发现第二个服务执行了两次，初步怀疑，第一个服务请求了两次，这个问题 留到下个文章解决

本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)

seata

seata1.3.0 系列学习（二、nacos+seata使用） 的相关文章

随机推荐

  • skimage的简介

    skimage的简介 skimage即是Scikit Image 基于python脚本语言开发的数字图片处理包 比如PIL Pillow opencv scikit image等 PIL和Pillow只提供最基础的数字图像处理 功能有限 o

  • activiti 自定义函数解析juel表达式

    activiti是支持juel表达式的 这个也很好用 但实际过程中需要支持类方法及变量 原来项目中解析juel 这边有自定义一个方法的 代码如下 public String getStringByELAndFormData String e

  • 使用C语言编写Python扩展1——Hello World

    使用C语言编写Python扩展1 Hello World 时间 2014 04 12 18 01 10 龍昌博客 原文 http www xefan com archives 84082 html 主题 Python C语言 能够使用C语言

  • 设计模式复习之装饰器模式

    一 装饰器模式 摘录 装饰器模式又称为包装 Wrapper 模式 装饰器模式以多客户端透明的方式扩展对象的功能 是继承关系的一个替代方案 通常给对象添加功能 要么直接修改对象添加相应的功能 要么派生子类来扩展 抑或是使用对象组合的方式 显然

  • 如何用Python创建SQL数据库 ? 学会就非常完美~

    今日份知识你摄入了么 会写SQL很重要 能高效地查询数据库被认为是数据分析师 科学家最基本的技能之一 SQL不仅重要 而且非常常用 根据 2021年Stackoverflow开发者调查 SQL是最常用的五种编程语言之一 所以 我们应该多投入

  • STL实现排序

    使用sort函数对容器内的随机元素进行排序 sort RandomAccessIterator first RandomAccessIterator last Compare comp RandomAccessIterator first

  • Libevent 事件循环(1)

    事件的dispatch int event base loop struct event base base int flags 得到采用的事件模型 epoll epoll select const struct eventop evsel

  • 单元测试，报java.lang.NoClassDefFoundError:org/springframework/test/content/TestContesxtAnnotationUtils

    这里写目录标题 一级目录 1 问题 单元测试 报java lang NoClassDefFoundError org springframework test content TestContesxtAnnotationUtils spri

  • Message: element not interactable错误解决

    1 在定位之前先等待资源加载完毕 sleep 10 element driver find element by xpath input class form control and name username 2 定义隐式等待 drive

  • SQL中grant的用法

    GRANT 名称 GRANT 赋予一个用户 一个组或所有用户访问权限 语法 GRANT privilege ON object TO PUBLIC GROUP group username 输入 privilege 可能的权限有 SELEC

  • Python OpenCV 入门教程

    原文链接 本文只是调整了代码格式 一 Python OpenCV 入门 欢迎阅读系列教程 内容涵盖 OpenCV 它是一个图像和视频处理库 包含 C C Python 和 Java 的绑定 OpenCV 用于各种图像和视频分析 如面部识别和

  • SSIS包配置

    Integrartion Services 包实际上就是一个对象属性的集合 在前面我们开发的所有 Integration Services包 其中的变量 属性 比如 数据库链接 同步文件目录等 我们都直接在包中用一个常量的方式 赋给这些变量

  • 2022亚马逊云科技中国峰会召开 宣布多项举措赋能客户数字化探索与创新

    2022年10月13日 以 自由构建 探索无限 为主题的亚马逊云科技中国峰会于今天在线上召开 在本次为期2天的峰会上 亚马逊云科技发布了云计算技术趋势展望 宣布 连中外 襄百业 携伙伴 促绿色 四大战略举措 进一步利用亚马逊云科技全球优势和

  • [思考进阶]03 每一个成年人都应该掌握的学习技巧

    除了要提升自己的技术能力 思维的学习和成长也非常非常重要 特推出此 思考进阶 系列 进行刻意练习 从而提升自己的认知 这世间有两种人 一种被誉为天之骄子 拥有那种天才的创造能力 这种人极少 另外一种是平凡的普通人 努力地想成功 这种人很多

  • C语言：输出一组数的最大值与最小值

    C语言 输出一组数中的最大值或最小值 如果要输出多个数的最大值只需更改数组大小与循环的限制条件即可 这里以三个数为例 最大值 include

  • [STM32] 关于USART接收中断的BUG和注意事项

    今天在使用USART模块 遇到了一些问题并解决了 于是发贴共享 问题描述 在使用USART做串口通讯时 我只把接收中断打开 并设置抢占优先级为最低一个级别 而接收中断上一个优先级处理事情比较多 可能占用了2ms时间 当我使用9600波特率往

  • 【Jupyter】【Colab】【AutoGluon】测试

    环境 pip install autogluon 测试代码 AutoGluon官网 from autogluon tabular import TabularDataset TabularPredictor train data Tabul

  • 第七章 缺失数据

    文章目录 一 缺失值的统计和删除 1 缺失信息的统计 2 缺失信息的删除 二 缺失值的填充和插值 1 利用fillna进行填充 练一练 END 2 插值函数 NOTE 关于polynomial和spline插值的注意事项 END 三 Nul

  • 用canvas画出可爱的哆啦A梦

    用canvas画出可爱的哆啦A梦 本文就介绍了如何用canvas案例画出哆啦A梦的基础内容 提示 以下是本篇文章正文内容 下面案例可供参考 一 canvas是什么 HTML5 的 canvas 元素使用 JavaScript 在网页上绘制图

  • seata1.3.0 系列学习（二、nacos+seata使用）

    上篇文章讲了如何安装seata 这篇文章主要讲如何使用 分布讲解什么情况回滚 不回滚 一 新建父级maven pom xml文件导入

热门标签