卖不甜枣 发表于 10 小时前

1.Seata 1.5.2 seata-server搭建

一:Seata基本介绍

Seata是一款开源的分布式事务解决方案,致力于在微服务架构下提供高性能和简朴易用的分布式事务服务。
详见官网链接:https://seata.apache.org/zh-cn/
1.汗青项目里的使用经验:

之前公司里的oem用户对应的App计划停服,通告用户手动确认迁徙到obm的用户App,oem 和 obm 用户的数据表结构完全一样,只是不同App对应的数据分别存储在不同的库,需要包管用户在迁徙后,oem库里清除用户数据而obm库里同步新增用户的数据。迁徙后数据需要包管的同等性。这几天工作不太忙,利用碎片时间重新搭建了一套也顺便记录下整个搭建过程。
二:Seata-server搭建

2.1 版本选择

Seata 也是CS结构的服务类型,需要有一个Seata-server端。需要注意的是:版本的选择需要和本身项目中其他的框架版本适配。
我的版本选择如下:
组件版本spring-boot2.6.11spring-cloud2021.0.4spring-cloud-alibaba2021.0.4.0nacos2.0.4seata1.5.2 官网上保举的版本适配截图见下:
https://i-blog.csdnimg.cn/direct/3e1cd29e632a447295ca459a25ac53a9.png
https://i-blog.csdnimg.cn/direct/77f12f3e9e09447f903ae767c728e4ce.png
2.2 seata-server 下载

从seata 官网进去后,探求下载页面 中的对应版本。
详细的链接为:https://seata.apache.org/zh-cn/unversioned/release-history/seata-server
https://i-blog.csdnimg.cn/direct/a2fbe66c53e74903b6b20ae5c4c57e2b.png
下载后,解压zip包:
https://i-blog.csdnimg.cn/direct/eb320a4e93f044bba39311babc9032b9.png
2.3 初始化DB脚本

文件路径:seata\script\server\db\mysql.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);
创建一个新库:seata
在新库里执行mysql.sql
2.4 设置文件编辑

文件路径:seata\conf\application.yml
application.yml 的设置信息可以参在官方给出的application.example.yml文件的设置。
# seata-server 对应的端口
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
      
# seata控制台的账号密码
console:
user:
    username: seata
    password: seata

seata:
config:
    # support: nacos, consul, apollo, zk, etcd3
    #以nacos 作为配置中心,具体nacos配置根据自己的nacos调整
    type: nacos
    nacos:
      server-addr: 127.0.0.1:8848
      namespace: d6eccad6-681c-4133-b9ff-1abcd951297a
      group: DOLPHIN_GROUP
      username: nacos
      password: nacos
registry:
    # support: nacos, eureka, redis, zk, consul, etcd3, sofa
   #以nacos 作为注册中心,具体nacos配置根据自己的nacos调整
    type: nacos
    nacos:
      application: seata-server
      server-addr: 127.0.0.1:8848
      group: DOLPHIN_GROUP
      namespace: d6eccad6-681c-4133-b9ff-1abcd951297a
      cluster: default
      username: nacos
      password: nacos
      ##if use MSE Nacos with auth, mutex with username/password attribute
      #access-key: ""
      #secret-key: ""
store:
    # support: file 、 db 、 redis
    #以db作为存储中心,具体存储配置根据自己的选择配
    mode: db
    db:
      datasource: druid
      db-type: mysql
      driver-class-name: com.mysql.cj.jdbc.Driver
      # 步骤2.3里初始化DB脚本时创建的库
      url: jdbc:mysql://127.0.0.1:3306/seata?rewriteBatchedStatements=true
      user: root
      password: myPwd
      min-conn: 5
      max-conn: 100
      global-table: global_table
      branch-table: branch_table
      lock-table: lock_table
      distributed-lock-table: distributed_lock
      query-limit: 100
      max-wait: 5000
#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
2.5 seata-server启动

seata\bin 目次下:
https://i-blog.csdnimg.cn/direct/f543236184f94c08bd010b855b209fe6.png
注意:启动log如下。监听的端口是8091. 是在启动的端口7091 + 1000 .设置文件里可见这个规则。
#server:
#    service-port: 8091 #If not configured, the default is '${server.port} + 1000'
https://i-blog.csdnimg.cn/direct/f593ca8c2245430bbd0c70caae52c789.png
2.6 seata-server 控制台登录
登录地址:localhost:7092
账号密码:见application.yml 中控制台设置
https://i-blog.csdnimg.cn/direct/b680afe4844c4e0cba3985fb609e4b5a.png

免责声明:如果侵犯了您的权益,请联系站长,我们会及时删除侵权内容,谢谢合作!更多信息从访问主页:qidao123.com:ToB企服之家,中国第一个企服评测及商务社交产业平台。
页: [1]
查看完整版本: 1.Seata 1.5.2 seata-server搭建