seata服务搭建

它支持两种存储模式,一个是文件,一个是数据库,下面我们分别介绍一下这两种

配置nacos存储配置,注意如果registry.conf中注册和配置使用的是file,就会去读取file.config的配置,如果是nacos则通过nacos动态读取配置

用nacos作为注册中心了,所以我们接下来要做的就是讲配置上传到nacos进行存储

首先我们需要去官网下载Seata的源码,找到其中的script目录:

https://gitcode.net/mirrors/seata/seata

script的目录结构是这样的:

  • client:存放客户端SQL脚本的,参数配置

  • config-center:各个配置中心参数导入脚本,config.txt为通用参数文件

  • server:服务端数据库脚本及各个容器配置

进入config-center/nacos目录,执行脚本,添加nacos配置信息(不要忘记开启nacos服务哦),命令如下:

ps:下载完成后,将脚本文件放入到seata项目的配置文件夹下(seata-server-1.4.2\conf):

ps: 需要导入nacos的配置信息文件config.txt需要放在config的上一层目录

ps: 存储模式改成 store.mode=db ,因为我使用的是mysql8.0.17版本的,所以 store.db.driverClassName=com.mysql.cj.jdbc.Driver,需要另外下载jdbc的jar包,下载好后放入项目中seata-server-1.4.2\lib\jdbc的目录下:

剩下的就是配置数据库的相关配置信息(url、username、password):

store.db.url=jdbc:mysql://127.0.0.1:3306/seata?useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai

store.db.user=root

store.db.password=123456

//执行脚本
sh ${SEATAPATH}/bin/nacos-config.sh -h localhost -p 8848 -g SEATA_GROUP -t 5a3c7d6c-f497-4d68-a71a-2e5e3340b3ca -u nacos-w nacos
Parameter Description:

-h: host, the default value is localhost.

-p: port, the default value is 8848.

-g: Configure grouping, the default value is 'SEATA_GROUP'.

-t: Tenant information, corresponding to the namespace ID field of Nacos, the default value is ''.

-u: username, nacos 1.2.0+ on permission control, the default value is ''.

-w: password, nacos 1.2.0+ on permission control, the default value is ''.

让我们看一下nacos那边的配置列表是否有对应的配置数据了:

很显然,已经添加成功了 ,那接下来我们就需要修改一下Seata服务端配置加载位置,那就需要修改registry.conf文件中的config那段配置,配置如下:

 config {
  # file、nacos 、apollo、zk、consul、etcd3
  type = "nacos"    #修改
 
  nacos {
    serverAddr = "127.0.0.1:8848"    #修改
    namespace = ""
    group = "SEATA_GROUP" #跟上面的-g 命令保持一致即可
  }
  #以下代码省略...
}

1、存储模式

1、file存储模式
默认支持的存储模式,直接启动即可,不需要改动任何文件,file模式是单机模式,全局事务会话信息会持久化到本地文件:/bin/sessionStore/root.data,性能较高,具体的命令如下:

sh seata-server.sh -p 8091 -h 127.0.0.1 -m file
2、db存储模式
这个模式是高可用的模式,全局事务会话信息通过db共享的,性能较比file模式较差一些,具体的实现步骤如下:

①创建数据库,表结构如下:

-- 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_gmt_modified_status` (`gmt_modified`, `status`),
KEY `idx_transaction_id` (`transaction_id`)
) ENGINE = InnoDB
DEFAULT CHARSET = utf8;

-- 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 = utf8;

-- the table to store lock data
--全局锁表
CREATE TABLE IF NOT EXISTS `lock_table`
(
`row_key` VARCHAR(128) NOT NULL,
`xid` VARCHAR(96),
`transaction_id` BIGINT,
`branch_id` BIGINT NOT NULL,
`resource_id` VARCHAR(256),
`table_name` VARCHAR(32),
`pk` VARCHAR(36),
`gmt_create` DATETIME,
`gmt_modified` DATETIME,
PRIMARY KEY (`row_key`),
KEY `idx_branch_id` (`branch_id`)
) ENGINE = InnoDB
DEFAULT CHARSET = utf8;
②设置事务日志存储方式

进入conf/file.conf,修改属性store.mode="db"

③修改数据库连接

db {
datasource = "druid" ##修改
dbType = "mysql"
driverClassName = "com.mysql.jdbc.Driver"
url = "jdbc:mysql://127.0.0.1:3306/seata" ##修改
user = "mysql" ##修改
password = "mysql" ##修改
minConn = 1
maxConn = 10
globalTable = "global_table"
branchTable = "branch_table"
lockTable = "lock_table"
queryLimit = 100
}
④启动seata

seata-server.bat -h 127.0.0.1 -p 8091 -m db -n 1
关于后面的启动参数这里就不做陈述了,上面表格有详解

2、配置中心说明

Seata根目录config有两个配置文件,registry.conf和file.config

registry.con配置说明

这个文件中只包含了两项配置属相:registry和config,源码如下:

registry {

# file 、nacos 、eureka、redis、zk、consul、etcd3、sofa

type = "file"

nacos {

serverAddr = "localhost"

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 = ""

group = "SEATA_GROUP"

}

consul {

serverAddr = "127.0.0.1:8500"

}

apollo {

app.id = "seata-server"

apollo.meta = "http://192.168.1.204:8801"

namespace = "application"

}

zk {

serverAddr = "127.0.0.1:2181"

session.timeout = 6000

connect.timeout = 2000

}

etcd3 {

serverAddr = "http://localhost:2379"

}

file {

name = "file.conf"

}

}

registry

它可以配置Seata服务注册的地址,支持现在市面上绝大多数的注册中心组件,配置也很简单,只需要修改type即可,然后在对应的配置下,配置好对应服务的ip相关信息即可,比如想用Nacos作为注册中心,那就type=nacos,然后修改ip,源码如下:

registry {

# file 、nacos 、eureka、redis、zk、consul、etcd3、sofa

type = "nacos" #修改,按照上面注释的单词来填写

nacos {

serverAddr = "127.0.0.1:8848" #对应nacos的相关配置

namespace = ""

cluster = "default"

}

# 以下代码省略...

}

这里注意一下,这个type默认是file,表示不用注册中心,如果是file,就可以不用注册中心快速运行Seata,只不过file没有注册中心的动态发现和动态配置的功能

config

用于配置Seata服务端的配置文件地址,意思就是说可以通过config配置来指定Seata服务端的配置信息的加载位置,它支持从远程配置中心读取和本地文件读取两种方式,如果配置为远程配置中心,可以使用type指定,配置形式和上面的registry一样

config {

# file、nacos 、apollo、zk、consul、etcd3

type = "nacos" #修改

nacos {

serverAddr = "127.0.0.1:8848" #修改

namespace = ""

group = "SEATA_GROUP"

}

# 以下代码省略...

}

需要注意的是,如果这里的type是file的话,他默认会加载file.conf文件中的配置信息,那这里就需要讲解一下file.conf文件了

file.conf配置说明

此配置文件存储的是Seata服务端的配置信息,完成配置是:transport(协议配置)、server(服务端配置)、metrics(监控)

transport {
  # tcp udt unix-domain-socket
  type = "TCP"
  #NIO NATIVE
  server = "NIO"
  #enable heartbeat
  heartbeat = true
  # the client batch send request enable
  enableClientBatchSendRequest = false
  #thread factory for netty
  threadFactory {
    bossThreadPrefix = "NettyBoss"
    workerThreadPrefix = "NettyServerNIOWorker"
    serverExecutorThreadPrefix = "NettyServerBizHandler"
    shareBossWorker = false
    clientSelectorThreadPrefix = "NettyClientSelector"
    clientSelectorThreadSize = 1
    clientWorkerThreadPrefix = "NettyClientWorkerThread"
    # netty boss thread size,will not be used for UDT
    bossThreadSize = 1
    #auto default pin or 8
    workerThreadSize = "default"
  }
  shutdown {
    # when destroy server, wait seconds
    wait = 3
  }
  serialization = "seata"
  compressor = "none"
}
# service configuration, only used in client side
service {
  #transaction service group mapping
  vgroupMapping.my_test_tx_group = "default"
  #only support when registry.type=file, please don't set multiple addresses
  default.grouplist = "127.0.0.1:8091"
  #degrade, current not support
  enableDegrade = false
  #disable seata
  disableGlobalTransaction = false
}
#client transaction configuration, only used in client side
client {
  rm {
    asyncCommitBufferLimit = 10000
    lock {
      retryInterval = 10
      retryTimes = 30
      retryPolicyBranchRollbackOnConflict = true
    }
    reportRetryCount = 5
    tableMetaCheckEnable = false
    reportSuccessEnable = false
    sqlParserType = druid
  }
  tm {
    commitRetryCount = 5
    rollbackRetryCount = 5
  }
  undo {
    dataValidation = true
    logSerialization = "jackson"
    logTable = "undo_log"
  }
  log {
    exceptionRate = 100
  }
}
 
## transaction log store, only used in server side
## 事务日志存储配置
store {
  ## store mode: file、db
  mode = "file"
  ## file store property
  ## 文件存储的配置属性
  file {
    ## store location dir
    dir = "sessionStore"
    # branch session size , if exceeded first try compress lockkey, still exceeded throws exceptions
    maxBranchSessionSize = 16384
    # globe session size , if exceeded throws exceptions
    maxGlobalSessionSize = 512
    # file buffer size , if exceeded allocate new buffer
    fileWriteBufferCacheSize = 16384
    # when recover batch read size
    sessionReloadReadSize = 100
    # async, sync
    flushDiskMode = async
  }
 
  ## database store property
  ## 数据库存储的配置属性
  db {
    ## the implement of javax.sql.DataSource, such as DruidDataSource(druid)/BasicDataSource(dbcp) etc.
    datasource = "dbcp"
    ## mysql/oracle/h2/oceanbase etc.
    dbType = "mysql"
    driverClassName = "com.mysql.jdbc.Driver"
    url = "jdbc:mysql://127.0.0.1:3306/seata"
    user = "mysql"
    password = "mysql"
    minConn = 1
    maxConn = 10
    globalTable = "global_table" # db模式全局事务表名
    branchTable = "branch_table" # db模式分支事务表名
    lockTable = "lock_table" # db模式全局锁表名
    queryLimit = 100 # db模式查询全局事务一次的最大条数
  }
}
## server configuration, only used in server side
# server服务端配置
server {
  recovery {
    #schedule committing retry period in milliseconds
# 两阶段提交未完成状态全局事务重试提交线程间隔时间
    committingRetryPeriod = 1000
    #schedule asyn committing retry period in milliseconds
# 两阶段异步提交状态重试提交线程间隔时间
    asynCommittingRetryPeriod = 1000
    #schedule rollbacking retry period in milliseconds
#两阶段回滚状态重试回滚线程间隔时间
    rollbackingRetryPeriod = 1000
    #schedule timeout retry period in milliseconds
#超时状态监测重试线程间隔时间
    timeoutRetryPeriod = 1000
  }
  undo {
# undo保留天数
    logSaveDays = 7
    #schedule delete expired undo_log in milliseconds
#undo清理线程间隔时间(ms)
    logDeletePeriod = 86400000
  }
  #unit ms,s,m,h,d represents milliseconds, seconds, minutes, hours, days, default permanent
  maxCommitRetryTimeout = "-1"
  maxRollbackRetryTimeout = "-1"
  rollbackRetryTimeoutUnlockEnable = false
}
 
## metrics configuration, only used in server side
## 监控设置
metrics {
  # 是否启动
  enabled = false
  # 指标注册器类型
  registryType = "compact"
  # multi exporters use comma divided
  # 指标结果prometheus数据输出器列表
  exporterList = "prometheus"
  # prometheus输出器Client端口号
  exporterPrometheusPort = 9898
}

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

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

Kafka和RabbitMQ有哪些区别,各自适合什么场景?

目录标题1. 消息的顺序2. 消息的匹配3. 消息的超时4. 消息的保持5. 消息的错误处理6. 消息的吞吐量总结1. 消息的顺序 有这样一个需求:当订单状态变化的时候,把订单状态变化的消息发送给所有关心订单变化的系统。 订单会有创建成功、待付款、已支付、已…

Cookie和Session详解

目录 前言: Session详解 Cookie和Session区别和关联 服务器组织会话的方式 使用Tomcat实现登录成功跳转到欢迎页面 登录前端页面 登录成功后端服务器 重定向到欢迎页面 抓包分析交互过程 小结: 前言: Cookie之前博客有介绍过&#x…

音视频技术开发周刊 | 285

每周一期,纵览音视频技术领域的干货。新闻投稿:contributelivevideostack.com。GPT-4 Office全家桶发布谷歌前脚刚宣布AI工具整合进Workspace,微软后脚就急匆匆召开了发布会,人狠话不多地祭出了办公软件王炸——Microsoft 365 Cop…

使用GPT-4生成QT代码

一、概述最近ChatGPT火爆起来了,ChatGPT是一种基于GPT的自然语言处理模型,可以用于生成自然语言文本,例如对话、文章等。最近又发现了一个优秀且免费的代码生成工具Cursor.so ,Cursor.so集成了 GPT-4 ,可以帮助你快速编…

Python3,5行代码,生成自动排序动图,这操作不比Excel香?

5行代码生成自动排序动图1、引言2、代码实战2.1 pynimate介绍2.2 pynimate安装2.3 代码示例3、总结1、引言 小屌丝:鱼哥,听说你的excel段位又提升了? 小鱼:你这是疑问的语气? 小屌丝:没有~ 吧… 小鱼&…

计算机网络复习重点

文章目录计算机网络复习重点第一章 计算机网络和因特网概念与应用1、什么是因特网2、协议protocol3、入网方式4、物理媒介5、数据交换模式6、延时与丢包什么时候发生延时?延时的类型丢包何时发生7、协议层次与模型因特网协议栈TCP / IP模型ISO/OSI参考模型协议数据单…

MySQL-存储过程

什么是存储过程我们前面所学习的MySQL语句都是针对一个表或几个表的单条 SQL 语句,但是在数据库的实际操作中,并非所有操作都那么简单,经常会有一个完整的操作需要多条SQL语句处理多个表才能完成。例如,为了确认学生能否毕业&…

归并排序和快速排序

目录 归并排序 思路: 代码执行: 快速排序 运行流程图: 代码思路: 代码执行: 归并排序 定义:归并排序是建立在归并操作上的一种有效,稳定的排序算法,该算法是采用分治法&#x…

【JavaSE】类和对象(中)

类和对象(中)4. this引用4.1 为什么要有this引用4.2 什么是this引用4.3 this引用的特性5. 对象的构造及初始化5.1 如何初始化对象5.2 构造方法(构造器)5.2.1 概念5.2.2 特性5.3 默认初始化5.4 就地初始化6. 封装6.1 封装的概念6.2…

常用hook

Hook 是 React 16.8 的新增特性。它可以让你在不编写 class 的情况下使用 state 以及其他的 React 特性。理解:hook是react提供的函数API官方提供的hook基础hookuseState APIconst [state, setState] useState(initialState); //返回state值 以及更新state的方法 …

壹沓科技完成近2亿元B轮融资:构建数字机器人,实现业务超自动化

RPA中国获悉,全球领先的数字机器人公司壹沓科技近期宣布完成近2亿元B轮融资,本轮融资由鼎晖VGC(创新与成长基金)领投,创享欢聚投资基金、IDG资本、钟鼎资本跟投,指数资本继续担任独家财务顾问。 壹沓科技CEO卞晓瑜表示&#xff1…

栈、队列、优先级队列的模拟实现

优先级队列的模拟实现栈stack的模拟实现push()pop()top()size()empty()swap()stack总代码队列queue的模拟实现push()pop()front()back()empty()size()swap()queue总代码优先级队列(堆)push()pop()top()empty()size()swap()priority_queue总代码deque的了解栈 在CSTL中栈并不属…

吃透Java面试题,建议收藏

本文已经收录到Github仓库,该仓库包含计算机基础、Java基础、多线程、JVM、数据库、Redis、Spring、Mybatis、SpringMVC、SpringBoot、分布式、微服务、设计模式、架构、校招社招分享等核心知识点,欢迎star~ Github地址:https://github.com/…

LeetCode:27. 移除元素

🍎道阻且长,行则将至。🍓 🌻算法,不如说它是一种思考方式🍀算法专栏: 👉🏻123 一、🌱27. 移除元素 题目描述:给你一个数组 nums 和一个值 val&am…

Chapter6.2:其他根轨迹及综合实例分析

该系列博客主要讲述Matlab软件在自动控制方面的应用,如无自动控制理论基础,请先学习自动控制系列博文,该系列博客不再详细讲解自动控制理论知识。 自动控制理论基础相关链接:https://blog.csdn.net/qq_39032096/category_10287468…

使用vite创建vue3工程

定义 什么是vite?-----新一代前端构建工具 优势 开发环境中,无需打包操作,可快速的冷启动---最牛的地方轻量快速的热重载(HMR)---一修改代码就局部刷新,webpack也具备,但vite更快真正的按需编…

【数据结构与算法】用队列实现栈

文章目录😎前言如何用队列实现栈?用队列实现栈整体的实现代码😎写在最后😎前言 😼前面我们相继实现了 栈 和 队列 ,是不是愁没有练手的地方呢?别担心,本章带大家用队列来实现一个栈&…

synchronized 加锁 this 和 class 的区别

synchronized 是 Java 语言中处理并发问题的一种常用手段,它也被我们亲切的称之为“Java 内置锁”,由此可见其地位之高。然而 synchronized 却有着多种用法,当它修饰不同对象时,其意义也是不同的,下面我们一起来看。 ​…

云原生时代顶流消息中间件Apache Pulsar部署实操之Pulsar IO与Pulsar SQL

文章目录Pulsar IO (Connector连接器)基础定义安装Pulsar和内置连接器连接Pulsar到Cassandra安装cassandra集群配置Cassandra接收器创建Cassandra Sink验证Cassandra Sink结果删除Cassandra Sink连接Pulsar到PostgreSQL安装PostgreSQL集群配置JDBC接收器创建JDBC Sink验证JDBC …

【网络】网络层协议——IP

目录网络层IP协议IP基础知识IP地址IP报头格式网段划分CIDR特殊的IP地址IP地址的数量限制私有IP地址和公有IP地址路由IP总结网络层 在复杂的网络环境中确定一个合法的路径。 IP协议 IP协议作为整个TCP/IP中至关重要的协议,主要负责将数据包发送给最终的目标计算机…