springboot cloud使用eureka整合分布式事務組件Seata 的方法
前言
近期一直在忙項目，我也是打工仔。不多說，我們開始玩一玩seata。
正文
什么都不說，我們按照慣例，先上一個圖（圖里不規(guī)范的使用請忽略）：
簡單一眼就看出來， 比我們平時用的東西，多了 Seata Server 微服務 。
同樣這個 Seata Server 微服務 ，也是需要注冊到eureka上面去的。
那么我們首先就搞一搞這個 seata server ，那么剩下的就是一些原本的業(yè)務服務整合配置了。
該篇用的 seata server 版本，用的是1.4.1 ， 可以去git下載下。當然，我也是給你們備了的：
seata server 1.4.1 某度網(wǎng)盤分享地址：
鏈接: https://pan.baidu.com/s/1Oj1NkKwU4jeLjJ3Pu9hT2Q
提取碼: 9at6
第一步，下載下來解壓 ：
第二步，創(chuàng)個 seata server 用的數(shù)據(jù)庫 ：
CREATE TABLE `branch_table` ( `branch_id` bigint(20) NOT NULL, `xid` varchar(128) NOT NULL, `transaction_id` bigint(20) DEFAULT NULL, `resource_group_id` varchar(32) DEFAULT NULL, `resource_id` varchar(256) DEFAULT NULL, `branch_type` varchar(8) DEFAULT NULL, `status` tinyint(4) DEFAULT NULL, `client_id` varchar(64) DEFAULT NULL, `application_data` varchar(2000) DEFAULT NULL, `gmt_create` datetime DEFAULT NULL, `gmt_modified` datetime DEFAULT NULL, PRIMARY KEY (`branch_id`), KEY `idx_xid` (`xid`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8; CREATE TABLE `global_table` ( `xid` varchar(128) NOT NULL, `transaction_id` bigint(20) DEFAULT NULL, `status` tinyint(4) NOT NULL, `application_id` varchar(32) DEFAULT NULL, `transaction_service_group` varchar(32) DEFAULT NULL, `transaction_name` varchar(128) DEFAULT NULL, `timeout` int(11) DEFAULT NULL, `begin_time` bigint(20) DEFAULT NULL, `application_data` varchar(2000) DEFAULT NULL, `gmt_create` datetime DEFAULT NULL, `gmt_modified` datetime DEFAULT NULL, PRIMARY KEY (`xid`), KEY `idx_gmt_modified_status` (`gmt_modified`,`status`), KEY `idx_transaction_id` (`transaction_id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8; CREATE TABLE `lock_table` ( `row_key` varchar(128) NOT NULL, `xid` varchar(96) DEFAULT NULL, `transaction_id` bigint(20) DEFAULT NULL, `branch_id` bigint(20) NOT NULL, `resource_id` varchar(256) DEFAULT NULL, `table_name` varchar(32) DEFAULT NULL, `pk` varchar(36) DEFAULT NULL, `gmt_create` datetime DEFAULT NULL, `gmt_modified` datetime DEFAULT NULL, PRIMARY KEY (`row_key`), KEY `idx_branch_id` (`branch_id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
創(chuàng)建完后：
第三步，修改下 \seata-1.4.1\seata-server-1.4.1\seata\conf 里的配置文件一些信息 ：
1. registry.conf
ok，registry.conf 這文件就修改這些配置項。
2. file.conf ：
以上兩個文件配置完（記得保存）， 我們先把我們的注冊中心 eureka服務跑起來，然后點擊啟動 seata server：
可以看到啟動成功（前提是eureka已經(jīng)啟動）：
第三步 ，配置我們需要用到 分布式事務 seata組件的 微服務 ：
我這里的示例實踐，需要用到的有2個微服務 ：
那么我們這兩個微服務都需要做點什么呢？
1. 在對應的微服務的對應的不同數(shù)據(jù)庫里(只要你想用上seata的)， 都加上undo_log 這個表：
SQL語句：
SET NAMES utf8mb4; SET FOREIGN_KEY_CHECKS = 0; -- ---------------------------- -- Table structure for undo_log -- ---------------------------- DROP TABLE IF EXISTS `undo_log`; CREATE TABLE `undo_log` ( `id` bigint(20) NOT NULL AUTO_INCREMENT, `branch_id` bigint(20) NOT NULL, `xid` varchar(100) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL, `context` varchar(128) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL, `rollback_info` longblob NOT NULL, `log_status` int(11) NOT NULL, `log_created` datetime(0) NULL, `log_modified` datetime(0) NULL, PRIMARY KEY (`id`) USING BTREE, UNIQUE INDEX `ux_undo_log`(`xid`, `branch_id`) USING BTREE ) ENGINE = InnoDB AUTO_INCREMENT = 1 CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Dynamic; SET FOREIGN_KEY_CHECKS = 1;
2. 關鍵步驟了 ， 導入jar包 （需要用到seata組件都服務都需要導入）
<dependency> <groupId>com.alibaba.cloud</groupId> <artifactId>spring-cloud-alibaba-seata</artifactId> <version>2.1.0.RELEASE</version> <exclusions> <exclusion> <artifactId>seata-all</artifactId> <groupId>io.seata</groupId> </exclusion> </exclusions> </dependency> <dependency> <artifactId>seata-all</artifactId> <groupId>io.seata</groupId> <version>1.4.1</version> </dependency>
3.更加關鍵了，就是做配置
先總得了解下，需要用到seata的 微服務需要做些什么配置 ？
1. 在resources 下 新增2個配置文件 ， file.conf 和 registry.conf
2.yml 新增配置seata 事務組參數(shù)
3.代碼調整數(shù)據(jù)源代理，交給seata代理
1. registry.conf
以上是業(yè)務微服務里的registry.conf 需要改動的配置信息 ，給出一份該篇文章使用的：
registry {
# file 、nacos 、eureka、redis、zk、consul、etcd3、sofa
type = "eureka"
loadBalance = "RandomLoadBalance"
loadBalanceVirtualNodes = 10
nacos {
application = "seata-server"
serverAddr = "127.0.0.1:8848"
group = "SEATA_GROUP"
namespace = ""
cluster = "default"
username = ""
password = ""
}
eureka {
serviceUrl = "http://localhost:8761/eureka/"
application = "seata-server"
weight = "1"
}
redis {
serverAddr = "localhost:6379"
db = 0
password = ""
cluster = "default"
timeout = 0
}
zk {
cluster = "default"
serverAddr = "127.0.0.1:2181"
sessionTimeout = 6000
connectTimeout = 2000
username = ""
password = ""
}
consul {
cluster = "default"
serverAddr = "127.0.0.1:8500"
}
etcd3 {
cluster = "default"
serverAddr = "http://localhost:2379"
}
sofa {
serverAddr = "127.0.0.1:9603"
application = "default"
region = "DEFAULT_ZONE"
datacenter = "DefaultDataCenter"
cluster = "default"
group = "SEATA_GROUP"
addressWaitTime = "3000"
}
file {
name = "file.conf"
}
}
config {
# file、nacos 、apollo、zk、consul、etcd3
type = "file"
nacos {
serverAddr = "127.0.0.1:8848"
namespace = ""
group = "SEATA_GROUP"
username = ""
password = ""
}
consul {
serverAddr = "127.0.0.1:8500"
}
apollo {
appId = "seata-server"
apolloMeta = "http://192.168.1.204:8801"
namespace = "application"
apolloAccesskeySecret = ""
}
zk {
serverAddr = "127.0.0.1:2181"
sessionTimeout = 6000
connectTimeout = 2000
username = ""
password = ""
}
etcd3 {
serverAddr = "http://localhost:2379"
}
file {
name = "file.conf"
}
}
file.conf
給出一份該篇使用的完整的：
transport {
# tcp udt unix-domain-socket
type = "TCP"
#NIO NATIVE
server = "NIO"
#enable heartbeat
heartbeat = true
# the client batch send request enable
enableClientBatchSendRequest = true
#thread factory for netty
threadFactory {
bossThreadPrefix = "NettyBoss"
workerThreadPrefix = "NettyServerNIOWorker"
serverExecutorThread-prefix = "NettyServerBizHandler"
shareBossWorker = false
clientSelectorThreadPrefix = "NettyClientSelector"
clientSelectorThreadSize = 1
clientWorkerThreadPrefix = "NettyClientWorkerThread"
# netty boss thread size,will not be used for UDT
bossThreadSize = 1
#auto default pin or 8
workerThreadSize = "default"
}
shutdown {
# when destroy server, wait seconds
wait = 3
}
serialization = "seata"
compressor = "none"
}
service {
#這里注意,等號前后都是配置,前面是yml里配置的事務組,后面是register.conf里定義的seata-server
vgroupMapping.test_tx_group = "seata-server"
#only support when registry.type=file, please don't set multiple addresses
seata_tc_server.grouplist = "127.0.0.1:8091"
#degrade, current not support
enableDegrade = false
#disable seata
disableGlobalTransaction = false
}
client {
rm {
asyncCommitBufferLimit = 10000
lock {
retryInterval = 10
retryTimes = 30
retryPolicyBranchRollbackOnConflict = true
}
reportRetryCount = 5
tableMetaCheckEnable = false
reportSuccessEnable = false
}
tm {
commitRetryCount = 5
rollbackRetryCount = 5
}
undo {
dataValidation = true
logSerialization = "jackson"
logTable = "undo_log"
}
log {
exceptionRate = 100
}
}
2. 需要在yml配置文件加上配置項，指明當前服務使用了 seata分布式事務組件，且需要加入的分布式事務組是哪個：
spring:
cloud:
alibaba:
seata.tx-service-group: test_tx_group
3.然后是需要將數(shù)據(jù)源交給seata去代理：
去掉默認自動加載數(shù)據(jù)源
配置dao層掃描位置
@MapperScan("com.cloud.client1.dao")
@SpringBootApplication(exclude = DataSourceAutoConfiguration.class)
然后是seata代理數(shù)據(jù)源（紅色標注的地方需要注意下，都是實打實踩出來的坑。導入類的來源以及掃描的mapper的xml位置）：
ok，到這里一個微服務 usercent的 整合 seata 分布式組件算是完成了。
同樣，我們繼續(xù)對 另外一個微服務 coredata 做seata 分布式組件 整合 。
也是第一步，file.conf 和 registry.conf （其實我們現(xiàn)在就是讓這兩個微服務在同一個分布式事務組，我們直接把剛才在usercent那邊的兩個文件直接粘貼過來就好）。
然后第二步就是修改yml配置：
第三步就是新增seata數(shù)據(jù)源代理、application上的注解排除自動加載數(shù)據(jù)源和掃描dao層地址，yml上面的配置項：
完事，兩個業(yè)務微服務都整合了 分布式事務組件 seata ，而且都設置在同個分布式事務組里 （test_tx_group）.
那么到這其實已經(jīng)完事了， 接下來玩下 分布式事務回滾場景 的例子 (怎么去使用)。
我該篇就不弄太多服務了，就弄了2個分布式服務。
展示的例子內(nèi)容 ：
1. 上游服務 出錯， 觸發(fā)分布式事務， 上下游服務都會事務回滾；
2.下游服務 出錯，觸發(fā)分布式事務， 上下游服務都會事務回滾；（某種程度上講，下游出錯如果只有一個下游，其實不需分布式事務，通過錯誤傳遞單個回滾也是可以的。但是如果服務調用鏈很長，中游服務出錯，需要整個鏈上的服務都事務回滾，那么就有必要都使用seata ）
我們開始模擬：
第一個場景 上游服務 coredata 使用seata全局事務注解@GlobalTransactional 標記方法，先插入一個Account數(shù)據(jù) ；然后調用下游服務 usercent 插入一條數(shù)據(jù)；
然后 上游服務 coredata繼續(xù)執(zhí)行業(yè)務邏輯，繼續(xù)插入數(shù)據(jù)；
接著模擬上游服務coredata開始報錯（我們通過name長度故意觸發(fā)錯誤）；
期望結果： 上下游兩個服務 在當前方法事務下插入的數(shù)據(jù)都回滾！
上游服務 coredata 方法：
通過fegin調用下游服務 usercent 方法：
下游服務 usercent 的插入方法：
開始模擬:
1.先把eureka跑起來：
暫時就注冊中心自己，沒有別的服務:
2.把seata server 服務跑起來，注冊到eureka上去：
我是window環(huán)境，執(zhí)行.bat
可以看到已經(jīng)成功注冊到eureka上了：
3. 把上游微服務 coredata 和 下游服務 usercent 都跑起來：
然后看下seata server上，也可以看到 兩個服務 都成功‘注冊'到了 seata server上了，而且都在同一個事務組 test_tx_group里面：
接下來，就是開始調用一下我們模擬的場景代碼就完事了（不過我會加點圖來給大家簡單分析下）：
一開始，都是沒有數(shù)據(jù)的：
調用上游服務coredata接口觸發(fā)一下整個流程：
調用開始:
我們打斷點到 上游已經(jīng)插入過一次數(shù)據(jù)，下游也插入過一次數(shù)據(jù)，
可以看到上游服務和下游服務的數(shù)據(jù)庫里面的undo_log表出現(xiàn)了 事務記錄，有關當前事務的 branch_id和 所在事務 xid，而且可以看到在兩個服務內(nèi)的undo_log表中記錄的xid都是一致的，代表他們都在一個事務中：
然后我們繼續(xù)往下執(zhí)行，故意讓上游報錯：
這時候，接口調用完畢結束：我們看到seata server里面的信息，可以看到全局事務 xid為22080結尾，回滾成功：
回滾成功后，undo_log表中的記錄會刪除掉：
當然我們兩個服務里面也是沒有數(shù)據(jù)的，因為回滾了：
這里可能有人會想，你查一下是空就能證明是回滾了么？
這時候我們也可以利用主鍵自增當前值可以看到確實發(fā)生了數(shù)據(jù)回滾的場景：
第一個場景就到此吧。
接下來我們模擬第二個場景：
上游服務 coredata 使用seata全局事務注解@GlobalTransactional 標記方法，先插入一個Account數(shù)據(jù) ；然后調用下游服務 usercent 插入一條數(shù)據(jù)；
然后下游服務 直接模擬出錯， 這樣觸發(fā)事務回滾。 期望結果： 上下游兩個服務 在當前方法事務下插入的數(shù)據(jù)都回滾！
也就是說我們需要對下游服務的插入方法里面做手腳，故意拋出錯誤：
快速調用一下：
可以看到下游出錯了：
看下我們的seata server怎么說,已出發(fā)分布式事務，回滾成功：
數(shù)據(jù)庫里面的數(shù)據(jù)也是回滾了，空的：
好了，該篇springboot cloud使用eureka整合 分布式事務組件 Seata 就到此吧。
ps： 最近比較忙，每篇文章其實都是用一些零碎時間拼湊出來的。不過我會堅持我的文章的初衷，能讓大家跟著實踐，能搞懂，能學會。我...只是個散工。
到此這篇關于SpringCloud 整合分布式事務組件 Seata的文章就介紹到這了,更多相關SpringCloud 整合分布式內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！
相關文章
詳解Java中布隆過濾器(Bloom Filter)原理及其使用場景
布隆過濾器是1970年由布隆提出的，它實際上是一個很長的二進制向量和一系列隨機映射函數(shù)，它的作用是檢索一個元素是否存在我們的集合之中，本文給大家詳細的講解一下布隆過濾器，感興趣的同學可以參考閱讀2023-05-05
打地鼠是我們非常熟悉的一款小游戲,它的游戲結構和規(guī)則也都比較簡單,那么如果能夠親自徒手開發(fā)這樣的一款經(jīng)典小游戲呢?這篇文章主要給大家介紹了關于如何使用Java語言編寫打地鼠游戲的相關資料,需要的朋友可以參考下2024-06-06
JAVA中HTTP基本認證(Basic Authentication)實現(xiàn)
HTTP 基本認證是一種簡單的認證方法,本文主要介紹了JAVA中HTTP基本認證(Basic Authentication),文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧2024-07-07
Spring Data Jpa實現(xiàn)分頁和排序代碼實例
本篇文章主要介紹了Spring Data Jpa實現(xiàn)分頁和排序代碼實例，具有一定的參考價值，有興趣的可以了解一下。2017-03-03
這篇文章主要介紹了Java中的原子類AtomicInteger使用詳解,原子操作是指不會被線程調度機制打斷的操作,這種操作一旦開始,就一直運行到結束,中間不會有任何線程上下文切換,需要的朋友可以參考下2023-12-12
SpringBoot封裝響應數(shù)據(jù)實現(xiàn)過程詳解
這篇文章主要介紹了SpringBoot封裝響應數(shù)據(jù)實現(xiàn)過程，SpringBoot響應數(shù)據(jù)封裝是指在SpringBoot應用程序中，將返回的數(shù)據(jù)進行封裝，以便于前端頁面或其他客戶端使用，感興趣想要詳細了解可以參考下文2023-05-05
這篇文章主要介紹了@JsonSerialize不起作用的解決方案，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-10-10
SpringCloud Zuul過濾器和谷歌Gauva實現(xiàn)限流
這篇文章主要介紹了SpringCloud Zuul過濾器和谷歌Gauva實現(xiàn)限流,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2020-03-03
本篇文章主要介紹了淺談Spring5 響應式編程，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2018-01-01
Java更新調度器(update scheduler)的使用詳解
Java更新調度器是Java中的一個特性,可以自動化Java應用程序的更新過程,它提供了一種方便的方式來安排Java應用程序的更新,確保其與最新的功能、錯誤修復和安全補丁保持同步,本文將深入介紹如何使用Java更新調度器,并解釋它對Java開發(fā)人員和用戶的好處2023-11-11