Spring Cloud Alibaba集成Seata分布式事务

Dear 丶 2022-10-06 04:47 189阅读 0赞

1.  **框架版本**  
    Spring Cloud：Hoxton.SR5  
    Spring Cloud Alibaba：2.2.3.RELEASE  
    Nacos：2.0.0  
    Seata：1.3
2.  **安装下载**  
    Seata[下载地址][Link 1]  
    Nacos[下载地址][Link 2]  
    nacos启动脚本在bin目录下startup.cmd  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI1NDUzMTgx_size_16_color_FFFFFF_t_70_pic_center]  
    seata在启动之前需要做一些配置修改（本文seata服务注册中心使用nacos，配置文件加载地址也使用nacos）
    
    1.  修改conf文件下的file.conf  
        mode="db"以及mysql和redis的配置信息
    2.  修改registry.conf  
        registry下的type=“nacos”，config下的type = “nacos”
    3.  下载seata源码，[下载地址][Link 2]
    4.  执行script/server/db下sql文件，以及script/client/db下sql文件这个sql脚本有问题没有id主键，自己添加一下
    5.  修改源码script/config-center/config.txt  
        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.XXX这里XXX名字随便起  
        service.vgroupMapping.account-service=default  
        service.vgroupMapping.order-service=default  
        service.vgroupMapping.repo-service=default  
        service.vgroupMapping.rest-web=default  
        \#这里的名字与file.conf中default.grouplist = "127.0.0.1:8091"相同  
        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.sqlParserType=druid  
        client.rm.reportSuccessEnable=false  
        client.rm.sagaBranchRegisterEnable=false  
        client.tm.commitRetryCount=5  
        client.tm.rollbackRetryCount=5  
        client.tm.degradeCheck=false  
        client.tm.degradeCheckAllowTimes=10  
        client.tm.degradeCheckPeriod=2000  
        \#这里修改为db  
        store.mode=db  
        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://127.0.0.1:3306/seata?useUnicode=true&useSSL=false&characterEncoding=utf8&serverTimezone=Asia/Shanghai  
        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.host=127.0.0.1  
        store.redis.port=6379  
        store.redis.maxConn=10  
        store.redis.minConn=1  
        store.redis.database=0  
        store.redis.password=null  
        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.log.exceptionRate=100  
        transport.serialization=seata  
        transport.compressor=none  
        metrics.enabled=false  
        metrics.registryType=compact  
        metrics.exporterList=prometheus  
        metrics.exporterPrometheusPort=9898
    6.  在script/config-center/nacos下打开Git Bash Here使用命令sh nacos-config.sh 127.0.0.1将配置信息注册到nacos，打开nacos在配置列表可以看到  
        ![nacos配置列表][nacos]
    7.  在seata/bin下启动seata-server.bat
3.  添加依赖

<dependency>
              <groupId>com.alibaba.cloud</groupId>
              <artifactId>spring-cloud-starter-alibaba-seata</artifactId>
              <exclusions>
                  <exclusion>
                      <groupId>io.seata</groupId>
                      <artifactId>seata-all</artifactId>
                  </exclusion>
              </exclusions>
          </dependency>
          <dependency>
              <groupId>io.seata</groupId>
              <artifactId>seata-spring-boot-starter</artifactId>
              <version>1.3.0</version>
          </dependency>

1.  添加seata配置信息

# seata配置
    seata:
      application-id: ${ spring.application.name}
      tx-service-group: rest-web
      service:
        grouplist:
          default: 127.0.0.1:8091
        vgroup-mapping:
          rest-web: default
      enabled: true
      config:
        type: nacos
        nacos:
          namespace:
          server-addr: 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"

> 注意：seata.tx-service-group=rest-web和seata.service.vgroup-mapping.rest-web=default，tx-service-group事务组名字和vgroup-mapping.XXX的XXX相同，并且vgroup-mapping.XXX必须在之前修改的conf.txt中存在，即在nacos配置列表中存在。

1.  使用@GlobalTransactional开启事务

到此结束，[源码地址][Link 3]

[Link 1]: https://github.com/seata/seata/releases
[Link 2]: https://github.com/alibaba/nacos/releases
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI1NDUzMTgx_size_16_color_FFFFFF_t_70_pic_center]: /images/20221005/c148742733864d938748475e9e45d76b.png
[nacos]: /images/20221005/c3f1ffc8a1c44354a5f6c8c7db1569c6.png
[Link 3]: https://gitee.com/wy521/spring-cloud-alibaba-seata?_from=gitee_search