Seata入门案例

先完nacos的安装与seata服务端的安装以及配置文件导入

nacos安装详细教程https://mp.csdn.net/mp_blog/creation/editor/107505689seata服务端安装教程https://mp.csdn.net/mp_blog/creation/editor/121103159seata配置导入nacos配置中心教程https://mp.csdn.net/mp_blog/creation/editor/120993190案例使用框架版本

项目结构如下

1.搭建父工程demo

新建springboot项目

勾选type为pom

修改pom.xml

添加springboot/springcloud/springcloudalibaba的依赖



    4.0.0
    com.daxiang
    demo
    0.0.1-SNAPSHOT
    
        order
        store
        generator
    
    demo
    Demo project for Spring Boot
    pom

    
        1.8
        2.2.6.RELEASE
        Hoxton.SR9
        2.3.2.RELEASE
        3.4.3.4
        8.0.26
        1.9.6
        2.9.2
    

    
    
        
            
            
                com.alibaba.cloud
                spring-cloud-alibaba-dependencies
                ${com.alibaba.cloud.version}
                pom
                import
            
            
            
                org.springframework.cloud
                spring-cloud-dependencies
                ${spring.cloud.version}
                pom
                import
            
            
            
                org.springframework.boot
                spring-boot-dependencies
                ${spring.boot.version}
                pom
                import
            
            
            
                com.baomidou
                mybatis-plus-boot-starter
                ${mybatis.plus.version}
            
            
            
                mysql
                mysql-connector-java
                ${mysql.connector.version}
                runtime
            


        
    
    

        
            org.springframework.boot
            spring-boot-starter
        

        
            org.springframework.boot
            spring-boot-starter-web
        

        
            org.springframework.boot
            spring-boot-starter-test
            test
        

        
        
            org.projectlombok
            lombok
            true
        

        
        
            com.github.xiaoymin
            swagger-bootstrap-ui
            ${com.github.xiaoymin}
        
        
            io.springfox
            springfox-swagger2
            ${io.springfox}
        

        
        
            com.alibaba.cloud
            spring-cloud-starter-alibaba-nacos-discovery
        

        
        
            org.springframework.cloud
            spring-cloud-starter-openfeign
        

    

    
        
            
                org.springframework.boot
                spring-boot-maven-plugin

1.添加pom

2.我这里将springboot的依赖放到了标签中

2.搭建order/store子项目

右键父项目,选择新建->module

点击完成

使用相同的方式创建store子项目

3.添加依赖

由于我们子项目需要连接数据库,操作数据库,

order中的pom.xml



    
        demo
        com.daxiang
        0.0.1-SNAPSHOT
    
    4.0.0

    com.daxiang.order
    order

    
        
        
            com.baomidou
            mybatis-plus-boot-starter
        
        
            mysql
            mysql-connector-java
            runtime
        
        
        
            com.alibaba.cloud
            spring-cloud-starter-alibaba-seata

store的pom.xml



    
        demo
        com.daxiang
        0.0.1-SNAPSHOT
    
    4.0.0

    com.daxiang.store
    store

    
        
        
            com.baomidou
            mybatis-plus-boot-starter
        
        
            mysql
            mysql-connector-java
            runtime
        
        
        
            com.alibaba.cloud
            spring-cloud-starter-alibaba-seata

4.添加启动类与配置文件

特别说明: 我的controller/mapper/pojo/service包是通过mybatis-plus的代码生成器生成的不了解的可以下看下这篇博客mybatis-plus代码生成工具使用教程https://mp.csdn.net/mp_blog/creation/editor/120528799

5.配置文件中添加配置 1.整合mybatis-plus的配置

# 数据源配置
spring:
  datasource:
    driver-class-name: com.mysql.cj.jdbc.Driver
    username: root
    password: root
    url: jdbc:mysql://127.0.0.1:3306/blogs?characterEncoding=UTF-8&serverTimezone=GMT%2B8

# mybatis-plus配置
mybatis-plus:
  type-aliases-package: com.daxiang.store.pojo
  mapper-locations: classpath:mapper/*.xml
  configuration:
    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl

2.整合nacos配置

# nacos注册中心配置
spring:
  cloud:
    nacos:
      discovery:
        server-addr: 127.0.0.1:8848
        namespace: e6325d8c-07b3-41ef-8037-13630936861d
        password: nacos
        username: nacos
        enabled: true

这里namespace是我之前在nacos中新建了有个命名空间

具体在上面的nacos教程中有介绍

3.整合seata配置

# seata配置
seata:
  config:
    type: nacos
    nacos:
      server-addr: 127.0.0.1:8848
      group: SEATA_GROUP
      namespace: ""
      username: nacos
      password: nacos
  registry:
    type: nacos
    nacos:
      application: seata-server
      server-addr: 127.0.0.1:8848
      group: SEATA_GROUP
      namespace: ""
      username: nacos
      password: nacos
# 事务分组配置 这里配置的名称需要与nacos中	service.vgroupMapping后面的一致
spring:
  cloud:
    alibaba:
      seata:
        tx-service-group: my_test_tx_group

完整的store配置如下 order配置只有端口号与项目名称不一样

server:
  port: 8081

# 配置数据源
spring:
  application:
    name: store
  datasource:
    driver-class-name: com.mysql.cj.jdbc.Driver
    username: root
    password: root
    url: jdbc:mysql://127.0.0.1:3306/blogs?characterEncoding=UTF-8&serverTimezone=GMT%2B8
  cloud:
    nacos:
      discovery:
        server-addr: 127.0.0.1:8848
        namespace: e6325d8c-07b3-41ef-8037-13630936861d
        password: nacos
        username: nacos
        enabled: true
    alibaba:
      seata:
        tx-service-group: my_test_tx_group
# mybatis-plus配置
mybatis-plus:
  type-aliases-package: com.daxiang.store.pojo
  mapper-locations: classpath:mapper/*.xml
  configuration:
    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
ribbon:
  nacos:
    enabled: true

seata:
  config:
    type: nacos
    nacos:
      server-addr: 127.0.0.1:8848
      group: SEATA_GROUP
      namespace: ""
      username: nacos
      password: nacos
  registry:
    type: nacos
    nacos:
      application: seata-server
      server-addr: 127.0.0.1:8848
      group: SEATA_GROUP
      namespace: ""
      username: nacos
      password: nacos

最后还需要在启动类上添加注解

openfigen的注解与mybatis的注解

6.添加业务代码

业务流程:

order远程调用store 两个服务都删除一条数据库数据测试分布式事务是否起作用

1.在store中添加删除数据接口

2.在order中添加fegin远程调用接口

3.在order中添加删除数据接口

接口上添加注解@GlobalTransactional

第一次在没有制造异常的情况下,删除成功

第二次手动添加一个1/0的异常,再次执行

开始远程调用的时候执行了删除由于在order中抛出了by zero的异常导致回滚

最终该数据未被删除,分布式事务起作用了

seata服务端控制台日志

Seata入门案例

Java相关栏目本月热门文章