一、簡介
作為微服務的解決方案之一的Spring cloud Alibaba擁有眾多優秀的開源框架，那么我們就使用這么框架搭建一個項目，並以此來研究一下這些優秀框架的源碼。所使用到的組件如下：
1、Nacos 服務注冊與發現
2、Nacos 分布式配置中心
3、Sentinel 流量控制和服務降級
4、RocketMQ 消息驅動
5、Seate 分布式事務
6、Dubbo Rpc通信
7、Oss 對象存儲
二、啟動nacos服務
1、下載nacos源碼：git clone https://github.com/alibaba/nacos.git
2、進入nacos文件夾，如果是windows的cmd終端則使用mvn -Prelease-nacos -Dmaven.test.skip=true clean install -U編譯；如果使用的PowerShell則使用mvn -Prelease-nacos '-Dmaven.test.skip=true' clean install -U編譯。
3、編譯完成后進入\distribution\target\nacos-server-2.0.4\nacos\bin文件夾下，使用startup.cmd -m standalone（windows下，非集群模式）命令啟動
4、啟動成功后，訪問http://localhost:8848/nacos，用戶名：nacos，密碼：nacos
5、關閉可直接雙擊shutdown.cmd
ps：nacos的數據存儲默認使用的是Derby文件類型的數據庫，在使用時會存在一定的局限性。比如無法支持多用戶同時操作，在數據量大、連接數多的情況下會產生大量的連接積壓，所以生產環境下我們可以使用mysql代替。
（1）在\distribution\target\nacos-server-2.0.4\nacos\conf文件夾下存在nacos-mysql.sql文件，放到mysql中執行初始化
（2）修改application.properties文件，增加mysql的配置
spring.datasource.platform=mysql db.num=1 db.url.0=jdbc:mysql://localhost:3306/nacos?characterEncoding=utf8&connectTimeout=1000&socketTimeout=3000&autoReconnect=true&useUnicode=true&useSSL=false&serverTimezone=UTC db.user.0=root db.password.0=123456
6、創建命名空間
7、配置管理tab，切換到新建的命名空間，新建一個配置，備用
三、配置中心與服務注冊
應用以來的jar包，使用windows啟動，會有grpc的錯誤，nacos client單獨使用1.4.2版本
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
</dependency>
<dependency>
<groupId>com.alibaba.nacos</groupId>
<artifactId>nacos-client</artifactId>
<version>1.4.2</version>
</dependency>
在resources文件夾下創建bootstrap.yml文件，配置如下：
spring: application: name: console cloud: nacos: config: server-addr: 192.168.232.207:8848 file-extension: properties namespace: 370c5370-3012-424f-8cb9-ce93c695d241
在nacos控制台，配置文件中配置注冊中心的信息
server.port=9100 spring.cloud.nacos.discovery.server-addr=192.168.232.207:8848 spring.cloud.nacos.discovery.namespace=370c5370-3012-424f-8cb9-ce93c695d241
四、Sentinel的限流降級
1、控制台
（1）從git上下載sentinel-dashboard，修改配置文件application.properties
#端口號 server.port=18885 csp.sentinel.dashboard.server=localhost:18885 project.name=sentinel-dashboard # 注冊中心地址 sentinel.nacos.server-addr=127.0.0.1:8848 sentinel.nacos.namespace=370c5370-3012-424f-8cb9-ce93c695d241 sentinel.nacos.group-id=sentinel
（2）規則持久化到nacos，找到pom文件的sentinel-datasource-nacos，刪掉scope啟動nacos
（3）修改源碼，增加實例化邏輯，網上有很多的案例實踐，我的已放到gitee上，地址：https://gitee.com/sglx666/sentinel-dashboard.git
2、客戶端
（1）添加sentinel的jar包
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
</dependency>
<dependency>
<groupId>com.alibaba.csp</groupId>
<artifactId>sentinel-datasource-nacos</artifactId>
</dependency>
<dependency>
<groupId>com.alibaba.csp</groupId>
<artifactId>sentinel-parameter-flow-control</artifactId>
</dependency>
（2）以限流為例，配置如下：
spring.cloud.sentinel.transport.dashboard=127.0.0.1:18885 nacos.address=127.0.0.1:8848 spring.cloud.sentinel.datasource.flow.nacos.server-addr=${nacos.address} spring.cloud.sentinel.datasource.flow.nacos.namespace=370c5370-3012-424f-8cb9-ce93c695d241 spring.cloud.sentinel.datasource.flow.nacos.username=nacos spring.cloud.sentinel.datasource.flow.nacos.password=nacos spring.cloud.sentinel.datasource.flow.nacos.data-id=${spring.application.name}-sentinel-flow spring.cloud.sentinel.datasource.flow.nacos.group-id=sentinel spring.cloud.sentinel.datasource.flow.nacos.data-type=json spring.cloud.sentinel.datasource.flow.nacos.rule-type=flow
五、分布式事務Seata
服務端
1、下載地址https://seata.io/zh-cn/blog/download.html
2、進入到conf目錄下，修改file.conf、registry.conf
3、進入到bin目錄下，點擊seata-server.bat啟動
4、服務端配置seataServer.properties
####################公共配置######################## #client和server通信編解碼方式 seata(ByteBuf)、protobuf、kryo、hession、fst，默認seata transport.serialization=seata #client和server通信數據壓縮方式 none、gzip，默認none transport.compressor=none #client和server通信心跳檢測開關 transport.heartbeat=true #默認file，支持file 、nacos 、eureka、redis、zk、consul、etcd3、sofa、custom registry.type=nacos #默認file，支持file、nacos 、apollo、zk、consul、etcd3、custom config.type=nacos transport.type=TCP transport.server=NIO 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 ###################server端相關配置########################### #undo保留天數 默認7天,log_status=1（附錄3）和未正常清理的undo server.undo.logSaveDays=7 #undo清理線程間隔時間 默認86400000，單位毫秒 server.undo.logDeletePeriod=86400000 #單位ms,s,m,h,d,對應毫秒,秒,分,小時,天,默認毫秒。默認值-1表示無限重試。 #公式: timeout>=now-globalTransactionBeginTime,true表示超時則不再重試 #注: 達到超時時間后將不會做任何重試,有數據不一致風險,除非業務自行可校准數據,否者慎用 server.maxCommitRetryTimeout=-1 #二階段回滾重試超時時長 同commit server.maxRollbackRetryTimeout=-1 #二階段提交未完成狀態全局事務重試提交線程間隔時間 默認1000，單位毫秒 server.recovery.committingRetryPeriod=1000 #二階段異步提交狀態重試提交線程間隔時間 默認1000，單位毫秒 server.recovery.asynCommittingRetryPeriod=1000 #二階段回滾狀態重試回滾線程間隔時間 默認1000，單位毫秒 server.recovery.rollbackingRetryPeriod=1000 #超時狀態檢測重試線程間隔時間 默認1000，單位毫秒，檢測出超時將全局事務置入回滾會話管理器 server.recovery.timeoutRetryPeriod=1000 server.rollbackRetryTimeoutUnlockEnable=false # 存儲模式為db store.mode=db #store.lock.mode=db #store.session.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 # db模式數據源類型druid、hikari 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&characterEncoding=UTF-8&rewriteBatchedStatements=true store.db.user=root store.db.password=hhh123 #初始連接數 store.db.minConn=1 #最大連接數 store.db.maxConn=10 #db模式獲取連接時最大等待時間 store.db.maxWait=5000 #db模式全局事務表名 store.db.globalTable=global_table #db模式分支事務表名 store.db.branchTable=branch_table #db模式全局鎖表名 store.db.lockTable=lock_table #db模式查詢全局事務一次的最大條數 store.db.queryLimit=50 #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 #tore.redis.database=0 #store.redis.password= #store.redis.queryLimit=100 #是否啟用Metrics 默認false關閉，在False狀態下，所有與Metrics相關的組件將不會被初始化，使得性能損耗最低 metrics.enabled=false #指標注冊器類型 默認為內置的compact（簡易）實現 metrics.registryType=compact #指標結果Measurement數據輸出器列表 默認prometheus metrics.exporterList=prometheus #prometheus輸出器Client端口號 metrics.exporterPrometheusPort=9898 #####################client端配置################### #是否開啟spring-boot自動裝配 seata.enabled=true #是否開啟數據源自動代理 seata.enableAutoDataSourceProxy=true #是否使用JDK代理作為數據源自動代理的實現方式,默認false,采用CGLIB作為數據源自動代理的實現方式 seata.useJdkProxy=false #客戶端事務消息請求是否批量合並發送 默認true，false單條發送 transport.enableClientBatchSendRequest=false #日志異常輸出概率 默認100，目前用於undo回滾失敗時異常堆棧輸出，百分之一的概率輸出，回滾失敗基本是臟數據，無需輸出堆棧占用硬盤空間 client.log.exceptionRate=100 #事務群組 service.vgroupMapping.sale_tx_group=default #service.vgroupMapping.order_tx_group=default #service.vgroupMapping.line_tx_group=default #TC服務列表 僅注冊中心為file時使用 service.default.grouplist=192.168.1.204:8901 #全局事務開關 默認false。false為開啟，true為關閉 service.disableGlobalTransaction=false #降級開關 service.enableDegrade=false #默認false。業務側根據連續錯誤數自動降級不走seata事務 client.tm.degradeCheck=false #升降級達標閾值 默認10 client.tm.degradeCheckAllowTimes=10 #服務自檢周期 默認2000,單位ms.每2秒進行一次服務自檢,來決定 client.tm.degradeCheckPeriod=2000 #一階段全局提交結果上報TC重試次數 默認1次，建議大於1 client.tm.commitRetryCount=5 #一階段全局回滾結果上報TC重試次數 默認1次，建議大於1 client.tm.rollbackRetryCount=5 client.tm.defaultGlobalTransactionTimeout=60000 #是否上報一階段成功 true用於保持分支事務生命周期記錄完整，false可提高不少性能 client.rm.reportSuccessEnable=false #異步提交緩存隊列長度 默認10000。 二階段提交成功，RM異步清理undo隊列 client.rm.asyncCommitBufferLimit=10000 #校驗或占用全局鎖重試間隔 默認10，單位毫秒 client.rm.lock.retryInterval=10 #校驗或占用全局鎖重試次數 默認30 client.rm.lock.retryTimes=30 #分支事務與其它全局回滾事務沖突時鎖策略 默認true，優先釋放本地鎖讓回滾成功 client.rm.lock.retryPolicyBranchRollbackOnConflict=true #一階段結果上報TC重試次數 默認5次 client.rm.reportRetryCount=5 #自動刷新緩存中的表結構 默認false client.rm.tableMetaCheckEnable=false client.rm.tableMetaCheckerInterval=60000 #sql解析類型 默認druid,可選antlr client.rm.sqlParserType=druid client.rm.sagaBranchRegisterEnable=false #二階段回滾鏡像校驗 默認true開啟，false關閉 client.undo.dataValidation=true #undo序列化方式 默認jackson client.undo.logSerialization=jackson #自定義undo表名 默認undo_log client.undo.logTable=undo_log #只生成被更新列的鏡像 默認true client.undo.onlyCareUpdateColumns=true client.undo.compress.enable=true client.undo.compress.type=zip client.undo.compress.threshold=64k log.exceptionRate=100
客戶端
1、以spring cloud框架為例，添加jar包
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-seata</artifactId>
<exclusions>
<exclusion>
<groupId>io.seata</groupId>
<artifactId>seata-spring-boot-starter</artifactId>
</exclusion>
<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.4.2</version>
</dependency>
<dependency>
<groupId>io.seata</groupId>
<artifactId>seata-all</artifactId>
<version>1.4.2</version>
</dependency>
2、使用@GlobalTransactional(rollbackFor = Exception.class)
3、 配置
# 開啟seata seata.enabled=true seata.application-id=${spring.application.name} seata.tx-service-group=sale_tx_group seata.service.vgroup-mapping.sale_tx_group=default # 是否自動開啟數據源代理 seata.enable-auto-data-source-proxy=true # 數據源代理模式，使用AT模式 seata.data-source-proxy-mode=AT # 校驗或占用全局鎖重試間隔，單位ms seata.client.rm.lock.retry-interval=10 # 校驗或占用全局鎖重試次數 seata.client.rm.lock.retry-times=30 # 分支事務與其它全局回滾事務沖突時鎖策略,true，優先釋放本地鎖讓回滾成功 seata.client.rm.lock.retry-policy-branch-rollback-on-conflict=true # 一階段全局提交結果上報TC重試次數 seata.client.tm.commit-retry-count=5 # 一階段全局回滾結果上報TC重試次數 seata.client.tm.rollback-retry-count=5 # 分布式事物超時時間 ms seata.client.tm.default-global-transaction-timeout=600000 # 降級開關,false 不打開 seata.client.tm.degrade-check=false seata.client.tm.degrade-check-period=2000 seata.client.tm.degrade-check-allow-times=10 # 全局事務開關 seata.service.disable-global-transaction=false seata.support.spring.datasource-autoproxy=true # 注冊中心 seata.registry.type = nacos seata.registry.nacos.application = seata-server seata.registry.nacos.server-addr = ${spring.cloud.nacos.discovery.server-addr} seata.registry.nacos.namespace = ${spring.cloud.nacos.discovery.namespace} seata.registry.nacos.group = DEFAULT_GROUP #seata.registry.nacos.cluster = default # 配置中心 seata.config.type = nacos seata.config.nacos.server-addr = ${spring.cloud.nacos.discovery.server-addr} seata.config.nacos.group = DEFAULT_GROUP seata.config.nacos.dataId = seataServer.properties seata.config.nacos.namespace = 2d8ceb51-d8a3-405c-8cfd-22519d2da8fc # 日志留存天數 seata.log.exception-rate=100
參考連接：https://blog.csdn.net/fu_huo_1993/article/details/120504020