[大数据]springCloud集成seata分布式事务

一、seata服务端安装

我们这里是基于nacos进行搭建的，关于nacos请参考
springcloud集成nacos注册中心
springcloud集成nacos配置中心

官网地址

本文是基于seata版本1.4.2搭建的

1、安装包下载
服务端安装包下载地址

服务端、客户端、配置中心的脚本下载地址

2、修改registry.conf配置文件 。 seata支持以下类型的配置

file,nacos,eureka,redis,zk,consul,etcd3,sofa

file类型是在不需要注册中和配置中心的情况下也能运行。

这里我们选择nacos类型，所以需要设置nacos的配置中心和注册中心

3、上传配置至Nacos配置中心

参考script/config-center 的config.txt并修改,之后运行仓库中提供的nacos脚本,将信息提交到nacos控制台,如果有需要更改,可直接通过控制台更改.

执行 sh ${SEATAPATH}/script/config-center/nacos/nacos-config.sh -h localhost -p 8848 -g SEATA_GROUP -t 5a3c7d6c-f497-4d68-a71a-2e5e3340b3ca -u username -w password

-h: 配置中心ip
-p: 配置中心端口号
-g: 配置中心分组
-t: 配置中心命名空间
-u: 配置中心用户名
-w: 配置中心密码

4、启动服务端

命令启动: seata-server.sh -h 127.0.0.1 -p 8091 -m db -n 1 -e test

-h: 注册到注册中心的ip
-p: Server rpc 监听端口
-m: 全局事务会话信息存储模式，file、db、redis，优先读取启动参数 (Seata-Server 1.3及以上版本支持redis)
-n: Server node，多个Server时，需区分各自节点，用于生成不同区间的transactionId，以免冲突
-e: 多环境配置参考 http://seata.io/en-us/docs/ops/multi-configuration-isolation.html

ps：

1、 如果store.mode是db模式需要创建下面3张表
全局事务–>分支事务–>全局锁，对应表global_table、branch_table、lock_table

二、客户端搭建

springCloud、springboot、spring-alibaba对应版本

<dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>com.alibaba.cloud</groupId>
                <artifactId>spring-cloud-alibaba-dependencies</artifactId>
                <version>2.2.5.RELEASE</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>Hoxton.SR3</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-dependencies</artifactId>
                <version>2.2.5.RELEASE</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

seata版本

<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-seata</artifactId>
</dependency>
<dependency>
    <groupId>io.seata</groupId>
    <artifactId>seata-spring-boot-starter</artifactId>
    <version>1.4.2</version>
</dependency>

application.yml配置seata的注册中心和配置中心，如果有多个客户端应用程序，下面的配置都要一样

seata:
  registry:
    type: nacos
    nacos:
      application: seata-server   #seata服务端应用名 必须和服务端一致
      server-addr: 127.0.0.0:8848  #nacos地址
      group : "SEATA_GROUP"
      namespace: ""
  tx-service-group: mytest   #事务分组，这里设置的mytest名称必须在service.vgroupMapping.mytest 中一致，通过事务分组能够找到seate集群

  config:
    type: nacos
    nacos:
      server-addr: 127.0.0.0:8848
      group : "SEATA_GROUP"
      namespace: ""

2、使用seata非常简单，如果是AT模式需要创建undo_log表，脚本在目录script\client\at\db下

在方法中添加@GlobalTransactional注解，就可以正常使用了

ps:

涉及到的表必须有主键，如果是自增注解，必须在字段上添加标识主键的注解
更多疑问参考http://seata.io/zh-cn/docs/overview/faq.html