当前位置：首页 > 后端开发 > SpringCloud实战｜8.SpringCloud 整合 seata1.3-估计是全网讲的最细的并且一次成功的

SpringCloud实战｜8.SpringCloud 整合 seata1.3-估计是全网讲的最细的并且一次成功的

7个月前 (05-21)20

手把手教你从0开始搭建spring cloud alibaba 脚手架，关注公众号“AI码师” 获取项目完整源码

前言

本篇文章介绍了如何在Spring Cloud项目中引入seata，以及seata的安装过程

开整

安装seata

下载安装包

链接:https://pan.baidu.com/s/1OuSDMJDNLFxQN2KA6BfWNQ (如果链接失效可以私信我)

修改seata/config.txt

修改存储方式

store.db.dbType=mysql
store.db.driverClassName=com.mysql.jdbc.Driver
store.db.url=jdbc:mysql://你的IP:3306/seata?useUnicode=true
store.db.user=root
store.db.password=root

添加如下配置

service.vgroupMapping.demo-order=default
service.vgroupMapping.demo-storage=default
service.vgroupMapping.demo-account=default

修改seata/conf/registry.conf

注册中心修改为nacos

  registry {
  # file 、nacos 、eureka、redis、zk、consul、etcd3、sofa
  type = "nacos"

  nacos {
    application = "seata-server"
    serverAddr = "你的IP:8848"
    group = "SEATA_GROUP"
    namespace = ""
    cluster = "default"
    username = "nacos"
    password = "nacos"
  }

配置中心也修改为nacos

config {
  # file、nacos 、apollo、zk、consul、etcd3
  type = "nacos"

  nacos {
    serverAddr = "你的IP:8848"
    namespace = "在nacos中创建一个命名空间，用来保存seata配置，提前配置好"
    group = "SEATA_GROUP"
    username = "nacos"
    password = "nacos"
  }

执行nacos脚本，推送seata配置到nacos

sh nacos-config.sh -h 你的nacos -p 8848 -g SEATA_GROUP -t 上面创建的命名空间 -u nacos -w nacos

等待推送完成…
推送完成后，nacos中长这样
SpringCloud实战｜8.SpringCloud 整合 seata1.3-估计是全网讲的最细的并且一次成功的 _ Java侠

创建seata 需要用到的表

创建数据库

create database seata;

创建相关表

CREATE TABLE `branch_table` (
  `branch_id` bigint(20) NOT NULL,
  `xid` varchar(128) NOT NULL,
  `transaction_id` bigint(20) DEFAULT NULL,
  `resource_group_id` varchar(32) DEFAULT NULL,
  `resource_id` varchar(256) DEFAULT NULL,
  `branch_type` varchar(8) DEFAULT NULL,
  `status` tinyint(4) DEFAULT NULL,
  `client_id` varchar(64) DEFAULT NULL,
  `application_data` varchar(2000) DEFAULT NULL,
  `gmt_create` datetime(6) DEFAULT NULL,
  `gmt_modified` datetime(6) DEFAULT NULL,
  PRIMARY KEY (`branch_id`),
  KEY `idx_xid` (`xid`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

CREATE TABLE `global_table` (
  `xid` varchar(128) NOT NULL,
  `transaction_id` bigint(20) DEFAULT NULL,
  `status` tinyint(4) NOT NULL,
  `application_id` varchar(32) DEFAULT NULL,
  `transaction_service_group` varchar(32) DEFAULT NULL,
  `transaction_name` varchar(128) DEFAULT NULL,
  `timeout` int(11) DEFAULT NULL,
  `begin_time` bigint(20) DEFAULT NULL,
  `application_data` varchar(2000) DEFAULT NULL,
  `gmt_create` datetime DEFAULT NULL,
  `gmt_modified` datetime DEFAULT NULL,
  PRIMARY KEY (`xid`),
  KEY `idx_gmt_modified_status` (`gmt_modified`,`status`),
  KEY `idx_transaction_id` (`transaction_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

CREATE TABLE `lock_table` (
  `row_key` varchar(128) NOT NULL,
  `xid` varchar(96) DEFAULT NULL,
  `transaction_id` bigint(20) DEFAULT NULL,
  `branch_id` bigint(20) NOT NULL,
  `resource_id` varchar(256) DEFAULT NULL,
  `table_name` varchar(32) DEFAULT NULL,
  `pk` varchar(36) DEFAULT NULL,
  `gmt_create` datetime DEFAULT NULL,
  `gmt_modified` datetime DEFAULT NULL,
  PRIMARY KEY (`row_key`),
  KEY `idx_branch_id` (`branch_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

启动seata服务

sh seata/bin/seata-server.sh
启动成功后，监听8091端口
SpringCloud实战｜8.SpringCloud 整合 seata1.3-估计是全网讲的最细的并且一次成功的 _ Java侠

看下nacos中是否注册了此服务:
看到如下内容表示，seata已经安装并注册成功
SpringCloud实战｜8.SpringCloud 整合 seata1.3-估计是全网讲的最细的并且一次成功的 _ Java侠

整合seata

代码在ams-cloud/ams-demo/demo-seata下面

创建父工程

在ams-demo下创建父工程demo-seata

引入依赖

 <dependencies>
        <!-- 配置读取 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-configuration-processor</artifactId>
        </dependency>

        <!-- 单元测试 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>

        <!-- Spring Cloud & Alibaba -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-bootstrap</artifactId>
        </dependency>

        <!-- 注册中心 -->
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-loadbalancer</artifactId>
        </dependency>

        <!-- 配置中心 -->
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
        </dependency>

        <dependency>
            <groupId>com.ams</groupId>
            <artifactId>common-mybatis-plus</artifactId>
            <version>1.0.0</version>
        </dependency>
        <dependency>
            <groupId>com.ams</groupId>
            <artifactId>common-base</artifactId>
            <version>${
     ams.version}</version>
        </dependency>

        <dependency>
            <groupId>com.ams</groupId>
            <artifactId>common-web</artifactId>
            <version>${
     ams.version}</version>
        </dependency>

        <!-- openfeign依赖 1. http客户端选择okhttp 2. loadbalancer替换ribbon -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>

        <dependency>
            <groupId>io.github.openfeign</groupId>
            <artifactId>feign-okhttp</artifactId>
        </dependency>
        <!--seata 必备-->
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-seata</artifactId>
        </dependency>
    </dependencies>

修改父工程的打包方式为pom

创建账户子模块

在demo-seata下创建demo-account子模块

添加启动类

package com.ams.demo.seater.order;

import io.seata.config.springcloud.EnableSeataSpringConfig;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.openfeign.EnableFeignClients;

/**
 * Created with IntelliJ IDEA.
 *
 * @author： AI码师 关注公众号"AI码师"获取完整源码
 * @date： 2021/12/8
 * @description：
 * @modifiedBy：
 * @version: 1.0
 */
@SpringBootApplication(exclude = DataSourceAutoConfiguration.class)
@EnableDiscoveryClient
@EnableFeignClients
public class DemoOrderApp {
     
    public static void main(String[] args) {
     
        SpringApplication.run(DemoOrderApp.class, args);
    }
}

添加扣除余额接口

package com.ams.demo.seater.account.controller;

import com.ams.common.result.R;
import com.ams.demo.seater.account.service.AccountService;
import lombok.RequiredArgsConstructor;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

/**
 * Created with IntelliJ IDEA.
 *
 * @author： AI码师 关注公众号"AI码师"获取完整源码
 * @date： 2021/12/8
 * @description：
 * @modifiedBy：
 * @version: 1.0
 */
@RestController
@RequestMapping("/account")
@RequiredArgsConstructor
public class AccountController {
     
    private final AccountService accountService;

    @RequestMapping("/decrease")
    public R decrease(@RequestParam("userId") Long userId, @RequestParam("money") Integer money) {
     
        accountService.decrease(userId, money);
        return R.ok("余额扣减成功");
    }
}

创建bootstrap.yml

server:
  port: 20004

spring:
  application:
    name: ams-demo-account
  cloud:
    nacos:
      # 注册中心
      discovery:
        server-addr: http://你的nacos地址:8848
      # 配置中心
      config:
        server-addr: ${
     spring.cloud.nacos.discovery.server-addr}
        file-extension: yaml
        shared-configs[0]:
          data-id: ams-common.yaml
          refresh: true
    alibaba:
      seata:
        tx-service-group: demo-account

新增nacos配置

在nacos新增配置 ams-demo-account.yaml

spring:
  datasource:
    type: com.alibaba.druid.pool.DruidDataSource
    driver-class-name: com.mysql.cj.jdbc.Driver 
    url: jdbc:mysql://${mysql.host}:${mysql.port}/ams_account?zeroDateTimeBehavior=convertToNull&useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai&autoReconnect=true
    username: ${
     mysql.username}
    password: ${
     mysql.password}
  redis:
    database: 0
    host: ${
     redis.host}
    port: ${
     redis.port}
    password: ${
     redis.password}
  cache:
    # 缓存类型
    type: redis
    # 缓存时间(单位：ms)
    redis:
      time-to-live: 3600000
      # 缓存null值，防止缓存穿透
      cache-null-values: true
      # 允许使用缓存前缀，
      use-key-prefix: true
      # 缓存前缀，没有设置使用注解的缓存名称(value)作为前缀，和注解的key用双冒号::拼接组成完整缓存key
      key-prefix: 'admin:'
                
mybatis-plus:
  configuration:
    # 驼峰下划线转换
    map-underscore-to-camel-case: true
    # 这个配置会将执行的sql打印出来，在开发或测试的时候可以用
    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl

# 全局参数设置
ribbon:
  ReadTimeout: 120000
  ConnectTimeout: 10000
  SocketTimeout: 10000
  MaxAutoRetries: 0
  MaxAutoRetriesNextServer: 1 

feign:
  httpclient:
    enabled: true
  okhttp:
    enabled: false
#Seata分布式事务配置(AT模式)
seata:
  enabled: true
  application-id: ${
     spring.application.name}
  #客户端和服务端在同一个事务组
  tx-service-group: demo-account
  enable-auto-data-source-proxy: true
  service:
    vgroup-mapping:
      demo-account: default
  config:
    type: nacos
    nacos:
      namespace: "填写在安装seata时创建的命名空间"
      serverAddr: 你的nacos地址:8848
      group: SEATA_GROUP
      username: "nacos"
      password: "nacos"
  #服务注册到nacos
  registry:
    type: nacos
    nacos:
      application: seata-server
      server-addr: 你的nacos地址:8848
      group: SEATA_GROUP
      namespace: "public"
      username: "nacos"
      password: "nacos"
      cluster: default

创建库存子模块

在demo-seata下创建子模块 demo-storage

添加启动类

package com.ams.demo.seater.storage;

import io.seata.config.springcloud.EnableSeataSpringConfig;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;

/**
 * Created with IntelliJ IDEA.
 *
 * @author： AI码师 关注公众号"AI码师"获取完整源码
 * @date： 2021/12/8
 * @description：
 * @modifiedBy：
 * @version: 1.0
 */
@SpringBootApplication(exclude = DataSourceAutoConfiguration.class)
@EnableDiscoveryClient
@EnableSeataSpringConfig
public class DemoStorageApp {
     
    public static void main(String[] args) {
     
        SpringApplication.run(DemoStorageApp.class, args);
    }
}

添加扣除库存接口

package com.ams.demo.seater.storage.controller;

import com.ams.common.result.R;
import com.ams.demo.seater.storage.service.StorageService;
import lombok.RequiredArgsConstructor;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

/**
 * Created with IntelliJ IDEA.
 *
 * @author： AI码师 关注公众号"AI码师"获取完整源码
 * @date： 2021/12/8
 * @description：
 * @modifiedBy：
 * @version: 1.0
 */
@RestController
@RequestMapping("/storage")
@RequiredArgsConstructor
public class StorageController {
     
    private final StorageService storageService;

    @RequestMapping("/decrease")
    public R decrease(@RequestParam("productId") Long productId, @RequestParam("count") Integer count) {
     
        storageService.decrease(productId, count);
        return R.ok("库存扣减成功");
    }
}

创建bootstrap.yml

server:
  port: 20005

spring:
  application:
    name: ams-demo-storage
  cloud:
    nacos:
      # 注册中心
      discovery:
        server-addr: http://你的nacosip:8848
      # 配置中心
      config:
        server-addr: ${
     spring.cloud.nacos.discovery.server-addr}
        file-extension: yaml
        shared-configs[0]:
          data-id: ams-common.yaml
          refresh: true
    alibaba:
      seata:
        tx-service-group: demo-storage

新增nacos配置

在nacos新增配置 ams-demo-storage.yaml

spring:
  datasource:
    type: com.alibaba.druid.pool.DruidDataSource
    driver-class-name: com.mysql.cj.jdbc.Driver 
    url: jdbc:mysql://${
     mysql.host}:${
     mysql.port}/ams_storage?zeroDateTimeBehavior=convertToNull&useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai&autoReconnect=true
    username: ${
     mysql.username}
    password: ${
     mysql.password}
  redis:
    database: 0
    host: ${
     redis.host}
    port: ${
     redis.port}
    password: ${
     redis.password}
  cache:
    # 缓存类型
    type: redis
    # 缓存时间(单位：ms)
    redis:
      time-to-live: 3600000
      # 缓存null值，防止缓存穿透
      cache-null-values: true
      # 允许使用缓存前缀，
      use-key-prefix: true
      # 缓存前缀，没有设置使用注解的缓存名称(value)作为前缀，和注解的key用双冒号::拼接组成完整缓存key
      key-prefix: 'admin:'
                
mybatis-plus:
  configuration:
    # 驼峰下划线转换
    map-underscore-to-camel-case: true
    # 这个配置会将执行的sql打印出来，在开发或测试的时候可以用
    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl

# 全局参数设置
ribbon:
  ReadTimeout: 120000
  ConnectTimeout: 10000
  SocketTimeout: 10000
  MaxAutoRetries: 0
  MaxAutoRetriesNextServer: 1 

feign:
  httpclient:
    enabled: true
  okhttp:
    enabled: false
#Seata分布式事务配置(AT模式)
seata:
  enabled: true
  application-id: ${
     spring.application.name}
  #客户端和服务端在同一个事务组
  tx-service-group: demo-storage
  enable-auto-data-source-proxy: true
  service:
    vgroup-mapping:
      demo-storage: default
  config:
    type: nacos
    nacos:
      namespace: "填写在安装seata时创建的命名空间"
      serverAddr: 你的nacosip:8848
      group: SEATA_GROUP
      username: "nacos"
      password: "nacos"
  #服务注册到nacos
  registry:
    type: nacos
    nacos:
      application: seata-server
      server-addr: 你的nacosip:8848
      group: SEATA_GROUP
      namespace: "public"
      username: "nacos"
      password: "nacos"
      cluster: default

mybatis:
  mapperLocations: classpath:mapper/*.xml
logging:
  level:
    spring: info

创建订单子模块

在demo-seata下创建demo-order子模块

添加创建订单的接口

package com.ams.demo.seater.order.controller;

import com.ams.common.result.R;
import com.ams.demo.seater.order.entity.Order;
import com.ams.demo.seater.order.service.OrderService;
import lombok.RequiredArgsConstructor;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.List;

/**
 * Created with IntelliJ IDEA.
 *
 * @author： AI码师 关注公众号"AI码师"获取完整源码
 * @date： 2021/12/8
 * @description：
 * @modifiedBy：
 * @version: 1.0
 */
@RestController
@RequestMapping("/order")
@RequiredArgsConstructor
public class OrderController {
     
    private final OrderService orderService;

    @RequestMapping("/createOrder")
    public R createOrder() {
     
        orderService.createOrder();
        return R.ok("订单创建成功");
    }
}

添加创建订单的service

package com.ams.demo.seater.order.service.impl;

import com.ams.common.result.R;
import com.ams.demo.seater.order.dao.OrderMapper;
import com.ams.demo.seater.order.entity.Order;
import com.ams.demo.seater.order.service.AccountFeignService;
import com.ams.demo.seater.order.service.OrderService;
import com.ams.demo.seater.order.service.StorageFeignService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import io.seata.spring.annotation.GlobalTransactional;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;

/**
 * Created with IntelliJ IDEA.
 *
 * @author： AI码师 关注公众号"AI码师"获取完整源码
 * @date： 2021/11/24
 * @description：
 * @modifiedBy：
 * @version: 1.0
 */
@Service
@RequiredArgsConstructor
public class OrderServiceImpl extends ServiceImpl<OrderMapper, Order> implements OrderService {
     
    private final AccountFeignService accountFeignService;
    private final StorageFeignService storageFeignService;

    @Override
    @GlobalTransactional(name = "ams-create-order",rollbackFor = Exception.class)
    public R createOrder() {
     
        Order order = Order.builder()
                .count(10)
                .money(100)
                .productId(1L)
                .status(0)
                .userId(1L)
                .build();
        // 创建订单
        save(order);
        // 扣除库存
        storageFeignService.decrease(order.getProductId(), order.getCount());
        // 扣余额
        accountFeignService.decrease(order.getUserId(), order.getMoney());
        //更新订单状态
        order.setStatus(1);
        updateById(order);
        return R.ok();
    }
}

添加调用库存接口的feign

package com.ams.demo.seater.order.service;

import com.ams.common.result.R;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;

/**
 * 关注微信公众号"AI码师"获取项目源码及2021面试题一套
 *
 * @author: AI码师
 * Date: 2021/12/13 11:05 下午
 * Description:
 */
@FeignClient(value = "ams-demo-storage")
@RequestMapping("/storage")
public interface StorageFeignService {
     
    @RequestMapping("/decrease")
    public R decrease(@RequestParam("productId") Long productId, @RequestParam("count") Integer count);
}

添加调用账户接口的feign

package com.ams.demo.seater.order.service;

import com.ams.common.result.R;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;

/**
 * 关注微信公众号"AI码师"获取项目源码及2021面试题一套
 *
 * @author: AI码师
 * Date: 2021/12/13 11:05 下午
 * Description:
 */
@FeignClient(value = "ams-demo-account")
@RequestMapping("/account")
public interface AccountFeignService {
     
    @RequestMapping("/decrease")
    public R decrease(@RequestParam("userId") Long userId, @RequestParam("money") Integer money);
}

创建启动类

package com.ams.demo.seater.order;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.openfeign.EnableFeignClients;

/**
 * Created with IntelliJ IDEA.
 *
 * @author： AI码师 关注公众号"AI码师"获取完整源码
 * @date： 2021/12/8
 * @description：
 * @modifiedBy：
 * @version: 1.0
 */
@SpringBootApplication(exclude = DataSourceAutoConfiguration.class)
@EnableDiscoveryClient
@EnableFeignClients
public class DemoOrderApp {
     
    public static void main(String[] args) {
     
        SpringApplication.run(DemoOrderApp.class, args);
    }
}

创建bootstrap.yml

server:
  port: 20003

spring:
  application:
    name: ams-demo-order
  cloud:
    nacos:
      # 注册中心
      discovery:
        server-addr: http://你的nacos地址:8848
      # 配置中心
      config:
        server-addr: ${
     spring.cloud.nacos.discovery.server-addr}
        file-extension: yaml
        shared-configs[0]:
          data-id: ams-common.yaml
          refresh: true
    alibaba:
      seata:
        tx-service-group: demo-order

新增nacos配置

在naocs中创建ams-demo-order.yaml配置

spring:
  datasource:
    type: com.alibaba.druid.pool.DruidDataSource
    driver-class-name: com.mysql.cj.jdbc.Driver 
    url: jdbc:mysql://${
     mysql.host}:${
     mysql.port}/ams_order?zeroDateTimeBehavior=convertToNull&useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai&autoReconnect=true
    username: ${
     mysql.username}
    password: ${
     mysql.password}
  redis:
    database: 0
    host: ${
     redis.host}
    port: ${
     redis.port}
    password: ${
     redis.password}
  cache:
    # 缓存类型
    type: redis
    # 缓存时间(单位：ms)
    redis:
      time-to-live: 3600000
      # 缓存null值，防止缓存穿透
      cache-null-values: true
      # 允许使用缓存前缀，
      use-key-prefix: true
      # 缓存前缀，没有设置使用注解的缓存名称(value)作为前缀，和注解的key用双冒号::拼接组成完整缓存key
      key-prefix: 'admin:'
                
mybatis-plus:
  configuration:
    # 驼峰下划线转换
    map-underscore-to-camel-case: true
    # 这个配置会将执行的sql打印出来，在开发或测试的时候可以用
    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl

# 全局参数设置
ribbon:
  ReadTimeout: 120000
  ConnectTimeout: 10000
  SocketTimeout: 10000
  MaxAutoRetries: 0
  MaxAutoRetriesNextServer: 1 

feign:
  httpclient:
    enabled: true
  okhttp:
    enabled: false
#Seata分布式事务配置(AT模式)
seata:
  enabled: true
  application-id: ${
     spring.application.name}
  #客户端和服务端在同一个事务组
  tx-service-group: demo-order
  enable-auto-data-source-proxy: true
  service:
    vgroup-mapping:
      demo-order: default
  config:
    type: nacos
    nacos:
      namespace: "填写在安装seata时创建的命名空间"
      serverAddr: 你的nacos ip:8848
      group: SEATA_GROUP
      username: "nacos"
      password: "nacos"
  #服务注册到nacos
  registry:
    type: nacos
    nacos:
      application: seata-server
      server-addr: 你的nacos ip:8848
      group: SEATA_GROUP
      namespace: "public"
      username: "nacos"
      password: "nacos"
      cluster: default
logging:
  level:
    spring: info

创建回滚表

在每个业务数据库下面创建回滚表

CREATE TABLE `undo_log` (
  `branch_id` bigint(20) NOT NULL COMMENT 'branch transaction id',
  `xid` varchar(128) NOT NULL COMMENT 'global transaction id',
  `context` varchar(128) NOT NULL COMMENT 'undo_log context,such as serialization',
  `rollback_info` longblob NOT NULL COMMENT 'rollback info',
  `log_status` int(11) NOT NULL COMMENT '0:normal status,1:defense status',
  `log_created` datetime(6) NOT NULL COMMENT 'create datetime',
  `log_modified` datetime(6) NOT NULL COMMENT 'modify datetime',
  UNIQUE KEY `ux_undo_log` (`xid`,`branch_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='AT transaction mode undo table';

验证

启动是三个服务，请求：http://localhost:20003/order/createOrder,通过设置异常，观察是否全局回滚
​

作者：乐哥聊编程
来源链接：https://lglbc.blog.csdn.net/article/details/122149076

“SpringCloud实战｜8.SpringCloud 整合 seata1.3-估计是全网讲的最细的并且一次成功的” 的相关文章

springboot获取properties文件的配置内容(转载)

springboot获取properties文件的配置内容(转载)

  1、使用@Value注解读取读取properties配置文件时，默认读取的是application.properties。   applicat...

session和cookie的异同

两者的相同点： cookie和session都是能够保存顾客状态的技术，尽管两者属于不同的技术，但是只要cookie能够做到的，session也能...

solr配置方案

http://www.sjsjw.com/kf_cloud/article/44_5945_1823.asp CentOS下用Tomcat+Zookeepe...

Java常用属性拷贝工具类使用总结

Java常用属性拷贝工具类使用总结

综合功能和性能建议使用 ：org.springframework.beans.BeanUtils#copyProperties .这个方法在复制的时候不会因为属性的不同而报错，影响代码执...

使用WebService发布soap接口，并实现客户端的https验证

使用WebService发布soap接口，并实现客户端的https验证

什么是https HTTPS其实是有两部分组成：HTTP + SSL / TLS， 也就是在HTTP上又加了一层处理加密信息的模块，并且会进行身份的验证。 如何进行身份...

关于C#泛型列表List的基本用法总结

//示例代码如下：using System;using System.Collections.Generic;using System.Collections.ObjectModel;n...

java第二天笔记

Unit2 类和对象 20211022周五 一、什么是类？ 同类对象的概括。类是抽象的，不具体 类就是类型。 二、什么是对象？ 具体事务。万物皆对象：对象是具体的...

关于Springboot使用Junit测试时,如何控制测试数据Rollback和Commit

关于Springboot使用Junit测试时,如何控制测试数据Rollback和Commit

要保证Springboot框架回滚数据,则数据库的事务管理需要由事务管理需要由Spring框架来控制,此外,测试类需要添加事务注解.    ...

什么是JDK？

1、Java Development Kit（Java 开发工具包）的缩写。用于 java 程序的开发，提供给程序员使用 2、使用 Java 语言编程都需要在计算机上安装一个 JDK 3...

线程八股文--藤原豆腐店自用

线程八股文--藤原豆腐店自用

目录 1.什么是进程、什么是线程，他们之间是什么关系？ 1.1.进程是什么？ 1.2.线程是什么？ 1.什么是进程、什...

本站是一个非赢利性的网站,目的是为大家提供各类优秀的编程资源，所有的资源都是网友推荐或从互联网上收集整理到的，如果有侵犯您版权的请与我们联系，我们会尽快改正。

Powered By Z-BlogPHP. Theme by TOYEAN.