transport {  # tcp udt unix-domain-socket  type = "TCP"  #NIO NATIVE  server = "NIO"  #enable heartbeat  heartbeat = true  #thread factory for netty  thread-factory {    boss-thread-prefix = "NettyBoss"    worker-thread-prefix = "NettyServerNIOWorker"    server-executor-thread-prefix = "NettyServerBizHandler"    share-boss-worker = false    client-selector-thread-prefix = "NettyClientSelector"    client-selector-thread-size = 1    client-worker-thread-prefix = "NettyClientWorkerThread"    # netty boss thread size,will not be used for UDT    boss-thread-size = 1    #auto default pin or 8    worker-thread-size = 8  }  shutdown {    # when destroy server, wait seconds    wait = 3  }  serialization = "seata"  compressor = "none"}service {  #vgroup->rgroup  #vgroup_mapping.my_test_tx_group = "default"  vgroup_mapping.my_test_tx_group = "hspedu_order_tx_group"  #only support single node  default.grouplist = "127.0.0.1:8091"  #degrade current not support  enableDegrade = false  #disable  disable = false  #unit ms,s,m,h,d represents milliseconds, seconds, minutes, hours, days, default permanent  max.commit.retry.timeout = "-1"  max.rollback.retry.timeout = "-1"}
client {  async.commit.buffer.limit = 10000  lock {    retry.internal = 10    retry.times = 30  }  report.retry.count = 5  tm.commit.retry.count = 1  tm.rollback.retry.count = 1}
## transaction log storestore {  ## store mode: file、db  ## mode = "file"  mode = "db"
  ## file store  file {    dir = "sessionStore"
    # branch session size , if exceeded first try compress lockkey, still exceeded throws exceptions    max-branch-session-size = 16384    # globe session size , if exceeded throws exceptions    max-global-session-size = 512    # file buffer size , if exceeded allocate new buffer    file-write-buffer-cache-size = 16384    # when recover batch read size    session.reload.read_size = 100    # async, sync    flush-disk-mode = async  }
  ## database store  db {    ## the implement of javax.sql.DataSource, such as DruidDataSource(druid)/BasicDataSource(dbcp) etc.    datasource = "dbcp"    ## mysql/oracle/h2/oceanbase etc.    db-type = "mysql"    ## driver-class-name = "com.mysql.jdbc.Driver"    driver-class-name = "com.mysql.cj.jdbc.Driver"    ## url = "jdbc:mysql://127.0.0.1:3306/seata"    url = "jdbc:mysql://127.0.0.1:3306/seata?characterEncoding=utf8&useSSL=false&serverTimezone=UTC&rewriteBatchedStatements=true"    ## user = "mysql"    user = "root"    ## password = "mysql"    password = "MySQL123"    min-conn = 1    max-conn = 3    global.table = "global_table"    branch.table = "branch_table"    lock-table = "lock_table"    query-limit = 100  }}lock {  ## the lock store mode: local、remote  mode = "remote"
  local {    ## store locks in user's database  }
  remote {    ## store locks in the seata's server  }}recovery {  #schedule committing retry period in milliseconds  committing-retry-period = 1000  #schedule asyn committing retry period in milliseconds  asyn-committing-retry-period = 1000  #schedule rollbacking retry period in milliseconds  rollbacking-retry-period = 1000  #schedule timeout retry period in milliseconds  timeout-retry-period = 1000}
transaction {  undo.data.validation = true  undo.log.serialization = "jackson"  undo.log.save.days = 7  #schedule delete expired undo_log in milliseconds  undo.log.delete.period = 86400000  undo.log.table = "undo_log"}
## metrics settingsmetrics {  enabled = false  registry-type = "compact"  # multi exporters use comma divided  exporter-list = "prometheus"  exporter-prometheus-port = 9898}
support {  ## spring  spring {    # auto proxy the DataSource bean    datasource.autoproxy = false  }}

驱动的名称：com.mysql.cj.jdbc.Driverurl地址：“jdbc:mysql://127.0.0.1:3306/seata?characterEncoding=utf8&useSSL=false&serverTimezone=UTC&rewriteBatchedStatements=true”

CREATE DATABASE seataUSE seata

-- the table to store GlobalSession datadrop table if exists `global_table`;create table `global_table` (  `xid` varchar(128)  not null,  `transaction_id` bigint,  `status` tinyint not null,  `application_id` varchar(32),  `transaction_service_group` varchar(32),  `transaction_name` varchar(128),  `timeout` int,  `begin_time` bigint,  `application_data` varchar(2000),  `gmt_create` datetime,  `gmt_modified` datetime,  primary key (`xid`),  key `idx_gmt_modified_status` (`gmt_modified`, `status`),  key `idx_transaction_id` (`transaction_id`));
-- the table to store BranchSession datadrop table if exists `branch_table`;create table `branch_table` (  `branch_id` bigint not null,  `xid` varchar(128) not null,  `transaction_id` bigint ,  `resource_group_id` varchar(32),  `resource_id` varchar(256) ,  `lock_key` varchar(128) ,  `branch_type` varchar(8) ,  `status` tinyint,  `client_id` varchar(64),  `application_data` varchar(2000),  `gmt_create` datetime,  `gmt_modified` datetime,  primary key (`branch_id`),  key `idx_xid` (`xid`));
-- the table to store lock datadrop table if exists `lock_table`;create table `lock_table` (  `row_key` varchar(128) not null,  `xid` varchar(96),  `transaction_id` long ,  `branch_id` long,  `resource_id` varchar(256) ,  `table_name` varchar(32) ,  `pk` varchar(36) ,  `gmt_create` datetime ,  `gmt_modified` datetime,  primary key(`row_key`));

registry {  # file 、nacos 、eureka、redis、zk、consul、etcd3、sofa  # type = "file"  type = "nacos"
  nacos {    # serverAddr = "localhost"    serverAddr = "localhost:8848"    namespace = ""    cluster = "default"  }

--  订单微服务的数据库CREATE DATABASE order_micro_service USE order_micro_service
CREATE TABLE `order`(id BIGINT NOT NULL AUTO_INCREMENT PRIMARY KEY,user_id BIGINT DEFAULT NULL ,product_id BIGINT DEFAULT NULL ,nums INT DEFAULT NULL ,money INT DEFAULT NULL,`status` INT DEFAULT NULL COMMENT '0：创建中; 1：已完结' );
SELECT * FROM `order`


-- 库存微服务的数据库`storage``order` CREATE DATABASE storage_micro_service USE storage_micro_service
CREATE TABLE `storage`(id BIGINT NOT NULL AUTO_INCREMENT PRIMARY KEY, product_id BIGINT DEFAULT NULL ,amount INT DEFAULT NULL COMMENT '库存量' );
--  初始化库存表INSERT INTO `storage` VALUES(NULL, 1, 10); 
SELECT * FROM `storage`
--  账号微服务的数据库CREATE DATABASE account_micro_service USE account_micro_service
CREATE TABLE `account`(id BIGINT NOT NULL AUTO_INCREMENT PRIMARY KEY , user_id BIGINT DEFAULT NULL ,money INT DEFAULT NULL COMMENT '账户金额' );
--  初始化账户表INSERT INTO `account` VALUES(NULL, 666, 10000);
SELECT * from `account`

-- the table to store seata xid data-- 0.7.0+ add context-- you must to init this sql for you business databese. the seata server not need it.-- 此脚本必须初始化在你当前的业务数据库中，用于AT 模式XID记录。与server端无关（注：业务数据库）-- 注意此处0.3.0+ 增加唯一索引 ux_undo_logdrop table `undo_log`;CREATE TABLE `undo_log` (  `id` bigint(20) NOT NULL AUTO_INCREMENT,  `branch_id` bigint(20) NOT NULL,  `xid` varchar(100) NOT NULL,  `context` varchar(128) NOT NULL,  `rollback_info` longblob NOT NULL,  `log_status` int(11) NOT NULL,  `log_created` datetime NOT NULL,  `log_modified` datetime NOT NULL,  `ext` varchar(100) DEFAULT NULL,  PRIMARY KEY (`id`),  UNIQUE KEY `ux_undo_log` (`xid`,`branch_id`)) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;

-- the table to store seata xid data-- 0.7.0+ add context-- you must to init this sql for you business databese. the seata server not need it.-- 此脚本必须初始化在你当前的业务数据库中，用于AT 模式XID记录。与server端无关（注：业务数据库）-- 注意此处0.3.0+ 增加唯一索引 ux_undo_logdrop table `undo_log`;CREATE TABLE `undo_log` (  `id` bigint(20) NOT NULL AUTO_INCREMENT,  `branch_id` bigint(20) NOT NULL,  `xid` varchar(100) NOT NULL,  `context` varchar(128) NOT NULL,  `rollback_info` longblob NOT NULL,  `log_status` int(11) NOT NULL,  `log_created` datetime NOT NULL,  `log_modified` datetime NOT NULL,  `ext` varchar(100) DEFAULT NULL,  PRIMARY KEY (`id`),  UNIQUE KEY `ux_undo_log` (`xid`,`branch_id`)) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;
```
```sql


use order_micro_service	CREATE TABLE `undo_log` (  `id` bigint(20) NOT NULL AUTO_INCREMENT,  `branch_id` bigint(20) NOT NULL,  `xid` varchar(100) NOT NULL,  `context` varchar(128) NOT NULL,  `rollback_info` longblob NOT NULL,  `log_status` int(11) NOT NULL,  `log_created` datetime NOT NULL,  `log_modified` datetime NOT NULL,  `ext` varchar(100) DEFAULT NULL,  PRIMARY KEY (`id`),  UNIQUE KEY `ux_undo_log` (`xid`,`branch_id`)) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;



use storage_micro_serviceCREATE TABLE `undo_log` (  `id` bigint(20) NOT NULL AUTO_INCREMENT,  `branch_id` bigint(20) NOT NULL,  `xid` varchar(100) NOT NULL,  `context` varchar(128) NOT NULL,  `rollback_info` longblob NOT NULL,  `log_status` int(11) NOT NULL,  `log_created` datetime NOT NULL,  `log_modified` datetime NOT NULL,  `ext` varchar(100) DEFAULT NULL,  PRIMARY KEY (`id`),  UNIQUE KEY `ux_undo_log` (`xid`,`branch_id`)) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;



use account_micro_serviceCREATE TABLE `undo_log` (  `id` bigint(20) NOT NULL AUTO_INCREMENT,  `branch_id` bigint(20) NOT NULL,  `xid` varchar(100) NOT NULL,  `context` varchar(128) NOT NULL,  `rollback_info` longblob NOT NULL,  `log_status` int(11) NOT NULL,  `log_created` datetime NOT NULL,  `log_modified` datetime NOT NULL,  `ext` varchar(100) DEFAULT NULL,  PRIMARY KEY (`id`),  UNIQUE KEY `ux_undo_log` (`xid`,`branch_id`)) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;

<?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">    <parent>        <artifactId>e-commerce-center</artifactId>        <groupId>com.rainbowsea</groupId>        <version>1.0-SNAPSHOT</version>    </parent>    <modelVersion>4.0.0</modelVersion>
    <artifactId>seata_account_micro_service-10012</artifactId>


    <!--    引入相关的依赖：我们引入了当前所需要的依赖，后面如果有其它的需要，再灵活添加-->    <dependencies>
        <!--        引入 seata starter -->        <dependency>            <groupId>com.alibaba.cloud</groupId>            <artifactId>spring-cloud-starter-alibaba-seata</artifactId>            <exclusions>                <!-- 排除自带的 seata-all ，引入自己的版本，否则会出现冲突 -->                <exclusion>                    <artifactId>seata-all</artifactId>                    <groupId>io.seata</groupId>                </exclusion>            </exclusions>        </dependency>        <!--        引入指定的版本 seata-all-->        <dependency>            <groupId>io.seata</groupId>            <artifactId>seata-all</artifactId>            <version>0.9.0</version>        </dependency>
        <!-- 提示 application.yml -->        <!--        <dependency>-->        <!--            <groupId>org.springframework.boot</groupId>-->        <!--            <artifactId>spring-boot-configuration-processor</artifactId>-->        <!--            <optional>true</optional>-->        <!--        </dependency>-->
        <!--        整合Openfeign -->        <!--        引入 openfeign starter 即场景启动器 starter-->        <dependency>            <groupId>org.springframework.cloud</groupId>            <artifactId>spring-cloud-starter-openfeign</artifactId>        </dependency>
        <!--引入 alibaba-nacos -discovery   -->        <dependency>            <groupId>com.alibaba.cloud</groupId>            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>        </dependency>
        <!--        引入 web-starter 说明：我们使用版本仲裁(从父项目继承了版本)-->        <dependency>            <groupId>org.springframework.boot</groupId>            <artifactId>spring-boot-starter-web</artifactId>        </dependency>
        <!--1. starter-actuator 是sprng boot 程序的监控系统,可以实现健康检查,info 信息等         2. 访问http://localhost:10000/actuator 可以看到相关链接,还可以做相关配置-->        <dependency>            <groupId>org.springframework.boot</groupId>            <artifactId>spring-boot-starter-actuator</artifactId>        </dependency>

        <!--        lombok 引入-->        <dependency>            <groupId>org.projectlombok</groupId>            <artifactId>lombok</artifactId>            <optional>true</optional>        </dependency>
        <!--        引入 test-starter -->        <dependency>            <groupId>org.springframework.boot</groupId>            <artifactId>spring-boot-starter-test</artifactId>            <scope>test</scope>        </dependency>
        <!--        引入我们自己对 bean 封装成 api 的模块内容-->        <dependency>            <groupId>com.rainbowsea</groupId>            <artifactId>e_commerce_center-common-api</artifactId>            <version>${project.version}</version>        </dependency>

        <!--        引入 mybatis  -->        <dependency>            <groupId>org.mybatis.spring.boot</groupId>            <artifactId>mybatis-spring-boot-starter</artifactId>        </dependency>
        <!--        引入 mysql-->        <dependency>            <groupId>mysql</groupId>            <artifactId>mysql-connector-java</artifactId>        </dependency>

        <!--        引入 jdbc -->        <dependency>            <groupId>org.springframework.boot</groupId>            <artifactId>spring-boot-starter-jdbc</artifactId>        </dependency>
        <!--        druid 数据库连接池 -->        <dependency>            <groupId>com.alibaba</groupId>            <artifactId>druid-spring-boot-starter</artifactId>            <!-- 这里我们重新指定一下 version -->            <version>1.1.13</version>        </dependency>
    </dependencies>
</project>

server:  port: 10012spring:  application:    name: seata-account-micro-service  cloud:    alibaba:      seata:        # 指定事务组名，需要和 seata-server中的对应 /conf/file.conf 当中的匹配        #  vgroup_mapping.my_test_tx_group = "hspedu_order_tx_group"        tx-service-group: hspedu_order_tx_group    nacos:      discovery:        server-addr: localhost:8848 # 指定 nacos server 地址  datasource:    driver-class-name: com.mysql.cj.jdbc.Driver # 注意: 这里我们配置的是 mysql8.0版本的    url: jdbc:mysql://localhost:3306/account_micro_service?characterEncoding=utf8&useSSL=false&serverTimezone=UTC&rewriteBatchedStatements=true    username: root    password: MySQL123# 配置 seata日志输出logging:  level:    io:      seata: info
mybatis:  mapperLocations: classpath:mapper/*.xml

transport {  # tcp udt unix-domain-socket  type = "TCP"  #NIO NATIVE  server = "NIO"  #enable heartbeat  heartbeat = true  #thread factory for netty  thread-factory {    boss-thread-prefix = "NettyBoss"    worker-thread-prefix = "NettyServerNIOWorker"    server-executor-thread-prefix = "NettyServerBizHandler"    share-boss-worker = false    client-selector-thread-prefix = "NettyClientSelector"    client-selector-thread-size = 1    client-worker-thread-prefix = "NettyClientWorkerThread"    # netty boss thread size,will not be used for UDT    boss-thread-size = 1    #auto default pin or 8    worker-thread-size = 8  }  shutdown {    # when destroy server, wait seconds    wait = 3  }  serialization = "seata"  compressor = "none"}service {  #vgroup->rgroup  #vgroup_mapping.my_test_tx_group = "default"  vgroup_mapping.hspedu_order_tx_group = "default"  #only support single node  default.grouplist = "127.0.0.1:8091"  #degrade current not support  enableDegrade = false  #disable  disable = false  #unit ms,s,m,h,d represents milliseconds, seconds, minutes, hours, days, default permanent  max.commit.retry.timeout = "-1"  max.rollback.retry.timeout = "-1"}
client {  async.commit.buffer.limit = 10000  lock {    retry.internal = 10    retry.times = 30  }  report.retry.count = 5  tm.commit.retry.count = 1  tm.rollback.retry.count = 1}
## transaction log storestore {  ## store mode: file、db  ## mode = "file"  mode = "db"
  ## file store  file {    dir = "sessionStore"
    # branch session size , if exceeded first try compress lockkey, still exceeded throws exceptions    max-branch-session-size = 16384    # globe session size , if exceeded throws exceptions    max-global-session-size = 512    # file buffer size , if exceeded allocate new buffer    file-write-buffer-cache-size = 16384    # when recover batch read size    session.reload.read_size = 100    # async, sync    flush-disk-mode = async  }
  ## database store  db {    ## the implement of javax.sql.DataSource, such as DruidDataSource(druid)/BasicDataSource(dbcp) etc.    datasource = "dbcp"    ## mysql/oracle/h2/oceanbase etc.    db-type = "mysql"    ## driver-class-name = "com.mysql.jdbc.Driver"    driver-class-name = "com.mysql.cj.jdbc.Driver"    ## url = "jdbc:mysql://127.0.0.1:3306/seata"    url = "jdbc:mysql://127.0.0.1:3306/seata?characterEncoding=utf8&useSSL=false&serverTimezone=UTC&rewriteBatchedStatements=true"    ## user = "mysql"    user = "root"    ## password = "mysql"    password = "MySQL123"    min-conn = 1    max-conn = 3    global.table = "global_table"    branch.table = "branch_table"    lock-table = "lock_table"    query-limit = 100  }}lock {  ## the lock store mode: local、remote  mode = "remote"
  local {    ## store locks in user's database  }
  remote {    ## store locks in the seata's server  }}recovery {  #schedule committing retry period in milliseconds  committing-retry-period = 1000  #schedule asyn committing retry period in milliseconds  asyn-committing-retry-period = 1000  #schedule rollbacking retry period in milliseconds  rollbacking-retry-period = 1000  #schedule timeout retry period in milliseconds  timeout-retry-period = 1000}
transaction {  undo.data.validation = true  undo.log.serialization = "jackson"  undo.log.save.days = 7  #schedule delete expired undo_log in milliseconds  undo.log.delete.period = 86400000  undo.log.table = "undo_log"}
## metrics settingsmetrics {  enabled = false  registry-type = "compact"  # multi exporters use comma divided  exporter-list = "prometheus"  exporter-prometheus-port = 9898}
support {  ## spring  spring {    # auto proxy the DataSource bean    datasource.autoproxy = false  }}

registry {  # file 、nacos 、eureka、redis、zk、consul、etcd3、sofa  # type = "file"  type = "nacos"
  nacos {    # serverAddr = "localhost"    serverAddr = "localhost:8848"    namespace = ""    cluster = "default"  }  eureka {    serviceUrl = "http://localhost:8761/eureka"    application = "default"    weight = "1"  }  redis {    serverAddr = "localhost:6379"    db = "0"  }  zk {    cluster = "default"    serverAddr = "127.0.0.1:2181"    session.timeout = 6000    connect.timeout = 2000  }  consul {    cluster = "default"    serverAddr = "127.0.0.1:8500"  }  etcd3 {    cluster = "default"    serverAddr = "http://localhost:2379"  }  sofa {    serverAddr = "127.0.0.1:9603"    application = "default"    region = "DEFAULT_ZONE"    datacenter = "DefaultDataCenter"    cluster = "default"    group = "SEATA_GROUP"    addressWaitTime = "3000"  }  file {    name = "file.conf"  }}
config {  # file、nacos 、apollo、zk、consul、etcd3  type = "file"
  nacos {    serverAddr = "localhost"    namespace = ""  }  consul {    serverAddr = "127.0.0.1:8500"  }  apollo {    app.id = "seata-server"    apollo.meta = "http://192.168.1.204:8801"  }  zk {    serverAddr = "127.0.0.1:2181"    session.timeout = 6000    connect.timeout = 2000  }  etcd3 {    serverAddr = "http://localhost:2379"  }  file {    name = "file.conf"  }}

package com.rainbowsea.springcloud.config;

import org.mybatis.spring.annotation.MapperScan;import org.springframework.context.annotation.Configuration;

/** * 常规配置: MyBatis 和 dao 关联 */@Configuration@MapperScan({"com.rainbowsea.springcloud.dao"})public class MyBatisConfig {}

package com.rainbowsea.springcloud.config;

import com.alibaba.druid.pool.DruidDataSource;import io.seata.rm.datasource.DataSourceProxy;import org.apache.ibatis.session.SqlSessionFactory;import org.mybatis.spring.SqlSessionFactoryBean;import org.mybatis.spring.transaction.SpringManagedTransactionFactory;import org.springframework.beans.factory.annotation.Value;import org.springframework.boot.context.properties.ConfigurationProperties;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
import javax.sql.DataSource;
/** * 1.这里很重要: 配置数据源的代理是 seata 也就是使用 seata 代理数据源 * 2. DataSourceProxy 是引入的 io.seata.rm.datasource */@Configurationpublic class DataSourceProxyConfig {
    @Value("${mybatis.mapperLocations}")  // 读取applicaton.yaml 配置文件当中的信息，通过前缀名    private String mapperLocations;
    //配置druidDataSource    @Bean    @ConfigurationProperties(prefix = "spring.datasource")    public DataSource druidDataSource() {        /*DruidDataSource druidDataSource = new DruidDataSource();        System.out.println("druidDataSource.hashcoder = " + druidDataSource.hashCode());        return druidDataSource;*/        return new DruidDataSource();    }
    //配置DataSourceProxy- 使用seata代理数据源    @Bean    public DataSourceProxy dataSourceProxy(DataSource dataSource) {        // 注意是: io.seata.rm.datasource.DataSourceProxy; 包下的内容        /*System.out.println("dataSourceProxy()中的 datasour.hashcode = " + dataSource.hashCode());        DataSourceProxy dataSourceProxy = new DataSourceProxy(dataSource);        System.out.println("dataSourceProxy()中的dataSourceProxy。hashcode= " + dataSourceProxy.hashCode());        return dataSourceProxy;*/        return new DataSourceProxy(dataSource);    }
    //配置SqlSessionFactory-常规写法    @Bean    public SqlSessionFactory sqlSessionFactoryBean(DataSourceProxy dataSourceProxy)            throws Exception {        //System.out.println("sqlSessionFactoryBean 中的 dataSourceProxy.hashcode = " + dataSourceProxy.hashCode());        SqlSessionFactoryBean sqlSessionFactoryBean =                new SqlSessionFactoryBean();        sqlSessionFactoryBean.setDataSource(dataSourceProxy);        sqlSessionFactoryBean.setMapperLocations                (new PathMatchingResourcePatternResolver().getResources(mapperLocations));        sqlSessionFactoryBean.setTransactionFactory                (new SpringManagedTransactionFactory());        return sqlSessionFactoryBean.getObject();    }}

package com.rainbowsea.springcloud;

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;
@EnableFeignClients@EnableDiscoveryClient@SpringBootApplication(exclude = DataSourceAutoConfiguration.class) // 排除自动配置数据源，让seata 代理配置public class SeataAccountMicroServiceApplication10012 {    public static void main(String[] args) {        SpringApplication.run(SeataAccountMicroServiceApplication10012.class,args);    }}

package com.rainbowsea.springcloud.service;

import com.rainbowsea.springcloud.entity.Result;import org.springframework.cloud.openfeign.FeignClient;import org.springframework.web.bind.annotation.PostMapping;import org.springframework.web.bind.annotation.RequestParam;
@FeignClient(value = "seata-storage-micro-service")  // 表示使用opFeign与分布式多个微服务通信// value 是配置在 nacos 当中显示的 服务名(也是配置在 对应微服务applicaton 当中的 name 服务名)，不可随便写public interface StorageService {
    /**     * 1.远程调用方式是post     * 2. 远程调用的 url 为 : http://@FeignClient(value = "seata_storage_micro_service")/storage/reduce（@PostMapping("/storage/reduce")）     * 3. seata_storage_micro_service 是 nacos 注册中心服务名     * 4. openfeign 会根据负载均衡算法来决定调用的是 : 10004/10006,默认是轮询算法     * 5. openfeign 是通过接口方式调用服务     * 6. 特别注意: 该方法要和对应微服务模块当中的 controller 的方法一致(参数，post,方法名,返回类型等)     *     * @param productId     * @param nums     * @return     */    // 扣减库存    @PostMapping("/storage/reduce")    Result reduce(@RequestParam("productId") Long productId, @RequestParam("nums") Integer nums);}

package com.rainbowsea.springcloud.controller;

import com.rainbowsea.springcloud.entity.Result;import com.rainbowsea.springcloud.service.AccountService;import org.springframework.web.bind.annotation.PostMapping;import org.springframework.web.bind.annotation.RequestParam;import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
@RestControllerpublic class AccountController {
    @Resource    AccountService accountService;
    @PostMapping("/account/reduce")    public Result reduce(@RequestParam("userId") Long userId, @RequestParam("money") Integer money) {        //模拟异常,超时        //openfeign 接口调用默认超时时间为1s/*        try {            TimeUnit.SECONDS.sleep(12);        } catch (InterruptedException e) {            e.printStackTrace();        }*/        accountService.reduce(userId, money);        return Result.success("200", "扣减账户余额OK");    }}