共计 9624 个字符，预计需要花费 25 分钟才能阅读完成。
这篇文章给大家分享的是有关分布式事务 seata1.3.0 如何整合 nacos 的内容。丸趣 TV 小编觉得挺实用的，因此分享给大家做个参考，一起跟随丸趣 TV 小编过来看看吧。
分布式事务 seata-demo 版本介绍
JDK：1.8
spring-cloud.version：Hoxton.SR8
alibaba.version：2.2.1.RELEASE
seata.version：1.3.0
nacos: 1.3.1
整合步骤
下载 nacos 我下载的 nacos-server-1.3.2.zip
seata 我下载的是 seata-server-1.3.0.zip
创建数据库 server 数据库脚本 同时每一个参与事务的数据库需要添加一张表 下载地址
上传 seata 配置到 nacos
下载 nacos-config.sh 文件, 放到解压文件 conf 文件夹下
修改 conf 目录下 file.conf 配置文件，主要是修改自定义事务组名称，事务日志存储模式为 db，并修改数据库连接信息
service {
#vgroup- rgroup
vgroup_mapping.tx-service-group = default # 修改事务组名称为：tx-service-group，和客户端自定义的名称对应
#only support single node
default.grouplist = 127.0.0.1:8091
#degrade current not support
enableDegrade = false
#disable
disable = false
#unit ms,s,m,h,d represents milliseconds, seconds, minutes, hours, days, default permanent
max.commit.retry.timeout = -1
max.rollback.retry.timeout = -1
## transaction log store, only used in seata-server
store {
## store mode: file、db、redis
mode = db
## database store property
db {## the implement of javax.sql.DataSource, such as DruidDataSource(druid)/BasicDataSource(dbcp)/HikariDataSource(hikari) etc.
datasource = druid
## mysql/oracle/postgresql/h3/oceanbase etc.
dbType = mysql
driverClassName = com.mysql.jdbc.Driver
url = jdbc:mysql://192.168.240.129:3306/seat_server
user = root
password = Root_123456
minConn = 5
maxConn = 30
globalTable = global_table
branchTable = branch_table
lockTable = lock_table
queryLimit = 100
maxWait = 5000
}
}修改 conf 目录下 registry.conf 配置，指明注册中心为 nacos，及修改 nacos 连接信息。
registry {
# file 、nacos 、eureka、redis、zk、consul、etcd3、sofa
type = nacos
nacos {
application = seata-server
serverAddr = 127.0.0.1:8848
group = default
namespace =
cluster = default
username = nacos
password = nacos
}
config {
# file、nacos 、apollo、zk、consul、etcd3 SEATA_GROUP
type = nacos
nacos {
serverAddr = 127.0.0.1:8848
namespace = default
group =
username = nacos
password = nacos
}
}上传配置到 nacos: 在 conf 目录下打开 git bash here 执行 nacos-config.sh 输入命令 sh nacos-config.sh -h 127.0.0.1
创建 client 服务
创建 seat_order 库，用来存储订单信息
创建 seat_storage 库，用来存储库存信息
创建 seat_account，用来存储账户信息
三个库添加日志回滚表
完整数据库示意图
5. 创建 seata-order-service（订单服务），seata-storage-service（库存服务），seata-account-service（账户服务）配置内容大同小异以 order 服务的配置为例, 修改 bootstrap.yml 文件
server:
port: 8180
spring:
application:
name: seata-order-service
cloud:
nacos:
discovery:
server-addr: 127.0.0.1:8848
username: nacos
password: nacos
config:
server-addr: 127.0.0.1:8848
username: nacos
password: nacos
mybatis:
mapperLocations: classpath:mapper/*.xml修改 application.yml 文件
seata:
enabled: true
application-id: seata-order-service
tx-service-group: my_test_tx_group #tx-service-group 需要与 conf 目录下 file.conf 文件下名称一致
config:
type: nacos
nacos:
namespace:
serverAddr: 127.0.0.1:8848
group: SEATA_GROUP
username: nacos
password: nacos
registry:
type: nacos
nacos:
application: seata-server
server-addr: 127.0.0.1:8848
group: SEATA_GROUP
namespace:
username: nacos
password: nacos
spring:
datasource:
#driver-class-name: com.mysql.jdbc.Driver
username: root
password: Root_123456
url: jdbc:mysql://192.168.240.129:3306/seat_order?characterEncoding=utf-8 useSSL=false添加主方法
@RestController
@RequestMapping(value = /order)
public class OrderController {
@Autowired
private OrderService orderService;
/**
* 创建订单
*/
@GetMapping(/create)
@GlobalTransactional
public CommonResult create(Order order) { orderService.create(order);
return new CommonResult(订单创建成功! , 200);
}
}启动 nacos，seata，seata-order-service，seata-storage-service，seata-account-service
2020-09-21 16:17:08.307 INFO 29768 --- [ main] i.s.s.a.GlobalTransactionScanner : Initializing Global Transaction Clients ...
2020-09-21 16:17:08.394 INFO 29768 --- [ main] i.s.core.rpc.netty.NettyClientBootstrap : NettyClientBootstrap has started
2020-09-21 16:17:08.394 INFO 29768 --- [ main] i.s.s.a.GlobalTransactionScanner : Transaction Manager Client is initialized. applicationId[seata-order-service] txServiceGroup[my_test_tx_group]
2020-09-21 16:17:08.403 INFO 29768 --- [ main] io.seata.rm.datasource.AsyncWorker : Async Commit Buffer Limit: 10000
2020-09-21 16:17:08.403 INFO 29768 --- [ main] i.s.rm.datasource.xa.ResourceManagerXA : ResourceManagerXA init ...
2020-09-21 16:17:08.408 INFO 29768 --- [ main] i.s.core.rpc.netty.NettyClientBootstrap : NettyClientBootstrap has started
2020-09-21 16:17:08.408 INFO 29768 --- [ main] i.s.s.a.GlobalTransactionScanner : Resource Manager is initialized. applicationId[seata-order-service] txServiceGroup[my_test_tx_group]
2020-09-21 16:17:08.408 INFO 29768 --- [ main] i.s.s.a.GlobalTransactionScanner : Global Transaction Clients are initialized.3. 测试分布式事务
库的初始状态
访问 http://localhost:8180/order/create?userId=1 productId=1 count=10 money=100
2020-09-21 16:27:22.497 INFO 29768 --- [nio-8180-exec-9] i.seata.tm.api.DefaultGlobalTransaction : Begin new global transaction [192.168.240.1:8091:51345170083352576]
2020-09-21 16:27:22.497 INFO 29768 --- [nio-8180-exec-9] c.m.cloud.service.impl.OrderServiceImpl : ------- 下单开始
2020-09-21 16:27:22.508 INFO 29768 --- [nio-8180-exec-9] c.m.cloud.service.impl.OrderServiceImpl : ------- order-service 中扣减库存开始
2020-09-21 16:27:22.530 INFO 29768 --- [nio-8180-exec-9] c.m.cloud.service.impl.OrderServiceImpl : ------- order-service 中扣减库存结束
2020-09-21 16:27:22.530 INFO 29768 --- [nio-8180-exec-9] c.m.cloud.service.impl.OrderServiceImpl : ------- order-service 中扣减余额开始
2020-09-21 16:27:22.543 INFO 29768 --- [nio-8180-exec-9] c.m.cloud.service.impl.OrderServiceImpl : ------- order-service 中扣减余额结束
2020-09-21 16:27:22.543 INFO 29768 --- [nio-8180-exec-9] c.m.cloud.service.impl.OrderServiceImpl : ------- order-service 中修改订单状态开始
2020-09-21 16:27:22.550 INFO 29768 --- [nio-8180-exec-9] c.m.cloud.service.impl.OrderServiceImpl : ------- order-service 中修改订单状态结束
2020-09-21 16:27:22.550 INFO 29768 --- [nio-8180-exec-9] c.m.cloud.service.impl.OrderServiceImpl : ------- 下单结束
2020-09-21 16:27:22.552 INFO 29768 --- [nio-8180-exec-9] i.seata.tm.api.DefaultGlobalTransaction : [192.168.240.1:8091:51345170083352576] commit status: Committed
2020-09-21 16:27:22.560 INFO 29768 --- [h_RMROLE_1_6_16] i.s.c.r.p.c.RmBranchCommitProcessor : rm client handle branch commit process:xid=192.168.240.1:8091:51345170083352576,branchId=51345170112712704,branchType=AT,resourceId=jdbc:mysql://192.168.240.129:3306/seat_order,applicationData=null
2020-09-21 16:27:22.560 INFO 29768 --- [h_RMROLE_1_6_16] io.seata.rm.AbstractRMHandler : Branch committing: 192.168.240.1:8091:51345170083352576 51345170112712704 jdbc:mysql://192.168.240.129:3306/seat_order null
2020-09-21 16:27:22.560 INFO 29768 --- [h_RMROLE_1_6_16] io.seata.rm.AbstractRMHandler : Branch commit result: PhaseTwo_Committed
2020-09-21 16:27:22.622 INFO 29768 --- [h_RMROLE_1_7_16] i.s.c.r.p.c.RmBranchCommitProcessor : rm client handle branch commit process:xid=192.168.240.1:8091:51345170083352576,branchId=51345170297262080,branchType=AT,resourceId=jdbc:mysql://192.168.240.129:3306/seat_order,applicationData=null
2020-09-21 16:27:22.622 INFO 29768 --- [h_RMROLE_1_7_16] io.seata.rm.AbstractRMHandler : Branch committing: 192.168.240.1:8091:51345170083352576 51345170297262080 jdbc:mysql://192.168.240.129:3306/seat_order null
2020-09-21 16:27:22.622 INFO 29768 --- [h_RMROLE_1_7_16] io.seata.rm.AbstractRMHandler : Branch commit result: PhaseTwo_Committed数据库状态
模拟异常
/**
* 扣减账户余额
*/
@Override
public void decrease(Long userId, BigDecimal money) {
LOGGER.info( ------- account-service 中扣减账户余额开始
// 模拟超时异常，全局事务回滚
try { Thread.sleep(30*1000);
} catch (InterruptedException e) { e.printStackTrace();
}
accountDao.decrease(userId,money);
LOGGER.info( ------- account-service 中扣减账户余额结束
}会发现数据库没有变化，并且控制台打印日志如下
2020-09-21 16:29:53.921 INFO 29768 --- [nio-8180-exec-3] i.seata.tm.api.DefaultGlobalTransaction : Begin new global transaction [192.168.240.1:8091:51345805197447168]
2020-09-21 16:29:53.921 INFO 29768 --- [nio-8180-exec-3] c.m.cloud.service.impl.OrderServiceImpl : ------- 下单开始
2020-09-21 16:29:53.931 INFO 29768 --- [nio-8180-exec-3] c.m.cloud.service.impl.OrderServiceImpl : ------- order-service 中扣减库存开始
2020-09-21 16:29:53.957 INFO 29768 --- [nio-8180-exec-3] c.m.cloud.service.impl.OrderServiceImpl : ------- order-service 中扣减库存结束
2020-09-21 16:29:53.957 INFO 29768 --- [nio-8180-exec-3] c.m.cloud.service.impl.OrderServiceImpl : ------- order-service 中扣减余额开始
2020-09-21 16:29:56.099 INFO 29768 --- [h_RMROLE_1_8_16] i.s.c.r.p.c.RmBranchRollbackProcessor : rm handle branch rollback process:xid=192.168.240.1:8091:51345805197447168,branchId=51345805231001600,branchType=AT,resourceId=jdbc:mysql://192.168.240.129:3306/seat_order,applicationData=null
2020-09-21 16:29:56.100 INFO 29768 --- [h_RMROLE_1_8_16] io.seata.rm.AbstractRMHandler : Branch Rollbacking: 192.168.240.1:8091:51345805197447168 51345805231001600 jdbc:mysql://192.168.240.129:3306/seat_order
2020-09-21 16:29:56.142 INFO 29768 --- [h_RMROLE_1_8_16] i.s.r.d.undo.AbstractUndoLogManager : xid 192.168.240.1:8091:51345805197447168 branch 51345805231001600, undo_log deleted with GlobalFinished
2020-09-21 16:29:56.143 INFO 29768 --- [h_RMROLE_1_8_16] io.seata.rm.AbstractRMHandler : Branch Rollbacked result: PhaseTwo_Rollbacked
2020-09-21 16:29:56.147 INFO 29768 --- [nio-8180-exec-3] i.seata.tm.api.DefaultGlobalTransaction : [192.168.240.1:8091:51345805197447168] rollback status: Rollbacked
2020-09-21 16:29:56.167 ERROR 29768 --- [nio-8180-exec-3] o.a.c.c.C.[.[.[/].[dispatcherServlet] : Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Request processing failed; nested exception is feign.RetryableException: Read timed out executing GET http://seata-account-service/account/decrease?userId=1 money=100] with root cause
java.net.SocketTimeoutException: Read timed out
...感谢各位的阅读！关于“分布式事务 seata1.3.0 如何整合 nacos”这篇文章就分享到这里了，希望以上内容可以对大家有一定的帮助，让大家可以学到更多知识，如果觉得文章不错，可以把它分享出去让更多的人看到吧！
正文完
