【SpringCloud-Alibaba系列教程】16.动态配置yml以及分布式事务

2022-03-25 1020

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

简介： 动态配置yml、分布式事务以及使用seata。

Nacos Config

我们在普通的项目文件中都是使用本地的yml文件进行本地的配置，在nacos中，也是可以将各个微服务的配置文件放进去，从nacos读取配置文件。

首先我们引入nacos config配置依赖

然后在项目中新建bootstrap.yml需要注意的是bootstrap.yml（bootstrap.properties）用来在程序引导时执行，应用于更加早期配置信息读取，如可以使用来配置application.yml中使用到参数等
application.yml（application.properties) 应用程序特有配置信息，可以用来配置后续各个模块中需使用的公共参数等。
bootstrap.yml 先于 application.yml 加载
首先我们可以在nacos端配置相关内容。

新建后我们把项目代码中的yml复制到nacos中。

然后就是项目端，需要我们进行修改，在这里为了不影响后续，我直接把application.yml的全部内容注释，然后新建bootstrap.yml

启动项目，项目正常运行，这样我们就实现了在nacos中配置。
其实这样不会实现自动刷新，意思是在项目启动了以后，如果我们更新了yaml的话，不会刷新相关配置的，那如何配置呢？其实只需要在controller注解@RefreshScope就可以实现实时读取相关配置了。
如何实现不同微服务的配置共享呢？
我们先介绍单个微服务共享
我们其实就和在项目文件中配置一样，我们把公共配置提取出来，在命名上稍有不同。
新建一个配置。名称不带后面具体配置的就可以了。
那不同微服务的配置共享其实需要在bootstrap.yml中配置以下

在nacos中新建all-service.yaml

相见分支参考220321_xgc_nacosConfig

seata实现分布式事务。

在传统的单体项目中，多个不同的业务逻辑使用的都是同一个数据源，使用的都是同一个事务管理器，所以不会存在事务问题。
在分布式或者微服务架构中，每个服务都有自己的数据源，使用不同事务管理器，如果A服务去调用B服务，B服务执行失败了，A服务的事务和B服务的事务都会回滚，这时候是不存在事务问题的，但是如果A服务B服务执行成功之后出现异常，A服务的事务会回滚，但是B服务的事务不会回滚，此时就存在分布式事务问题。
（在单体的项目中，有多个不同的数据源，每个数据源中都有自己独立的事务管理器，互不影响，那么这时候也会存在多数据源事务管理：解决方案jta+ atominc）
首先我们需要在官网下载seata，本文使用的seata版本是1.4.2
将下载好的压缩包，解压到指定目录文件夹下。解压之后的目录文件结构

修改seata解压目录中的bin目录下的file.conf文件

修改seata解压目录中的bin目录下的registry.conf文件（可以参考项目分支resource目录下registry.conf文件）

在本地新建一个seata数据库，导入如下数据库脚本
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;
或者去官网拷贝数据库脚本，网址：https://github.com/seata/seata/blob/1.2.0/script/server/db/mysql.sql

去官copyconfig.txt配置和nacos-config.sh配置
config.txt 网址：https://github.com/seata/seata/blob/develop/script/config-center/config.txt
nacos-config.sh网址：https://github.com/seata/seata/blob/develop/script/config-center/nacos/nacos-config.sh
将config.txt配置放在安装seata的目录下，与bin目录同级

将nacos-config.sh copy下来的文件放在安装seata目录下的conf目录

修改config.txt中的部分配置
数据库的ip以及用户名密码

新建不同的事务组

将seata的配置导入到nacos的配置中心
在conf目录下，使用git将seata的配置导入nacos配置中心，前提是电脑环境上安装了git

使用如下命令进行导入：
sh nacos-config.sh -h localhost -p 8848 -g SEATA_GROUP -t 命名空间id这里我的是（e3868230-8c1f-42b8-b433-286408a175d6） -u nacos -w nacos
QQ截图20220322194828.png
QQ截图20220322194810.png
这样我们就可以在nacos中看到配置了

启动seata（前提nacos启动）打开bin目录

进入cmd命令行
输入 seata-server.bat -p 9000 -m file

然后我们首先需要在数据库初始化一张seata记录日志需要用到表。

然后我们首先需要在数据库初始化一张seata记录日志需要用到表。
CREATE TABLE undo_log (
id bigint NOT NULL AUTO_INCREMENT,
branch_id bigint NOT NULL,
xid varchar(100) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
context varchar(128) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
rollback_info longblob NOT NULL,
log_status int NOT NULL,
log_created datetime NOT NULL,
log_modified datetime NOT NULL,
PRIMARY KEY (id) USING BTREE,
UNIQUE INDEX ux_undo_log(xid, branch_id) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 2 CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Dynamic;
然后引入seata pom文件这需要排除之前的自带的seata

seata是通过代理数据源实现的。
所以要新建DataSourceProxyConfig

然后在resource目录下添加

以及相关的bootstrao.yml

然后只需要在这里添加一个注解，就可以实现全局事务了。

我们再扣减库存的时候模拟一个异常打一个断点

然后我们进行正常下单。
可以看到我们进入断点

又到了扣减库存这里
我们首先看一下订单是不是增加了。

以及我们的回滚日志也有了

我们现在放开断点，抛出异常看看会发生什么？

发现我们的订单被删除了，回滚的log也没了。
其实这样就实现了我们分布式事务了。
具体还需要大家手动实现才能更加理解。
项目源码参考一下分支220321_xgc_seata
Gitee：https://gitee.com/coderxgc/springcloud-alibaba
GitHub：https://github.com/coderxgc/springcloud-alibaba
部分参考https://www.jianshu.com/p/fda8f616ba22