Spring Cloud 使用 Seata 实现分布式事务，Nacos 作为 Seata 配置中心

雨点打透心脏的1/2处 2023-05-30 06:08 71阅读 0赞

至于对Nacos和Seata的介绍，请移步GitHub官网：

Nacos：https://nacos.io/zh-cn/docs/quick-start.html

Seata：https://github.com/seata/seata/wiki/Home\_Chinese

Nacos Server下载地址：https://github.com/alibaba/nacos/releases

Seata Server下载地址：https://github.com/seata/seata/releases

文章中的源码在GitHub

环境准备  
创建数据库及表（在官方demo中的all\_in\_one.sql）  
要求：带有InnoDB引擎的MySQL。  
注意：实际上，示例用例中的3个服务应该有3个数据库。但是，我们只需创建一个数据库并配置3个数据源即可。

业务表  
create schema db\_account;  
use db\_account;  
   
CREATE TABLE \`account\_tbl\` (  
       \`id\` int(11) NOT NULL AUTO\_INCREMENT,  
       \`user\_id\` varchar(255) DEFAULT NULL,  
       \`money\` int(11) DEFAULT 0,  
       PRIMARY KEY (\`id\`)  
) ENGINE=InnoDB DEFAULT CHARSET=utf8;  
   
INSERT INTO account\_tbl (id, user\_id, money) VALUES (1, '1001', 10000);  
INSERT INTO account\_tbl (id, user\_id, money) VALUES (2, '1002', 10000);  
   
CREATE TABLE \`undo\_log\` (  
  \`id\` bigint(20) NOT NULL AUTO\_INCREMENT,  
  \`branch\_id\` bigint(20) NOT NULL,  
  \`xid\` varchar(100) 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=9 DEFAULT CHARSET=utf8;  
   
create schema db\_order;  
   
use db\_order;  
   
CREATE TABLE \`order\_tbl\` (  
  \`id\` int(11) NOT NULL AUTO\_INCREMENT,  
  \`user\_id\` varchar(255) DEFAULT NULL,  
  \`commodity\_code\` varchar(255) DEFAULT NULL,  
  \`count\` int(11) DEFAULT '0',  
  \`money\` int(11) DEFAULT '0',  
  PRIMARY KEY (\`id\`)  
) ENGINE=InnoDB AUTO\_INCREMENT=9 DEFAULT CHARSET=utf8;  
   
CREATE TABLE \`undo\_log\` (  
  \`id\` bigint(20) NOT NULL AUTO\_INCREMENT,  
  \`branch\_id\` bigint(20) NOT NULL,  
  \`xid\` varchar(100) 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=9 DEFAULT CHARSET=utf8;  
   
create schema db\_storage;  
   
use db\_storage;  
   
CREATE TABLE \`storage\_tbl\` (  
  \`id\` int(11) NOT NULL AUTO\_INCREMENT,  
  \`commodity\_code\` varchar(255) DEFAULT NULL,  
  \`count\` int(11) DEFAULT '0',  
  PRIMARY KEY (\`id\`),  
  UNIQUE KEY \`commodity\_code\` (\`commodity\_code\`)  
) ENGINE=InnoDB AUTO\_INCREMENT=2 DEFAULT CHARSET=utf8;  
   
   
INSERT INTO storage\_tbl (id, commodity\_code, count) VALUES (1, '2001', 1000);  
   
CREATE TABLE \`undo\_log\` (  
  \`id\` bigint(20) NOT NULL AUTO\_INCREMENT,  
  \`branch\_id\` bigint(20) NOT NULL,  
  \`xid\` varchar(100) 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=9 DEFAULT CHARSET=utf8;

启动 Nacos  
这里的 Nacos 配置使用的是本地启动的，nacos.config 的 Group, namespace 都是默认的，如果需要可以修改成自己对应的，可以参考官方文档：https://nacos.io/zh-cn/docs/quick-start.html

sh startup.sh -m standalone

启动 Seata Server  
在 Seata Release 下载最新版的 Seata Server 并解压得到如下目录：  
.  
├──bin  
├──conf  
├──file\_store  
└──lib  
修改 conf/registry.conf 配置，将 type 改为 nacos  
registry \{  
  type = "nacos"  
   
  nacos \{  
    serverAddr = "localhost"  
    namespace = "public"  
    cluster = "default"  
  \}  
\}  
   
config \{  
  type = "nacos"  
   
  nacos \{  
    serverAddr = "localhost"  
    namespace = "public"  
    cluster = "default"  
  \}  
\}  
修改 conf/nacos-config.txt配置  
修改 service.vgroup\_mapping为自己应用对应的名称；如果有多个服务，添加相应的配置(service.vgroup\_mapping后面的值要与spring.cloud.alibaba.seata.tx-service-group对应的值匹配)如：

service.vgroup\_mapping.my\_test\_tx\_group=default  
   
//改为   
   
service.vgroup\_mapping.storage-service-fescar-service-group=default  
service.vgroup\_mapping.order-service-fescar-service-group=default  
service.vgroup\_mapping.business-service-fescar-service-group=default  
service.vgroup\_mapping.account-service-fescar-service-group=default  
也可以在 Nacos 配置页面添加，data-id 为 service.vgroup\_mapping.$\{YOUR\_SERVICE\_NAME\}-fescar-service-group, group 为 SEATA\_GROUP， 如果不添加该配置，启动后会提示no available server to connect

注意配置文件末尾有空行，需要删除，否则会提示失败，尽管实际上是成功的

将 Seata 配置添加到 Nacos 中  
cd conf  
sh nacos-config.sh localhost  
成功后会提示

init nacos config finished, please start seata-server

在 Nacos 管理页面应该可以看到有 47 个 Group 为SEATA\_GROUP的配置

启动 Seata Server  
cd ..  
sh ./bin/seata-server.sh 8091 file

启动后在 Nacos 的服务列表下面可以看到一个名为serverAddr的服务

用例  
参考官网中用户购买商品的业务逻辑。整个业务逻辑由3个微服务提供支持：

存储服务：扣除给定商品的存储数量。  
订单服务：根据购买请求创建订单。  
帐户服务：借记用户帐户的余额。  
请求逻辑

分别启动：

ExampleBusinessApplication  
ExampleAccountApplication  
ExampleOrderApplication  
ExampleStorageApplication  
其中ExampleBusinessApplication服务中暴露了两个主要测试接口

http://127.0.0.1:8084/purchase/commit接口是可以正常执行完成的方法

http://127.0.0.1:8084/purchase/rollback接口是会发生异常并正常回滚的方法

需要修改的文件：

1、各个服务中的application.properties的spring.cloud.alibaba.seata.tx-service-group

2、各个服务中的registry.conf的type

3、seata-server中的conf/nacos-config.txt的service.vgroup\_mapping

文章参考：

https://github.com/helloworlde/spring-cloud-alibaba-component/tree/master/cloud-seata-nacos  
————————————————  
版权声明：本文为CSDN博主「qq\_27376871」的原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接及本声明。  
原文链接：https://blog.csdn.net/qq\_27376871/article/details/91570779