栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

SpringCloud:seata 事务之AT模式(2)

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

SpringCloud:seata 事务之AT模式(2)

SpringCloud:seata 之AT模式(2)

文章目录
  • SpringCloud:seata 之AT模式(2)
    • 关联文章
    • 1、项目结构
    • 2、引入依赖
    • 3、seata配置
      • 3.1、本地配置
    • 3.2、nacos配置中心配置


关联文章

SpringCloud:seata 服务端启动以及介绍

SpringCloud:seata 事务之AT模式

SpringCloud:seata 事务之TCC模式

1、项目结构

  • 客户端在调用其他微服务时,添加了一个注解@GlobalTransactional保证全局事务。

  • 而每个服务端都有一个自己的事务注解,@Transactional,保证自己本服务的事务。

2、引入依赖
        
        
            com.alibaba.cloud
            spring-cloud-alibaba-seata
        
        
            io.seata
            seata-spring-boot-starter
            1.4.2
            
                
                    io.seata
                    seata-all
                
            
        
        
            io.seata
            seata-all
            1.4.2
        
3、seata配置 3.1、本地配置
spring:
  cloud:
    nacos:
      discovery:
        server-addr: 127.0.0.1:8848
    alibaba:
      seata:
		#seata事务编号 对应配置中心的 service.vgroupMapping.seata-service-group=default
        tx-service-group: seata-service-group 
seata:
  enabled: true
  application-id: ${spring.application.name} #seata应用编号,默认${spring.application.name}
  data-source-proxy-mode: AT # 指定AT模式 也可指定XA模式
  config:  # seata配置中心
    type: nacos
    nacos:
      data-id: seata.properties
      group: SEATA_GROUP
      username: "nacos"
      password: "nacos"
  enable-auto-data-source-proxy: true
3.2、nacos配置中心配置
transport.type=TCP
transport.server=NIO
transport.heartbeat=true
transport.enableClientBatchSendRequest=false
transport.threadFactory.bossThreadPrefix=NettyBoss
transport.threadFactory.workerThreadPrefix=NettyServerNIOWorker
transport.threadFactory.serverExecutorThreadPrefix=NettyServerBizHandler
transport.threadFactory.shareBossWorker=false
transport.threadFactory.clientSelectorThreadPrefix=NettyClientSelector
transport.threadFactory.clientSelectorThreadSize=1
transport.threadFactory.clientWorkerThreadPrefix=NettyClientWorkerThread
transport.threadFactory.bossThreadSize=1
transport.threadFactory.workerThreadSize=default
transport.shutdown.wait=3
service.vgroupMapping.seata-service-group=default
service.default.grouplist=127.0.0.1:8091
service.enableDegrade=false
service.disableGlobalTransaction=false
client.rm.asyncCommitBufferLimit=10000
client.rm.lock.retryInterval=10
client.rm.lock.retryTimes=30
client.rm.lock.retryPolicyBranchRollbackOnConflict=true
client.rm.reportRetryCount=5
client.rm.tableMetaCheckEnable=false
client.rm.tableMetaCheckerInterval=60000
client.rm.sqlParserType=druid
client.rm.reportSuccessEnable=false
client.rm.sagaBranchRegisterEnable=false
client.tm.commitRetryCount=5
client.tm.rollbackRetryCount=5
client.tm.defaultGlobalTransactionTimeout=60000
client.tm.degradeCheck=false
client.tm.degradeCheckAllowTimes=10
client.tm.degradeCheckPeriod=2000
store.mode=db
store.publicKey=
store.file.dir=file_store/data
store.file.maxBranchSessionSize=16384
store.file.maxGlobalSessionSize=512
store.file.fileWriteBufferCacheSize=16384
store.file.flushDiskMode=async
store.file.sessionReloadReadSize=100
store.db.datasource=druid
store.db.dbType=mysql
store.db.driverClassName=com.mysql.jdbc.Driver
store.db.url=jdbc:mysql://localhost:3306/seata?useUnicode=true&characterEncoding=utf-8&useSSL=false
store.db.user=root
store.db.password=123456
store.db.minConn=5
store.db.maxConn=30
store.db.globalTable=global_table
store.db.branchTable=branch_table
store.db.queryLimit=100
store.db.lockTable=lock_table
store.db.maxWait=5000
store.redis.mode=single
store.redis.single.host=127.0.0.1
store.redis.single.port=6379
store.redis.sentinel.masterName=
store.redis.sentinel.sentinelHosts=
store.redis.maxConn=10
store.redis.minConn=1
store.redis.maxTotal=100
store.redis.database=0
store.redis.password=
store.redis.queryLimit=100
server.recovery.committingRetryPeriod=1000
server.recovery.asynCommittingRetryPeriod=1000
server.recovery.rollbackingRetryPeriod=1000
server.recovery.timeoutRetryPeriod=1000
server.maxCommitRetryTimeout=-1
server.maxRollbackRetryTimeout=-1
server.rollbackRetryTimeoutUnlockEnable=false
client.undo.dataValidation=true
client.undo.logSerialization=jackson
client.undo.onlyCareUpdateColumns=true
server.undo.logSaveDays=7
server.undo.logDeletePeriod=86400000
client.undo.logTable=undo_log
client.undo.compress.enable=true
client.undo.compress.type=zip
client.undo.compress.threshold=64k
log.exceptionRate=100
transport.serialization=seata
transport.compressor=none
metrics.enabled=false
metrics.registryType=compact
metrics.exporterList=prometheus
metrics.exporterPrometheusPort=9898

需要注意的地方,因为选用的是nacos配置,其实配置都在nacos上。

  • service.default.grouplist 属性对应的就是seata服务端的地址
  • service.vgroupMapping.seata-service-group=default中的seata-service-group与我们配置文件的alibab.seata.tx-service-group是对应的,保持一致。
转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/837448.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号