若依微服务 + seata1.5.2版本分布式事务(安装配置nacos+部署)

这篇具有很好参考价值的文章主要介绍了若依微服务 + seata1.5.2版本分布式事务(安装配置nacos+部署)。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

若依官方使用的1.4.0版本seata,版本较低配置相对更麻烦一些

一、seata服务端下载,下载方式介绍两种入口,如下:

1、找到对应版本,下载 binary 即可。 下载包名为:seata-server-1.5.2.zip

若依微服务 + seata1.5.2版本分布式事务(安装配置nacos+部署)

2. github上下载   Releases · seata/seata · GitHub 

找到对应的1.5.2版本,每个版本下都有一个缩放的Assets,点击下载即可。

若依微服务 + seata1.5.2版本分布式事务(安装配置nacos+部署)

二、解压、修改SEATA配置(并修改nacos配置)

 1. 解压zip,linux解压后目录一致(windows和linux都可以使用)

若依微服务 + seata1.5.2版本分布式事务(安装配置nacos+部署)

2、seata配置nacos,进入 conf目录下 cd \seata-server-1.5.2\seata\conf ,修改 application.yml 配置文件内容。

内容如下,可直接复制使用:

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: 127.0.0.1:8848
      namespace:              #此处不填写,将会默认使用DEFAULT_GROUP
      group: SEATA_GROUP
      username: nacos         #nacos的账户(请自行修改)
      password: nacos         #nacos的密码(请自行修改)
      data-id: seataServer.yml #对应文章后边在nacos中添加的配置
  registry:
    # support: nacos, eureka, redis, zk, consul, etcd3, sofa
    type: nacos
    nacos:
      application: seata-server
      server-addr: 127.0.0.1:8848
      group: SEATA_GROUP
      namespace:              #此处不填写,将会默认使用DEFAULT_GROUP
      cluster: default
      username: nacos         #nacos的账户(请自行修改)
      password: nacos         #nacos的密码(请自行修改)
  #store:
    # support: file 、 db 、 redis
   # mode: file
#  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

 3、集成Nacos配置中心

 nacos上创建seataServer.yml配置文件(此处的数据库后边有教程,需要添加一个seata专用的库)

请注意此处

driverClassName:com.mysql.jdbc.Driver (配置过程中有可能踩坑)

此处请注意使用的MySQL版本

5.x版本请使用 com.mysql.jdbc.Driver  

8.x版本请使用 com.mysql.cj.jdbc.Driver

service:
  vgroupMapping:
    ruoyi-system-group: default
store:
  db:
    datasource: druid
    dbType: mysql
    driverClassName: com.mysql.jdbc.Driver #此处请注意 5.x版本请使用com.mysql.jdbc.Driver  8以上版本请使用 com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://127.0.0.1:3306/ry-seata?useUnicode=true    #创建的库(后边有教程)
    user: root   #数据库账号(自行修改)
    password: root   #数据库密码(自行修改)
    globalTable: global_table
    lockTable: lock_table
    branchTable: branch_table
    maxConn: 30
    maxWait: 5000
    minConn: 5
    queryLimit: 100
  mode: db

 若依微服务 + seata1.5.2版本分布式事务(安装配置nacos+部署)

4、nacos配置 给需要用到分布式事务的模块配置信息

添加service.vgroupMapping.ruoyi-xxxx-group配置信息(多个服务模块都需要用分布式事务的话,请添加多个这样的配置,每个配置名称需对应服务模块名称)

service.vgroupMapping.ruoyi-xxxx-group (ruoyi-xxxx-group 中的ruoyi-xxxx请修改为对应的服务名)

内容:default

若依微服务 + seata1.5.2版本分布式事务(安装配置nacos+部署)

若依微服务 + seata1.5.2版本分布式事务(安装配置nacos+部署)

5、nacos修改服务模块配置(需要使用分布式事务的模块配置都需要修改):

 若依微服务 + seata1.5.2版本分布式事务(安装配置nacos+部署)

三、配置数据库(mysql)

1、 由于seata使用mysql作为db高可用数据库,故需要在mysql创建一个ry-seata库,并导入数据库脚本。

-- -------------------------------- 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_gmt_modified_status` (`gmt_modified`, `status`),
    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(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 = utf8mb4;

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

2、需要使用分布式事务项目模块对应的数据库中添加表(多个数据库的话,每个库中都需要加表)

CREATE TABLE `undo_log` (
  `id` bigint(20) NOT NULL AUTO_INCREMENT,
  `branch_id` bigint(20) NOT NULL,
  `xid` varchar(100) NOT NULL,
  `context` varchar(128) NOT NULL,
  `rollback_info` longblob NOT NULL,
  `log_status` int(11) NOT NULL,
  `log_created` datetime NOT NULL,
  `log_modified` datetime NOT NULL,
  `ext` varchar(100) DEFAULT NULL,
  PRIMARY KEY (`id`),
  UNIQUE KEY `ux_undo_log` (`xid`,`branch_id`)
) ENGINE=InnoDB AUTO_INCREMENT=25 DEFAULT CHARSET=utf8;

四、启动seata

打开setae的bin文件夹

若依微服务 + seata1.5.2版本分布式事务(安装配置nacos+部署)

1、windows系统:直接点击seata-server.bat即可启动seata

2、Linux系统:

        sh seata-server.sh -h xx.xx.x.xxx -p 8091

        注意上面的 -h :指该服务器ip,不指定的话,不然注册到nacos的会是不想要的本地ip(127.xx.xx.xx)

启动完成后可以浏览日志,或者去nacos中服务列表查看seata 服务是否已成功注册。如下图:

若依微服务 + seata1.5.2版本分布式事务(安装配置nacos+部署)

注意:seata启动会占用两个端口,8091 和 7091 。 其中 8091 是注册到nacos中的服务端端口,7091是其客户端端口。7091对应页面如下图:

访问地址:xx.xx.x.xxx:7091    账号:   seata/seata

若依微服务 + seata1.5.2版本分布式事务(安装配置nacos+部署)

五、微服务中需要使用分布式事务的模块添加事务注解 

 1、主服务添加的事务注解(调用其他模块的主服务方)

@Transactional
@GlobalTransactional(rollbackFor = Exception.class) // 重点 第一个开启事务的需要添加seata全局事务注解

  (rollbackFor = Exception.class):自定义的异常也可进行事务回滚(去除的话,自定义异常将会不进行事务回滚)

若依微服务 + seata1.5.2版本分布式事务(安装配置nacos+部署)

 2、被调用服务模块添加分布式事务注解

/** * 事务传播特性设置为 REQUIRES_NEW 开启新的事务 重要!!!!一定要使用REQUIRES_NEW */

 @Transactional(propagation = Propagation.REQUIRES_NEW)

若依微服务 + seata1.5.2版本分布式事务(安装配置nacos+部署)

以上内容就是所有配置教程了,到此结束!

​​​​​​​以下内容作为参考:

注意:如果代码运行时出现以下异常,则是序列化问题

json decode exception, Cannot construct instance of `java.time.LocalDateTime` (no Creators, like default constructor, exist): cannot deserialize from Object value (no delegate- or property-based Creator)
 at [Source: (byte[])"{"@class":"io.seata.rm.datasource.undo.BranchUndoLog","xid":"192.168.1.5:8091:298880381343518720","branchId":298880382744416257,"sqlUndoLogs":["java.util.ArrayList",[{"@class":"io.seata.rm.datasource.undo.sqlUndoLog","sqlType":"UPDATE","tableName":"stock_tbl","beforeImage":{"@class":"io.seata.rm.datasource.sql.struct.TableRecords","rows":["java.util.ArrayList",[{"@class":"io.seata.rm.datasource.sql.struct.Row","fields":["java.util.ArrayList",[{"@class":"io.seata.rm.dataso"[truncated 12232 bytes]; line: 1,column: 3987] (through reference chain: io.seata.rm.datasource.undo.BranchUndoLog["sqlUndoLogs"]->java.util.ArrayList[1]->io.seata.rm.datasource.undo.sqlUndoLog["afterImage"]->io.seata.rm.datasource.sql.struct.TableRecords["rows"]->java.util.ArrayList[0]->io.seata.rm.datasource.sql.struct.Row["fields"]->java.util.ArrayList[6]->io.seata.rm.datasource.sql.struct.Field["value"])

Seata 默认采用的序列化方式是 jackson,报错信息显示jackson 反序列化失败

解决方案:降低mysql-connector-java版本(项目模块的pom)

调整mysql-connector-java版本 <= 8.0.22;

<dependency>
    <groupId>MysqL</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>8.0.22</version>
</dependency>

在该版本下,数据库的datetime 被解析为java.sql.Timestamp,因此也就不存在java.time.LocalDateTime无法反序列化的问题了。

这种方案最简单、快速,推荐;

解决方案可参考(多种解决方案):Seata json decode exception, Cannot construct instance of `java.time.LocalDateTime` 报错原因/解决方案最全汇总版 - 编程之家

Seata配置参考文章:

Seata1.5.2安装配置(nacos)+部署_seata安装和部署_不知道取啥昵称的博客-CSDN博客

分布式事务 seata 最全入门教程_seata教程_handsomeshao的博客-CSDN博客文章来源地址https://www.toymoban.com/news/detail-491672.html

到了这里,关于若依微服务 + seata1.5.2版本分布式事务(安装配置nacos+部署)的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • 微服务13-Seata的四种分布式事务模式

    XA模式分为两种情况 : 提交成功: 提交失败: 具有强一致性seata相当于是在RM上做了一层封装; XA模式 优点 : 1.事务的强一致性,只要有失败的,TC事务协调者就会发送信息让RM回滚——满足ACID原则 2.没有代码侵入,常用数据库都支持 缺点 : 1.第一阶段就要锁定数据库资源

    2024年02月07日
    浏览(30)
  • 【SpringCloud】微服务保护(Sentinel)和分布式事务(Seata)

    建议学完该系列前篇 【SpringCloud】商城项目拆分微服务各个组件学习 然后再来看本文 然后学习 【RabbitMQ】交换机、队列、可靠性保证和延迟消息 在微服务远程调用的过程中,还存在几个问题需要解决。 首先是业务健壮性问题: 例如在之前的查询购物车列表业务中,购物车

    2024年01月25日
    浏览(44)
  • Java微服务分布式事务框架seata的TCC模式

    🌹作者主页:青花锁 🌹简介:Java领域优质创作者🏆、Java微服务架构公号作者😄 🌹简历模板、学习资料、面试题库、技术互助 🌹文末获取联系方式 📝 专栏 描述 Java项目实战 介绍Java组件安装、使用;手写框架等 Aws服务器实战 Aws Linux服务器上操作nginx、git、JDK、Vue Jav

    2024年03月23日
    浏览(32)
  • 分布式事务篇-2.1 阿里云轻量服务器--Docker--部署Seata

    本文介绍基于Seata 解决分布式事务,Seata 是一个服务所有首先需要对其进行部署。 Seata 是一款开源的分布式事务解决方案,致力于提供高性能和简单易用的分布式事务服务。Seata 将为用户提供了 AT、TCC、SAGA 和 XA 事务模式,为用户打造一站式的分布式解决方案。 拷贝完毕删

    2024年02月11日
    浏览(31)
  • 第19关 5.2k star 开源分布式存储服务Rancher-Longhorn在k8s上部署

    ------ 课程视频同步分享在今日头条和B站 大家好,我是博哥爱运维。 什么是Longhorn Longhorn是一个轻量级、可靠且易于使用的Kubernetes分布式块存储系统。 Longhorn 是免费的开源软件。它最初由 Rancher Labs 开发,现在作为云原生计算基金会的孵化项目进行开发。 官方文档: https:

    2024年02月04日
    浏览(29)
  • 分布式:一文吃透分布式事务和seata事务

    什么是事务 事务是并发控制的单位,是用户定义的一个操作序列。 事务特性 原子性(Atomicity): 事务是数据库的逻辑工作单位,事务中包括的诸操作要么全做,要么全不做。 一致性(Consistency): 事务执行的结果必须是使数据库从一个一致性状态变到另一个一致性状态。一致性

    2024年02月07日
    浏览(46)
  • SpringCloud(17~21章):Alibaba入门简介、Nacos服务注册和配置中心、Sentinel实现熔断与限流、Seata处理分布式事务

    Spring Cloud Netflix项目进入维护模式 https://spring.io/blog/2018/12/12/spring-cloud-greenwich-rc1-available-now 说明 Spring Cloud Netflix Projects Entering Maintenance Mode 什么是维护模式 将模块置于维护模式,意味着 Spring Cloud 团队将不会再向模块添加新功能。我们将修复 block 级别的 bug 以及安全问题,我

    2024年01月19日
    浏览(46)
  • 分布式事务 Seata

    事务(Transaction)是计算机科学中的一个重要概念,主要是指一个 完整的、不可分割的操作序列 。在关系型数据库中,事务通常用于描述对数据库进行的一系列操作的执行单元。 事务的ACID特性 : 原子性(Atomicity):事务是一个原子操作,要么全部执行,要么全部回滚。如

    2024年02月17日
    浏览(36)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包