• Seata入门开发

    连接：https://pan.baidu.com/s/14Wg4r6v7m9OAfRxtCBs9Ow?pwd=3phv

    1.  Seata配置文件application.yml 
      1. server:
      2.   port: 7091
      3.  
      4. spring:
      5.   application:
      6.     name: seata-server
      7.  
      8. logging:
      9.   config: classpath:logback-spring.xml
      10.   file:
      11.     path: ${user.home}/logs/seata
      12. #   extend:
      13. #     logstash-appender:
      14. #       destination: 127.0.0.1:4560
      15. #     kafka-appender:
      16. #       bootstrap-servers: 127.0.0.1:9092
      17. #      topic: logback_to_logstash
      18.  
      19. console:
      20.   user:
      21.     username: seata
      22.     password: seata
      23.  
      24. seata:
      25.   config:
      26.     # support: nacos, consul, apollo, zk, etcd3
      27.     type: nacos
      28.     nacos:
      29.       server-addr: 127.0.0.1:8848
      30.       namespace:
      31.       group: SEATA_GROUP
      32.       username:
      33.       password:
      34.       ##if use MSE Nacos with auth, mutex with username/password attribute
      35.       #access-key: ""
      36.       #secret-key: ""
      37.       data-id: seataServer.properties
      38.   registry:
      39.     # support: nacos, eureka, redis, zk, consul, etcd3, sofa
      40.     type: nacos
      41.     nacos:
      42.       application: seata-server
      43.       server-addr: 127.0.0.1:8848
      44.       group: SEATA_GROUP
      45.       namespace:
      46.       cluster: default
      47.       username:
      48.       password:
      49.       ##if use MSE Nacos with auth, mutex with username/password attribute
      50.       #access-key: ""
      51.       #secret-key: ""
      52.   store:
      53.     # support: file 、 db 、 redis
      54.     mode: db
      55.     db:
      56.       datasource: druid
      57.       db-type: mysql
      58.       driver-class-name: com.mysql.cj.jdbc.Driver
      59.       url: jdbc:mysql://127.0.0.1:3306/seata?serverTimezone=Asia/Shanghai
      60.       user: root
      61.       password: 123456
      62.       min-conn: 5
      63.       max-conn: 100
      64.       global-table: global_table
      65.       branch-table: branch_table
      66.       lock-table: lock_table
      67.       distributed-lock-table: distributed_lock
      68.       query-limit: 100
      69.       max-wait: 5000
      70.   server:
      71.     service-port: 8091 #If not configured, the default is '${server.port} + 1000'
      72.     max-commit-retry-timeout: -1
      73.     max-rollback-retry-timeout: -1
      74.     rollback-retry-timeout-unlock-enable: false
      75.     enable-check-auth: true
      76.     enable-parallel-request-handle: true
      77.     retry-dead-threshold: 130000
      78.     xaer-nota-retry-timeout: 60000
      79.     recovery:
      80.       handle-all-session-period: 1000
      81.     undo:
      82.       log-save-days: 7
      83.       log-delete-period: 86400000
      84.     session:
      85.       branch-async-queue-size: 5000 #branch async remove queue size
      86.       enable-branch-async-remove: false #enable to asynchronous remove branchSession
      87.   security:
      88.     secretKey: SeataSecretKey0c382ef121d778043159209298fd40bf3850a017
      89.     tokenValidityInMilliseconds: 1800000
      90.     ignore:
      91.       urls: /,/**/*.css,/**/*.js,/**/*.html,/**/*.map,/**/*.svg,/**/*.png,/**/*.ico,/console-fe/public/**,/api/v1/auth/login
    2.  Nacos添加seataServer.properties 
      1. transport.type=TCP
      2. transport.server=NIO
      3. transport.heartbeat=true
      4. transport.enableTmClientBatchSendRequest=false
      5. transport.enableRmClientBatchSendRequest=true
      6. transport.enableTcServerBatchSendResponse=false
      7. transport.rpcRmRequestTimeout=30000
      8. transport.rpcTmRequestTimeout=30000
      9. transport.rpcTcRequestTimeout=30000
      10. transport.threadFactory.bossThreadPrefix=NettyBoss
      11. transport.threadFactory.workerThreadPrefix=NettyServerNIOWorker
      12. transport.threadFactory.serverExecutorThreadPrefix=NettyServerBizHandler
      13. transport.threadFactory.shareBossWorker=false
      14. transport.threadFactory.clientSelectorThreadPrefix=NettyClientSelector
      15. transport.threadFactory.clientSelectorThreadSize=1
      16. transport.threadFactory.clientWorkerThreadPrefix=NettyClientWorkerThread
      17. transport.threadFactory.bossThreadSize=1
      18. transport.threadFactory.workerThreadSize=default
      19. transport.shutdown.wait=3
      20. transport.serialization=seata
      21. transport.compressor=none
      22. service.vgroupMapping.my_test_tx_group=default
      23. service.default.grouplist=127.0.0.1:8091
      24. service.enableDegrade=false
      25. service.disableGlobalTransaction=false
      26. client.rm.asyncCommitBufferLimit=10000
      27. client.rm.lock.retryInterval=10
      28. client.rm.lock.retryTimes=30
      29. client.rm.lock.retryPolicyBranchRollbackOnConflict=true
      30. client.rm.reportRetryCount=5
      31. client.rm.tableMetaCheckEnable=true
      32. client.rm.tableMetaCheckerInterval=60000
      33. client.rm.sqlParserType=druid
      34. client.rm.reportSuccessEnable=false
      35. client.rm.sagaBranchRegisterEnable=false
      36. client.rm.sagaJsonParser=fastjson
      37. client.rm.tccActionInterceptorOrder=-2147482648
      38. client.tm.commitRetryCount=5
      39. client.tm.rollbackRetryCount=5
      40. client.tm.defaultGlobalTransactionTimeout=60000
      41. client.tm.degradeCheck=false
      42. client.tm.degradeCheckAllowTimes=10
      43. client.tm.degradeCheckPeriod=2000
      44. client.tm.interceptorOrder=-2147482648
      45. client.undo.dataValidation=true
      46. client.undo.logSerialization=jackson
      47. client.undo.onlyCareUpdateColumns=true
      48. server.undo.logSaveDays=7
      49. server.undo.logDeletePeriod=86400000
      50. client.undo.logTable=undo_log
      51. client.undo.compress.enable=true
      52. client.undo.compress.type=zip
      53. client.undo.compress.threshold=64k
      54. tcc.fence.logTableName=tcc_fence_log
      55. tcc.fence.cleanPeriod=1h
      56. log.exceptionRate=100
      57. store.mode=db
      58. store.lock.mode=file
      59. store.session.mode=file
      60. store.file.dir=file_store/data
      61. store.file.maxBranchSessionSize=16384
      62. store.file.maxGlobalSessionSize=512
      63. store.file.fileWriteBufferCacheSize=16384
      64. store.file.flushDiskMode=async
      65. store.file.sessionReloadReadSize=100
      66. store.db.datasource=druid
      67. store.db.dbType=mysql
      68. store.db.driverClassName=com.mysql.cj.jdbc.Driver
      69. store.db.url=jdbc:mysql://127.0.0.1:3306/seata?serverTimezone=Asia/Shanghai
      70. store.db.user=root
      71. store.db.password=123456
      72. store.db.minConn=5
      73. store.db.maxConn=30
      74. store.db.globalTable=global_table
      75. store.db.branchTable=branch_table
      76. store.db.distributedLockTable=distributed_lock
      77. store.db.queryLimit=100
      78. store.db.lockTable=lock_table
      79. store.db.maxWait=5000
      80. store.redis.mode=single
      81. store.redis.single.host=127.0.0.1
      82. store.redis.single.port=6379
      83. store.redis.maxConn=10
      84. store.redis.minConn=1
      85. store.redis.maxTotal=100
      86. store.redis.database=0
      87. store.redis.queryLimit=100
      88. server.recovery.committingRetryPeriod=1000
      89. server.recovery.asynCommittingRetryPeriod=1000
      90. server.recovery.rollbackingRetryPeriod=1000
      91. server.recovery.timeoutRetryPeriod=1000
      92. server.maxCommitRetryTimeout=-1
      93. server.maxRollbackRetryTimeout=-1
      94. server.rollbackRetryTimeoutUnlockEnable=false
      95. server.distributedLockExpireTime=10000
      96. server.xaerNotaRetryTimeout=60000
      97. server.session.branchAsyncQueueSize=5000
      98. server.session.enableBranchAsyncRemove=false
      99. server.enableParallelRequestHandle=false
      100. metrics.enabled=false
      101. metrics.registryType=compact
      102. metrics.exporterList=prometheus
      103. metrics.exporterPrometheusPort=9898

    3.  Seata数据库建表sql 
      1. /*
      2. Navicat MySQL Data Transfer
      4. Source Server         : mysql
      5. Source Server Version : 80020
      6. Source Host           : localhost:3306
      7. Source Database       : seata
      9. Target Server Type    : MYSQL
      10. Target Server Version : 80020
      11. File Encoding         : 65001
      13. Date: 2022-07-27 18:35:46
      14. */
      15.  
      16. SET FOREIGN_KEY_CHECKS=0;
      17.  
      18. -- ----------------------------
      19. -- Table structure for `branch_table`
      20. -- ----------------------------
      21. DROP TABLE IF EXISTS `branch_table`;
      22. CREATE TABLE `branch_table` (
      23.   `branch_id` bigint NOT NULL,
      24.   `xid` varchar(128) NOT NULL,
      25.   `transaction_id` bigint DEFAULT NULL,
      26.   `resource_group_id` varchar(32) DEFAULT NULL,
      27.   `resource_id` varchar(256) DEFAULT NULL,
      28.   `branch_type` varchar(8) DEFAULT NULL,
      29.   `status` tinyint DEFAULT NULL,
      30.   `client_id` varchar(64) DEFAULT NULL,
      31.   `application_data` varchar(2000) DEFAULT NULL,
      32.   `gmt_create` datetime(6) DEFAULT NULL,
      33.   `gmt_modified` datetime(6) DEFAULT NULL,
      34.   PRIMARY KEY (`branch_id`),
      35.   KEY `idx_xid` (`xid`)
      36. ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
      37.  
      38. -- ----------------------------
      39. -- Records of branch_table
      40. -- ----------------------------
      41.  
      42. -- ----------------------------
      43. -- Table structure for `global_table`
      44. -- ----------------------------
      45. DROP TABLE IF EXISTS `global_table`;
      46. CREATE TABLE `global_table` (
      47.   `xid` varchar(128) NOT NULL,
      48.   `transaction_id` bigint DEFAULT NULL,
      49.   `status` tinyint NOT NULL,
      50.   `application_id` varchar(32) DEFAULT NULL,
      51.   `transaction_service_group` varchar(32) DEFAULT NULL,
      52.   `transaction_name` varchar(128) DEFAULT NULL,
      53.   `timeout` int DEFAULT NULL,
      54.   `begin_time` bigint DEFAULT NULL,
      55.   `application_data` varchar(2000) DEFAULT NULL,
      56.   `gmt_create` datetime DEFAULT NULL,
      57.   `gmt_modified` datetime DEFAULT NULL,
      58.   PRIMARY KEY (`xid`),
      59.   KEY `idx_gmt_modified_status` (`gmt_modified`,`status`),
      60.   KEY `idx_transaction_id` (`transaction_id`)
      61. ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
      62.  
      63. -- ----------------------------
      64. -- Records of global_table
      65. -- ----------------------------
      66.  
      67. -- ----------------------------
      68. -- Table structure for `lock_table`
      69. -- ----------------------------
      70. DROP TABLE IF EXISTS `lock_table`;
      71. CREATE TABLE `lock_table` (
      72.   `row_key` varchar(128) NOT NULL,
      73.   `xid` varchar(96) DEFAULT NULL,
      74.   `transaction_id` bigint DEFAULT NULL,
      75.   `branch_id` bigint NOT NULL,
      76.   `resource_id` varchar(256) DEFAULT NULL,
      77.   `table_name` varchar(32) DEFAULT NULL,
      78.   `pk` varchar(36) DEFAULT NULL,
      79.   `gmt_create` datetime DEFAULT NULL,
      80.   `gmt_modified` datetime DEFAULT NULL,
      81.   PRIMARY KEY (`row_key`),
      82.   KEY `idx_branch_id` (`branch_id`)
      83. ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
      84.  
      85. -- ----------------------------
      86. -- Records of lock_table
      87. -- ----------------------------
    4.  Seata控制台启动、访问
      启动Nacos并添加seataServer.properties配置，Mysql创建seata数据库并执行建表语句，双击seata-server.bat启动Seata服务，Seata服务启动后Nacos服务列表可以看到该服务， Seata控制台访问： http://localhost:7091，用户名和密码均为seata

    5.  Seata分布式事务测试
      1. "1.0" encoding="UTF-8"?>
      2. "http://maven.apache.org/POM/4.0.0"
      3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
      4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
      5.     4.0.0
      6.  
      7.     com.seata
      8.     seatatest
      9.     pom
      10.     1.0-SNAPSHOT
      11.     
      12.         <module>seata-commonmodule>
      13.         <module>seata-ordermodule>
      14.         <module>seata-accountmodule>
      15.         <module>seata-webmodule>
      16.     
      17.  
      18.     
      19.         UTF-8
      20.         1.8
      21.         1.8
      22.         1.1.10
      23.         Hoxton.SR8
      24.         2.3.2.RELEASE
      25.         2.2.4.RELEASE
      26.         1.2.35
      27.         3.6
      28.         1.0-SNAPSHOT
      29.         2.1.0
      30.     
      31.  
      32.     
      33.         
      34.             
      35.                 org.springframework.cloud
      36.                 spring-cloud-dependencies
      37.                 ${spring-cloud.version}
      38.                 pom
      39.                 import
      40.             
      41.             
      42.                 org.springframework.boot
      43.                 spring-boot-dependencies
      44.                 ${springboot.version}
      45.                 pom
      46.                 import
      47.             
      48.             
      49.                 com.alibaba.cloud
      50.                 spring-cloud-alibaba-dependencies
      51.                 ${springcloudalibaba.version}
      52.                 pom
      53.                 import
      54.             
      55.             
      56.             
      57.                 com.alibaba
      58.                 druid
      59.                 ${druid.version}
      60.             
      61.  
      62.             
      63.                 com.alibaba
      64.                 fastjson
      65.                 ${fastjson.version}
      66.             
      67.  
      68.             
      69.                 org.apache.commons
      70.                 commons-lang3
      71.                 ${commons-lang3.version}
      72.             
      73.  
      74.             
      75.                 com.seata
      76.                 seata-common
      77.                 ${seata-common.version}
      78.             
      79.  
      80.             
      81.                 org.mybatis.spring.boot
      82.                 mybatis-spring-boot-starter
      83.                 ${mybatis.version}
      84.             
      85.  
      86.         
      87.     
      88.  
      89.  
      90.     
      91.         
      92.             
      93.                 org.springframework.boot
      94.                 spring-boot-maven-plugin
      95.             
      96.         
      97.     
      98.  
      99.  
      1. "1.0" encoding="UTF-8"?>
      2. "http://maven.apache.org/POM/4.0.0"
      3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
      4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
      5.     
      6.         seatatest
      7.         com.seata
      8.         1.0-SNAPSHOT
      9.     
      10.     4.0.0
      11.  
      12.     seata-common
      13.  
      14.     
      15.  
      16.         
      17.                 com.alibaba.cloud
      18.                  spring-cloud-starter-alibaba-seata
      19.       
      20.  
      21.         
      22.             com.alibaba.nacos
      23.             nacos-client
      24.             1.4.0
      25.         
      26.  
      27.         
      28.             org.springframework.boot
      29.             spring-boot-starter-web
      30.         
      31.  
      32.         
      33.             org.springframework.boot
      34.             spring-boot-starter-test
      35.             test
      36.         
      37.  
      38.         
      39.             com.alibaba.cloud
      40.             spring-cloud-starter-alibaba-nacos-discovery
      41.         
      42.  
      43.         
      44.             com.alibaba.cloud
      45.             spring-cloud-starter-alibaba-nacos-config
      46.         
      47.  
      48.         
      49.             org.springframework.boot
      50.             spring-boot-devtools
      51.             runtime
      52.             true
      53.         
      54.         
      55.             mysql
      56.             mysql-connector-java
      57.             runtime
      58.         
      59.         
      60.             org.projectlombok
      61.             lombok
      62.         
      63.         
      64.             org.springframework.boot
      65.             spring-boot-starter-test
      66.             test
      67.         
      68.  
      69.         
      70.             org.mybatis.spring.boot
      71.             mybatis-spring-boot-starter
      72.         
      73.  
      74.  
      75.         
      76.             com.alibaba
      77.             druid
      78.         
      79.  
      80.         
      81.         
      82.             org.springframework.boot
      83.             spring-boot-starter-data-redis
      84.         
      85.         
      86.         
      87.             org.apache.commons
      88.             commons-pool2
      89.         
      90.  
      91.         
      92.             com.alibaba
      93.             fastjson
      94.         
      95.  
      96.         
      97.             commons-codec
      98.             commons-codec
      99.         
      100.  
      101.         
      102.             org.apache.commons
      103.             commons-lang3
      104.         
      105.  
      106.     
      107.  
      108.  
      1. "1.0" encoding="UTF-8"?>
      2. "http://maven.apache.org/POM/4.0.0"
      3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
      4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
      5.     
      6.         seatatest
      7.         com.seata
      8.         1.0-SNAPSHOT
      9.     
      10.     4.0.0
      11.  
      12.     seata-web
      13.  
      14.     
      15.  
      16.         
      17.             com.seata
      18.             seata-common
      19.         
      20.  
      21.         
      22.             org.springframework.cloud
      23.             spring-cloud-starter-openfeign
      24.         
      25.  
      26.     
      27.  
      28.  
      1. "1.0" encoding="UTF-8"?>
      2. "http://maven.apache.org/POM/4.0.0"
      3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
      4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
      5.     
      6.         seatatest
      7.         com.seata
      8.         1.0-SNAPSHOT
      9.     
      10.     4.0.0
      11.  
      12.     seata-order
      13.  
      14.     
      15.         
      16.             com.seata
      17.             seata-common
      18.         
      19.     
      20.  
      21.  
      1. "1.0" encoding="UTF-8"?>
      2. "http://maven.apache.org/POM/4.0.0"
      3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
      4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
      5.     
      6.         seatatest
      7.         com.seata
      8.         1.0-SNAPSHOT
      9.     
      10.     4.0.0
      11.  
      12.     seata-account
      13.  
      14.     
      15.         
      16.             com.seata
      17.             seata-common
      18.         
      19.     
      20.  
      21.  

      1. server:
      2.   port: 8088
      3.   servlet:
      4.     context-path: /
      5.  
      6.  
      7. spring:
      8.   cloud:
      9.     nacos:
      10.       discovery:
      11.         server-addr: 127.0.0.1:8848
      12.     alibaba:
      13.       seata:
      14.         tx-service-group: my_test_tx_group
      15.   application:
      16.     name: seata-web
      17.  
      18. seata:
      19.   service:
      20.     vgroup-mapping:
      21.       my_test_tx_group: default
      22.     grouplist:
      23.       default: 127.0.0.1:8091
      24.     enable-degrade: false
      25.     disable-global-transaction: false
      1. server:
      2.   port: 8070
      3.   servlet:
      4.     context-path: /
      5.  
      6. spring:
      7.   datasource:
      8.     type: com.alibaba.druid.pool.DruidDataSource
      9.     driver-class-name: com.mysql.cj.jdbc.Driver
      10.     url: jdbc:mysql://localhost:3306/db_account?serverTimezone=Asia/Shanghai
      11.     username: root
      12.     password: 123456
      13.   cloud:
      14.     nacos:
      15.       discovery:
      16.         server-addr: 127.0.0.1:8848
      17.     alibaba:
      18.       seata:
      19.         tx-service-group: my_test_tx_group
      20.   application:
      21.     name: seata-account
      22.  
      23. mybatis:
      24.   mapper-locations: classpath:mybatis/mapper/*.xml
      26. #seata:
      27. #  config:
      28. #    type: nacos
      29. #    nacos:
      30. #      server-addr: 127.0.0.1:8848
      31. #      group: SEATA_GROUP
      32. #      namespace: ""
      33. #  registry:
      34. #    type: nacos
      35. #    nacos:
      36. #      application: seata-server
      37. #      server-addr: 127.0.0.1:8848
      38. #      group: SEATA_GROUP
      39. #      namespace: ""
      40. seata:
      41.   service:
      42.     vgroup-mapping:
      43.       my_test_tx_group: default
      44.     grouplist:
      45.       default: 127.0.0.1:8091
      46.     enable-degrade: false
      47.     disable-global-transaction: false
      1. server:
      2.   port: 8090
      3.   servlet:
      4.     context-path: /
      5.  
      6. spring:
      7.   datasource:
      8.     type: com.alibaba.druid.pool.DruidDataSource
      9.     driver-class-name: com.mysql.cj.jdbc.Driver
      10.     url: jdbc:mysql://localhost:3306/db_order?serverTimezone=Asia/Shanghai
      11.     username: root
      12.     password: 123456
      13.   cloud:
      14.     nacos:
      15.       discovery:
      16.         server-addr: 127.0.0.1:8848
      17.     alibaba:
      18.       seata:
      19.         tx-service-group: my_test_tx_group
      20.   application:
      21.     name: seata-order
      22.  
      23. mybatis:
      24.   mapper-locations: classpath:mybatis/mapper/*.xml
      26. seata:
      27.   service:
      28.     vgroup-mapping:
      29.       my_test_tx_group: default
      30.     grouplist:
      31.       default: 127.0.0.1:8091
      32.     enable-degrade: false
      33.     disable-global-transaction: false


    6.  Seata分布式事务回滚



    https://blog.csdn.net/caoli201314?type=blog

  • 相关阅读:
    VitualBox安装增强功能实现无缝模式和拖放功能（踩坑点记录汇总）
    《向量数据库指南》——AutoGPT 宣布不再使用向量数据库
    Spring中Bean循环依赖详解
    o.s.web.servlet.PageNotFound : No mapping for GET /favicon.ico
    【git 学习】--- ubuntu18.04 搭建本地git服务器
    哈希表、哈希桶（C++实现）
    Kafka - 05 Kafka生产者| 消息发送方式 | 序列化器 | 分区器 | 拦截器 |生产者配置参数
    分库分表总结
    推荐收藏，机器学习7种特征编码太好用了
    边缘计算技术的崭新篇章：赋能未来智能系统
  • 原文地址：https://blog.csdn.net/tongxin_tongmeng/article/details/126038705