• spring cloud alibaba 集成seata

    1.启动服务端

            1.下载 seata-server-1.4.2

            2.创建数据库

             

    1. DROP DATABASE IF EXISTS `ry-seata`;
    2.  
    3. CREATE DATABASE  `ry-seata` DEFAULT CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci;
    4.  
    5. SET NAMES utf8mb4;
    6. SET FOREIGN_KEY_CHECKS = 0;
    7.  
    8. USE `ry-seata`;
    9.  
    10. -- -------------------------------- The script used when storeMode is 'db' --------------------------------
    11. -- the table to store GlobalSession data
    12. CREATE TABLE IF NOT EXISTS `global_table`
    13. (
    14.     `xid`                       VARCHAR(128) NOT NULL,
    15.     `transaction_id`            BIGINT,
    16.     `status`                    TINYINT      NOT NULL,
    17.     `application_id`            VARCHAR(32),
    18.     `transaction_service_group` VARCHAR(32),
    19.     `transaction_name`          VARCHAR(128),
    20.     `timeout`                   INT,
    21.     `begin_time`                BIGINT,
    22.     `application_data`          VARCHAR(2000),
    23.     `gmt_create`                DATETIME,
    24.     `gmt_modified`              DATETIME,
    25.     PRIMARY KEY (`xid`),
    26.     KEY `idx_gmt_modified_status` (`gmt_modified`, `status`),
    27.     KEY `idx_transaction_id` (`transaction_id`)
    28. ) ENGINE = InnoDB
    29.   DEFAULT CHARSET = utf8mb4;
    30.  
    31. -- the table to store BranchSession data
    32. CREATE TABLE IF NOT EXISTS `branch_table`
    33. (
    34.     `branch_id`         BIGINT       NOT NULL,
    35.     `xid`               VARCHAR(128) NOT NULL,
    36.     `transaction_id`    BIGINT,
    37.     `resource_group_id` VARCHAR(32),
    38.     `resource_id`       VARCHAR(256),
    39.     `branch_type`       VARCHAR(8),
    40.     `status`            TINYINT,
    41.     `client_id`         VARCHAR(64),
    42.     `application_data`  VARCHAR(2000),
    43.     `gmt_create`        DATETIME(6),
    44.     `gmt_modified`      DATETIME(6),
    45.     PRIMARY KEY (`branch_id`),
    46.     KEY `idx_xid` (`xid`)
    47. ) ENGINE = InnoDB
    48.   DEFAULT CHARSET = utf8mb4;
    49.  
    50. -- the table to store lock data
    51. CREATE TABLE IF NOT EXISTS `lock_table`
    52. (
    53.     `row_key`        VARCHAR(128) NOT NULL,
    54.     `xid`            VARCHAR(96),
    55.     `transaction_id` BIGINT,
    56.     `branch_id`      BIGINT       NOT NULL,
    57.     `resource_id`    VARCHAR(256),
    58.     `table_name`     VARCHAR(32),
    59.     `pk`             VARCHAR(36),
    60.     `gmt_create`     DATETIME,
    61.     `gmt_modified`   DATETIME,
    62.     PRIMARY KEY (`row_key`),
    63.     KEY `idx_branch_id` (`branch_id`)
    64. ) ENGINE = InnoDB
    65.   DEFAULT CHARSET = utf8mb4;

            3.填写配置

            seata-server-1.4.2/conf/registry.conf

    1. registry {
    2.   # file 、nacos 、eureka、redis、zk、consul、etcd3、sofa
    3.   type = "nacos"
    4.  
    5.   nacos {
    6.     application = "seata-server"
    7.     serverAddr = "127.0.0.1:8848"
    8.     group = "DEFAULT_GROUP"
    9.     namespace = ""
    10.     cluster = "DEFAULT"
    11.     username = "nacos"
    12.     password = "nacos"
    13.   }
    14.   eureka {
    15.     serviceUrl = "http://localhost:8761/eureka"
    16.     application = "default"
    17.     weight = "1"
    18.   }
    19.   redis {
    20.     serverAddr = "localhost:6379"
    21.     db = 0
    22.     password = ""
    23.     cluster = "default"
    24.     timeout = 0
    25.   }
    26.   zk {
    27.     cluster = "default"
    28.     serverAddr = "127.0.0.1:2181"
    29.     sessionTimeout = 6000
    30.     connectTimeout = 2000
    31.     username = ""
    32.     password = ""
    33.   }
    34.   consul {
    35.     cluster = "default"
    36.     serverAddr = "127.0.0.1:8500"
    37.     aclToken = ""
    38.   }
    39.   etcd3 {
    40.     cluster = "default"
    41.     serverAddr = "http://localhost:2379"
    42.   }
    43.   sofa {
    44.     serverAddr = "127.0.0.1:9603"
    45.     application = "default"
    46.     region = "DEFAULT_ZONE"
    47.     datacenter = "DefaultDataCenter"
    48.     cluster = "default"
    49.     group = "SEATA_GROUP"
    50.     addressWaitTime = "3000"
    51.   }
    52.   file {
    53.     name = "file.conf"
    54.   }
    55. }
    56.  
    57. config {
    58.   # file、nacos 、apollo、zk、consul、etcd3
    59.   type = "nacos"
    60.  
    61.   nacos {
    62.     serverAddr = "127.0.0.1:8848"
    63.     namespace = ""
    64.     group = "SEATA_GROUP"
    65.     username = "nacos"
    66.     password = "nacos"
    67.     dataId = "seataServer.properties"
    68.   }
    69.   consul {
    70.     serverAddr = "127.0.0.1:8500"
    71.     aclToken = ""
    72.   }
    73.   apollo {
    74.     appId = "seata-server"
    75.     ## apolloConfigService will cover apolloMeta
    76.     apolloMeta = "http://192.168.1.204:8801"
    77.     apolloConfigService = "http://192.168.1.204:8080"
    78.     namespace = "application"
    79.     apolloAccesskeySecret = ""
    80.     cluster = "seata"
    81.   }
    82.   zk {
    83.     serverAddr = "127.0.0.1:2181"
    84.     sessionTimeout = 6000
    85.     connectTimeout = 2000
    86.     username = ""
    87.     password = ""
    88.     nodePath = "/seata/seata.properties"
    89.   }
    90.   etcd3 {
    91.     serverAddr = "http://localhost:2379"
    92.   }
    93.   file {
    94.     name = "file.conf"
    95.   }
    96. }

            4.nacos中seata的配置文件seataServer.properties内容

            

    1. store.mode=db
    2. store.db.datasource=druid
    3. store.db.dbType=mysql
    4. store.db.driverClassName=com.mysql.jdbc.Driver
    5. store.db.url=jdbc:mysql://127.0.0.1:3306/ry-seata?rewriteBatchedStatements=true
    6. store.db.user=root
    7. store.db.password=123456
    8. store.db.minConn=5
    9. store.db.maxConn=30
    10. store.db.globalTable=global_table
    11. store.db.branchTable=branch_table
    12. store.db.queryLimit=100
    13. store.db.lockTable=lock_table
    14. store.db.maxWait=5000

            5.运行服务端

            seata-server.bat -h 192.168.1.5

            启动成功

    2.配置微服务项目

            1.引入依赖

            

    1. <!-- SpringBoot Seata -->
    2.         <dependency>
    3.             <groupId>com.alibaba.cloud</groupId>
    4.             <artifactId>spring-cloud-starter-alibaba-seata</artifactId>
    5.             <version>2.2.5.RELEASE</version>
    6.             <exclusions>
    7.                 <exclusion>
    8.                     <groupId>io.seata</groupId>
    9.                     <artifactId>seata-spring-boot-starter</artifactId>
    10.                 </exclusion>
    11.             </exclusions>
    12.         </dependency>
    13.  
    14.         <dependency>
    15.             <groupId>io.seata</groupId>
    16.             <artifactId>seata-spring-boot-starter</artifactId>
    17.             <version>1.4.2</version>
    18.         </dependency>

            2.修改微服务的配置文件

            

    1. # seata配置
    2. seata:
    3.   # 默认关闭，如需启用spring.datasource.dynami.seata需要同时开启
    4.   enabled: true
    5.   # Seata 应用编号，默认为 ${spring.application.name}
    6.   application-id: seata-server
    7.   # Seata 事务组编号，用于 TC 集群名
    8.   tx-service-group: default_tx_group
    9.   # 关闭自动代理
    10.   enable-auto-data-source-proxy: false
    11.   # 服务配置项
    12.   service:
    13.     # 虚拟组和分组的映射
    14.     vgroup-mapping:
    15.       #映射集群名称
    16.       default_tx_group: DEFAULT
    17.   registry:
    18.     type: nacos
    19.     nacos:
    20.       application: seata-server
    21.       server-addr: 127.0.0.1:8848
    22.       namespace:
    23.       username: nacos
    24.       password: nacos
    25.       group: DEFAULT_GROUP
    26.   data-source-proxy-mode: XA

               2.微服务链接的数据库需要建表

                

    1. -- for AT mode you must to init this sql for you business database. the seata server not need it.
    2. CREATE TABLE IF NOT EXISTS `undo_log`
    3. (
    4.     `branch_id`     BIGINT(20)   NOT NULL COMMENT 'branch transaction id',
    5.     `xid`           VARCHAR(100) NOT NULL COMMENT 'global transaction id',
    6.     `context`       VARCHAR(128) NOT NULL COMMENT 'undo_log context,such as serialization',
    7.     `rollback_info` LONGBLOB     NOT NULL COMMENT 'rollback info',
    8.     `log_status`    INT(11)      NOT NULL COMMENT '0:normal status,1:defense status',
    9.     `log_created`   DATETIME(6)  NOT NULL COMMENT 'create datetime',
    10.     `log_modified`  DATETIME(6)  NOT NULL COMMENT 'modify datetime',
    11.     UNIQUE KEY `ux_undo_log` (`xid`, `branch_id`)
    12. ) ENGINE = InnoDB
    13.   AUTO_INCREMENT = 1
    14.   DEFAULT CHARSET = utf8mb4 COMMENT ='AT transaction mode undo table';

              3.启动微服务

                    链接成功

            4.测试 @GlobalTransactional 注解

            

    1. /**
    2.      * 删除物业公司
    3.      */
    4.     @RequiresPermissions("business:propertyCompany:remove")
    5.     @Log(title = "物业公司", businessType = BusinessType.DELETE)
    6. 	@DeleteMapping("/{ids}")
    7.     @GlobalTransactional
    8.     public AjaxResult remove(@PathVariable Long[] ids)
    9.     {
    10.         //return toAjax(bPropertyCompanyService.deleteBPropertyCompanyByIds(ids));
    11.         List<Long> longs = Arrays.asList(ids);
    12.         for(Long id:longs){
    13.             BPropertyCompany byId = bPropertyCompanyService.getById(id);
    14.  
    15.             ClosePropertyCompanyOrCommunityParam param=new ClosePropertyCompanyOrCommunityParam();
    16.             param.setId(String.valueOf(byId.getId()));
    17.             param.setType(0);
    18.             param.setPhone(byId.getPhone());
    19.             R<Map> rmap= remoteUserService.closePropertyCompanyOrCommunity(param, SecurityConstants.INNER);
    20.             if (rmap.getCode() == 500){
    21.                 throw new RuntimeException(rmap.getMsg());
    22.             }
    23.         }
    24.         boolean b = bPropertyCompanyService.removeByIds(Arrays.asList(ids));
    25.         return toAjax(b);
    26.     }

    需要注意的是:这两处必须一致

  • 相关阅读:
    SQL SERVER中存储过程的使用场景
    【scikit-learn基础】--『回归模型评估』之损失分析
    springboot+vue实现Minio文件存储
    Linux/shell命令
    自学软件测试1个半月上岸拿5个offer
    解决ubuntu网卡失效-更换内核版本
    B+树结构与索引＜二＞ _ 索引页示例
    数字孪生3d车间、虚拟车间、数字化三维车间的案例比较
    Android垂直跑马灯
    ​P1190 [NOIP2010 普及组] 接水问题 【贪心】​
  • 原文地址：https://blog.csdn.net/qq_31683775/article/details/133929097