Spring Cloud Alibaba 整合Seata 之概念介绍及Seata-server搭建

news2024/12/27 11:21:02

目录

前言

基础介绍

官方文档

模式分类

角色介绍

Seata Server 部署 -  docker-compose 

数据库

服务器

docker-compose.yaml

nacos配置

启动

前言

Seata 是 阿里巴巴 开源的 分布式事务中间件，以 高效 并且对业务 0 侵入 的方式，解决 微服务 场景下面临的分布式事务问题。

主要指讲述 seata服务端的搭建以及与springcloud的集成以实现分布式事务控制的过程 

基础介绍

以下部分来自官网，部分来自个人理解

官方文档

中文文档

Seata 是什么

github项目

GitHub - seata/seata: Seata is an easy-to-use, high-performance, open source distributed transaction solution.


组件


模式分类

  • AT：基于支持本地 ACID 事务的关系型数据库。Java 应用，通过 JDBC 访问数据库。整体机制：二阶段提交。   一阶段：业务数据和回滚日志记录在同一个本地事务中提交，释放本地锁和连接资源。二阶段：提交异步化，非常快速地完成。回滚通过一阶段的回滚日志进行反向补偿。

  • TCC：不依赖于底层数据资源的事务支持，支持把 自定义 的分支事务纳入到全局事务的管理中。

  • SAGA ：Saga模式是SEATA提供的长事务解决方案，在Saga模式中，业务流程中每个参与者都提交本地事务，当出现某一个参与者失败则补偿前面已经成功的参与者，一阶段正向服务和二阶段补偿服务都由业务开发实现。

  • XA 

角色介绍

seata主要有下面三种角色

  • 事务协调器（TC）：维护全局事务和分支事务的状态，驱动全局提交或回滚。
  • 事务管理器（TM）：定义全局事务的范围：开始全局事务，提交或回滚全局事务。
  • 资源管理器（RM）：管理分支事务处理的资源，与TC交谈以注册分支事务并报告分支事务的状态，并驱动分支事务提交或回滚。

一个分布式事务流程图：

TM要求TC开始新的事务。TC生成一个表示全局事务的XID。

XID是通过微服务的调用链传播的。

RM将本地事务注册为XID到TC的相应全局事务的分支。

TM要求TC提交或回滚XID的相应全局事务。

TC驱动XID对应全局事务下的所有分支事务完成分支提交或回滚。

Seata Server 部署 -  docker-compose 

数据库

新建一个mysql数据库 seata，sql脚本


-- -------------------------------- The script used when storeMode is 'db' --------------------------------
-- the table to store GlobalSession data
CREATE TABLE IF NOT EXISTS `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_status_gmt_modified` (`status` , `gmt_modified`),
    KEY `idx_transaction_id` (`transaction_id`)
) ENGINE = InnoDB
  DEFAULT CHARSET = utf8mb4;

-- the table to store BranchSession data
CREATE TABLE IF NOT EXISTS `branch_table`
(
    `branch_id`         BIGINT       NOT NULL,
    `xid`               VARCHAR(128) NOT NULL,
    `transaction_id`    BIGINT,
    `resource_group_id` VARCHAR(32),
    `resource_id`       VARCHAR(256),
    `branch_type`       VARCHAR(8),
    `status`            TINYINT,
    `client_id`         VARCHAR(64),
    `application_data`  VARCHAR(2000),
    `gmt_create`        DATETIME(6),
    `gmt_modified`      DATETIME(6),
    PRIMARY KEY (`branch_id`),
    KEY `idx_xid` (`xid`)
) ENGINE = InnoDB
  DEFAULT CHARSET = utf8mb4;

-- the table to store lock data
CREATE TABLE IF NOT EXISTS `lock_table`
(
    `row_key`        VARCHAR(128) NOT NULL,
    `xid`            VARCHAR(128),
    `transaction_id` BIGINT,
    `branch_id`      BIGINT       NOT NULL,
    `resource_id`    VARCHAR(256),
    `table_name`     VARCHAR(32),
    `pk`             VARCHAR(36),
    `status`         TINYINT      NOT NULL DEFAULT '0' COMMENT '0:locked ,1:rollbacking',
    `gmt_create`     DATETIME,
    `gmt_modified`   DATETIME,
    PRIMARY KEY (`row_key`),
    KEY `idx_status` (`status`),
    KEY `idx_branch_id` (`branch_id`),
    KEY `idx_xid_and_branch_id` (`xid` , `branch_id`)
) ENGINE = InnoDB
  DEFAULT CHARSET = utf8mb4;

CREATE TABLE IF NOT EXISTS `distributed_lock`
(
    `lock_key`       CHAR(20) NOT NULL,
    `lock_value`     VARCHAR(20) NOT NULL,
    `expire`         BIGINT,
    primary key (`lock_key`)
) ENGINE = InnoDB
  DEFAULT CHARSET = utf8mb4;

INSERT INTO `distributed_lock` (lock_key, lock_value, expire) VALUES ('AsyncCommitting', ' ', 0);
INSERT INTO `distributed_lock` (lock_key, lock_value, expire) VALUES ('RetryCommitting', ' ', 0);
INSERT INTO `distributed_lock` (lock_key, lock_value, expire) VALUES ('RetryRollbacking', ' ', 0);
INSERT INTO `distributed_lock` (lock_key, lock_value, expire) VALUES ('TxTimeoutCheck', ' ', 0);

服务器

创建目录

mkdir -p /apps/seata/{config,data,logs}

docker-compose.yaml

version: "3.1"
services:
  seata-server:
    image: seataio/seata-server
    container_name: seata
    ports:
      - "7091:7091"
      - "8091:8091"
    environment:
    - SEATA_IP=192.168.1.115
    - SEATA_PORT=8091
    - STORE_MODE=file
    volumes:
      - "/usr/share/zoneinfo/Asia/Shanghai:/etc/localtime"
      - "/usr/share/zoneinfo/Asia/Shanghai:/etc/timezone"
      
    networks:
      - dev
networks:
  dev:
    external: true

先把docker-compose up -d服务起起来，然后copy出来配置文件

sudo docker cp 4c808f11c609:/seata-server/resources/ /apps/seata/config/

文件目录是这样子的

修改配置文件

 application.yaml 

server:
  port: 7091

spring:
  application:
    name: seata-server

logging:
  config: classpath:logback-spring.xml
  file:
    path: ${user.home}/logs/seata
  extend:
    logstash-appender:
      destination: 127.0.0.1:4560
    kafka-appender:
      bootstrap-servers: 127.0.0.1:9092
      topic: logback_to_logstash

console:
  user:
    username: seata
    password: seata

seata:
  config:
    # support: nacos, consul, apollo, zk, etcd3
    type: nacos
    nacos:
      server-addr: 192.168.1.115:8108
      namespace: seata-server
      group: SEATA_GROUP
      username: nacos
      password: nacos
      data-id: seataServer.properties

  registry:
    # support: nacos, eureka, redis, zk, consul, etcd3, sofa
    type: nacos
    nacos:
      application: seata-server
      server-addr: 192.168.1.115:8108
      group: SEATA_GROUP
      namespace: seata-server
      # tc集群名称
      cluster: default
      username: nacos
      password: nacos
  #  server:
  #    service-port: 8091 #If not configured, the default is '${server.port} + 1000'
  security:
    secretKey: SeataSecretKey0c382ef121d778043159209298fd40bf3850a017
    tokenValidityInMilliseconds: 1800000
    ignore:
      urls: /,/**/*.css,/**/*.js,/**/*.html,/**/*.map,/**/*.svg,/**/*.png,/**/*.ico,/console-fe/public/**,/api/v1/auth/login

nacos配置

新建一个命名空间 seata-server

 在这个命名空间下新建一个配置文件  seataServer.properties 组为  SEATA_GROUP

 

 

 内容如下：

store.mode=db
#-----db-----
store.db.datasource=druid
store.db.dbType=mysql
# 需要根据mysql的版本调整driverClassName
# mysql8及以上版本对应的driver：com.mysql.cj.jdbc.Driver
# mysql8以下版本的driver：com.mysql.jdbc.Driver
store.db.driverClassName=com.mysql.cj.jdbc.Driver
store.db.url=jdbc:mysql://mysql:3306/seata?useUnicode=true&characterEncoding=utf8&connectTimeout=1000&socketTimeout=3000&autoReconnect=true&useSSL=false
store.db.user= root
store.db.password=113355
# 数据库初始连接数
store.db.minConn=1
# 数据库最大连接数
store.db.maxConn=20
# 获取连接时最大等待时间 默认5000，单位毫秒
store.db.maxWait=5000
# 全局事务表名 默认global_table
store.db.globalTable=global_table
# 分支事务表名 默认branch_table
store.db.branchTable=branch_table
# 全局锁表名 默认lock_table
store.db.lockTable=lock_table
# 查询全局事务一次的最大条数 默认100
store.db.queryLimit=100


# undo保留天数 默认7天,log_status=1（附录3）和未正常清理的undo
server.undo.logSaveDays=7
# undo清理线程间隔时间 默认86400000，单位毫秒
server.undo.logDeletePeriod=86400000
# 二阶段提交重试超时时长 单位ms,s,m,h,d,对应毫秒,秒,分,小时,天,默认毫秒。默认值-1表示无限重试
# 公式: timeout>=now-globalTransactionBeginTime,true表示超时则不再重试
# 注: 达到超时时间后将不会做任何重试,有数据不一致风险,除非业务自行可校准数据,否者慎用
server.maxCommitRetryTimeout=-1
# 二阶段回滚重试超时时长
server.maxRollbackRetryTimeout=-1
# 二阶段提交未完成状态全局事务重试提交线程间隔时间 默认1000，单位毫秒
server.recovery.committingRetryPeriod=1000
# 二阶段异步提交状态重试提交线程间隔时间 默认1000，单位毫秒
server.recovery.asynCommittingRetryPeriod=1000
# 二阶段回滚状态重试回滚线程间隔时间  默认1000，单位毫秒
server.recovery.rollbackingRetryPeriod=1000
# 超时状态检测重试线程间隔时间 默认1000，单位毫秒，检测出超时将全局事务置入回滚会话管理器
server.recovery.timeoutRetryPeriod=1000

 

 

启动

docker-compose down

docker-compose up -d重新启动后，效果如下

 

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/596774.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

过零投切开关的安科瑞低压电力电容器设计

过零投切开关的安科瑞低压电力电容器设计

安科瑞 徐浩竣 江苏安科瑞电器制造有限公司 zx acrelxhj 摘要：目前，我们经常使用的电容器投切开关在实际的运行过程中还存在着很多问题，新型的过零投切开关主要利用微电子技术，同时企业对电路的结构等开展了进一步的优化与调整…
阅读更多...
真的有必要定义VO，BO，PO，DO，DTO吗？

真的有必要定义VO，BO，PO，DO，DTO吗？

今天给大家带来一篇关于VO，BO，PO，DO，DTO的文章，阅读完这篇文章之后，希望大家对VO，BO，PO，DO，DTO有自己的见解。 1. 概念 在讲具体的概念之前，我们…
阅读更多...
I.MX6ULL_Linux_驱动篇(35) linux并发与竞争

I.MX6ULL_Linux_驱动篇(35) linux并发与竞争

Linux是一个多任务操作系统，存在多个任务共同操作同一段内存或者设备的情况，多个任务或者中断都能访问的资源叫做共享资源，就和共享单车一样。在驱动开发中要注意对共享资源的保护，也就是要处理对共享资源的并发访问。比如共享单车…
阅读更多...
Mybatis插件MyBatisCodeHelperPro使用

Mybatis插件MyBatisCodeHelperPro使用

目录 MyBatisCodeHelperPro的安装（IDEA插件的两种安装方式） 通过IDEA连接MySQL数据库，方便后续的数据库操作 MyBatisCodeHelperPro的使用 1、新建项目工程测试 2、在pom文件中引入依赖（后面测试需要用到） 3、编写…
阅读更多...
使用docker部署 java web项目完整记录

使用docker部署 java web项目完整记录

概述：基于java及vue开发的前后端web应用， 整套系统由 一个后端服务一个管理端前端vue一个用户端前端vue项目组， 涉及的中间件及第三方应用有 mysql、redis、nginx， 采用docker方式部署整套系统 一、docker 安装 1、参考文档&…
阅读更多...
jira中issue状态的改变触发jenkins job构建

jira中issue状态的改变触发jenkins job构建

背景：想通过监控jira中 issue状态的变化去触发jenkins job的构建 在jenkins中安装插件：JIRA Trigger plugin. 下载地址：https://plugins.jenkins.io/jira-trigger/ 在Jenkins-> Manage Jenkins -> Configure System -> JIRA Trigg…
阅读更多...
UnityVR--EventManager--事件中心2

UnityVR--EventManager--事件中心2

目录 前言 事件中心的结构 EventManager事件管理器 EventType事件类型 EventListener监听及回调 EventDataBase回调时需要传递的参数 总结 前言 上一篇（事件中心1）中，简单解释了委托、事件、监听者，是用于管理项目运行过程…
阅读更多...
深度学习进阶篇[9]：对抗生成网络GANs综述、代表变体模型、训练策略、GAN在计算机视觉应用和常见数据集介绍，以及前沿问题解决

深度学习进阶篇[9]：对抗生成网络GANs综述、代表变体模型、训练策略、GAN在计算机视觉应用和常见数据集介绍，以及前沿问题解决

【深度学习入门到进阶】必看系列，含激活函数、优化策略、损失函数、模型调优、归一化算法、卷积模型、序列模型、预训练模型、对抗神经网络等 专栏详细介绍：【深度学习入门到进阶】必看系列，含激活函数、优化策略、损失函数、模型调优、归一化…
阅读更多...
多线程-*同步代码块*解决两种线程创建方式的线程安全问题

多线程-*同步代码块*解决两种线程创建方式的线程安全问题

线程安全问题及解决 当我们使用多个线程访问同一资源（可以是同一个变量、同一个文件、同一条记录等）的时候，若多个线程只有读操作，那么不会发生线程安全问题。但是多个线程中对资源有读和写的操作。就容易出现线程安全问题。 举…
阅读更多...
PyTorch 深度学习 || 专题三：PyTorch 数据的准备

PyTorch 深度学习 || 专题三：PyTorch 数据的准备

PyTorch 数据的准备 1. 生成数据的准备工作 import torch import torch.utils.data as Data#准备建模数据 x torch.unsqueeze(torch.linspace(-1, 1, 500), dim1) # 生成列向量 y x.pow(3) # yx^3#设置超参数 batch_size 15 # 分块大小 torch.manual_seed(10) # 设置种子点…
阅读更多...
国自然发文：这种行为将永久取消基金申请资格

国自然发文：这种行为将永久取消基金申请资格

函评阶段这些行为被基金委禁止 国家自然科学基金委重拳出击打击"打招呼"现象,出台《国家自然科学基金项目评审请托行为禁止清单》，禁止科研人员、依托单位、评审专家和基金委工作人员24种违规行为。 主要内容如下: 一、科研人员禁止清单(7项) 主要包括…
阅读更多...
初阶数据结构——二叉树

初阶数据结构——二叉树

目录 树的概念及结构树的概念树的相关概念树的表示树在实际中的运用 二叉树概念及结构特殊的二叉树二叉树的性质二叉树的存储结构 二叉树的顺序结构及实现二叉树的顺序结构堆的概念及结构堆的实现堆的结构：初始化堆：销毁堆：插入数据&#xff…
阅读更多...
通过maven配置不同的开发环境

通过maven配置不同的开发环境

前言 项目有开发、测试、生产至少有这三个环境， 所需要的配置信息肯定不一样， 比如需要开发环境的时候，注解掉测试和生产的配置信息，打开开发的配置信息。 后来工作接触到新项目，发现是通过maven来控制加载不同的配置…
阅读更多...
第55讲：Python函数形参、实参的语法格式汇总以及应用小案例

第55讲：Python函数形参、实参的语法格式汇总以及应用小案例

文章目录 1.Python函数中各种参数的汇总1.1.常规参数1.2.参数设置默认值1.3.强制传参时使用关键字传参1.4.个数可变的形参1.5.将序列中的每个元素都转换为位置实参1.6.将字典中的每个元素都转换为关键字实参 2.小案例练习Python中的各种函数参数2.1.案例一2.2.案例二 1.Python函…
阅读更多...
React-reacte-app项目实现antD按需加载（2023）

React-reacte-app项目实现antD按需加载（2023）

出现的问题： 项目打包后，由于引入了antD，所以打包后的mani.js体积会非常大。相当于引入了全部的antD的代码。所以可以做一个优化：通过script标签引入antD，将其挂载在window上。使用antD组件的使用，直接从w…
阅读更多...
2.矢量分析

2.矢量分析

目录 一.标量函数和矢量函数 二.矢端曲线 三.矢量函数导数和微分 1.导数 2.导数的几何意义 3.微分 4.矢量导数性质 5.例题 四.矢量导数的应用 1.几何应用 1.曲线的切线和法平面 2.曲面的法线和法平面 2.物理应用 3.两大典型问题 五.矢量函数的积分 如果第一章我…
阅读更多...
WOT全球技术创新大会开幕倒计时——好内容才是永远的底气

WOT全球技术创新大会开幕倒计时——好内容才是永远的底气

距离6月16日-17日召开的WOT全球技术创新大会还有半个月时间，所有讲师、议题均已就位。本届WOT不仅囊括2023年最火的技术——AIGC、大模型、大算力，也有被技术人永恒关注的热点话题——多云实践、业务架构演进、效能提升。 筹备数月之久，50来…
阅读更多...
Intel® 以太网800 系列网络适配器 – DPDK上的性能演进

Intel® 以太网800 系列网络适配器 – DPDK上的性能演进

1. 介绍 Intel以太网800系列网络适配器提供卓越的性能，以满足各种工作负载的要求。800系列提供了数据包分类和排序优化、硬件增强的定时能力以及完全可编程的流水线。Intel的以太网产品组合始终提供可靠的体验和经过验证的互操作性。 在DPDK中，ICE轮询模…
阅读更多...
CDN控制平台操作指引之账号注册及添加域名

CDN控制平台操作指引之账号注册及添加域名

一、注册账户及登录 （一）请确认您已经注册了火伞云账号并完成账号实名认证。如果未注册，请先完成账号注册和实名认证。 （二）登录火伞云融合CDN管理平台。 二、添加加速域名 使用火伞云融合CDN加速指定网站&#xff…
阅读更多...
NodeJs之Ajax技术

NodeJs之Ajax技术

1. 初识Ajax ./public/Ajax.html <!DOCTYPE html> <html lang"en"> <head><meta charset"UTF-8"><meta http-equiv"X-UA-Compatible" content"IEedge"><meta name"viewport" content&qu…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023