后端微服務基礎架構Spring Cloud

版本關系

版本發布說明-阿里云Spring Cloud Alibaba官網

選擇

創建項目

創建父項目

什么都不動，創建即可

1)? 刪掉沒用的文件

保留

2) pom中加入

打包方式  <packaging>pom</packaging>

3) 刪掉src

4) pom.xml中刪除沒用的

5)更改pom.xml中

spring-boot-starter-parent版本為更改為3.3.4，點擊右上角的maven標記刷新依賴

? ?刪掉依賴

properties更換為

  <properties><maven.compiler.source>17</maven.compiler.source><maven.compiler.target>17</maven.compiler.target><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><spring-cloud.version>2023.0.3</spring-cloud.version><spring-cloud-alibaba.version>2023.0.3.2</spring-cloud-alibaba.version></properties>

再加入：刷新

<dependencyManagement><dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-dependencies</artifactId><version>${spring-cloud.version}</version><type>pom</type><scope>import</scope></dependency><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-alibaba-dependencies</artifactId><version>${spring-cloud-alibaba.version}</version><type>pom</type><scope>import</scope></dependency></dependencies></dependencyManagement>

完整的：

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>3.3.4</version><relativePath/> <!-- lookup parent from repository --></parent><packaging>pom</packaging><groupId>com.i7i8i9</groupId><artifactId>weifuwu3</artifactId><version>0.0.1-SNAPSHOT</version><name>weifuwu3</name><description>weifuwu3</description><properties><maven.compiler.source>17</maven.compiler.source><maven.compiler.target>17</maven.compiler.target><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><spring-cloud.version>2023.0.3</spring-cloud.version><spring-cloud-alibaba.version>2023.0.3.2</spring-cloud-alibaba.version></properties><dependencyManagement><dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-dependencies</artifactId><version>${spring-cloud.version}</version><type>pom</type><scope>import</scope></dependency><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-alibaba-dependencies</artifactId><version>${spring-cloud-alibaba.version}</version><type>pom</type><scope>import</scope></dependency></dependencies></dependencyManagement><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build></project>

創建最外層服務

1.創建module? ---services

就是個普通java module，不用選add sample code

pom中也是加入打包方式

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><parent><artifactId>weifuwu3</artifactId><groupId>com.i7i8i9</groupId><version>0.0.1-SNAPSHOT</version></parent><modelVersion>4.0.0</modelVersion><artifactId>services</artifactId><packaging>pom</packaging><properties><maven.compiler.source>17</maven.compiler.source><maven.compiler.target>17</maven.compiler.target><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding></properties></project>

刪除src

創建微服務

新建module ,主要是確認一定在上面建立的services服務下，不用選add sample code,Parent一定要對，

創建完成后，在父級服務pom中可以看到<modules>

查看maven結構

可以點擊齒輪，選中Group Modules

完善項目

導入公共依賴

主要是在最外層services pom.xml中加入，比如nacos

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><parent><artifactId>weifuwu3</artifactId><groupId>com.i7i8i9</groupId><version>0.0.1-SNAPSHOT</version></parent><modelVersion>4.0.0</modelVersion><artifactId>services</artifactId><packaging>pom</packaging><properties><maven.compiler.source>17</maven.compiler.source><maven.compiler.target>17</maven.compiler.target><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding></properties><dependencies>
<!--        導入nacos--><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId></dependency></dependencies>
</project>

在各層服務依賴中查看

啟動

給每個微服務pom.xml導入Web依賴

在某個微服務上點擊右鍵 generate,選擇 edit starters

不行自己導

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><parent><artifactId>weifuwu3</artifactId><groupId>com.i7i8i9</groupId><version>0.0.1-SNAPSHOT</version><relativePath>../../pom.xml</relativePath></parent><modelVersion>4.0.0</modelVersion><artifactId>service-order</artifactId><properties><maven.compiler.source>17</maven.compiler.source><maven.compiler.target>17</maven.compiler.target><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding></properties><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency></dependencies></project>

新建主程序

src/main/java下新建

com.i7i8i9.auth.AuthMainApplication

package com.i7i8i9.order;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;@SpringBootApplication
public class OrderMainApplication {public static void main(String[] args) {SpringApplication.run(OrderMainApplication.class, args);}
}

編寫application.yml

spring.application.name=service-order
server.port=8080
spring.cloud.nacos.discovery.server-addr=127.0.0.1:8848

Nacos

? 下載，啟動

http://192.168.32.1:8848/nacos/index.html

基本原則

1.Gateway:? ?前后端之間會經過GateWay, 后端服務之間因為屬于同一個工程，一般不經過

? ? ? ? ? ? ? ? ? ? ? GateWay，但也可以經過

服務

1.目錄

? ? ?服務可以都放在服務模塊下，但是需要在服務模塊的pom.xml體現

? ? ??

? ?pom.xml

? ??

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><parent><artifactId>cloud-demo</artifactId><groupId>com.i7i8i9</groupId><version>0.0.1-SNAPSHOT</version></parent><packaging>pom</packaging><modelVersion>4.0.0</modelVersion><modules><module>service-product</module><module>service-order</module><module>seata-account</module><module>seata-business</module><module>seata-order</module><module>seata-storage</module></modules><artifactId>services</artifactId><properties><maven.compiler.source>17</maven.compiler.source><maven.compiler.target>17</maven.compiler.target><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding></properties><dependencies>
<!--   sentinel是流量保護    --><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-sentinel</artifactId></dependency><dependency><!--        nucos 注冊中心   服務發現--><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><!-- openfeign 遠程調用--><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><scope>annotationProcessor</scope></dependency><dependency><groupId>com.i7i8i9</groupId><artifactId>model</artifactId><version>0.0.1-SNAPSHOT</version></dependency></dependencies>
</project>

Feign遠程調用

指的是需要調用其他服務的服務

1.服務src下建立feign文件夾

2.服務主程序上加注釋

@EnableFeignClients(basePackages = "com.atguigu.business.feign")

3.Feign文件夾內建需要調用的抽象類客戶端

? ? ?主要目的是供serviceImp使用

? ? 快速的方式是去被調用controller方面里面復制

方法名前面可以去掉public

package com.atguigu.business.feign;import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;@FeignClient(value="seata-storage")     //服務名稱nacos里面有
public interface StorageFeignClient {//找到扣庫存服務的接口復制其方法名和參數/**** @param commodityCode* @param count* @return*/@GetMapping("/deduct")String deduct(@RequestParam("commodityCode") String commodityCode,@RequestParam("count") Integer count);
}

4.服務實現類

主要是裝配Feign客戶端，再調用其方法

package com.atguigu.business.service.impl;import com.atguigu.business.feign.OrderFeignClient;
import com.atguigu.business.feign.StorageFeignClient;
import com.atguigu.business.service.BusinessService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;@Service
public class BusinessServiceImpl implements BusinessService {//第一步就是拿到遠程服務客戶端@AutowiredStorageFeignClient storageFeignClient;@AutowiredOrderFeignClient orderFeignClient;@Overridepublic void purchase(String userId, String commodityCode, int orderCount) {//TODO 1. 扣減庫存storageFeignClient.deduct(commodityCode,orderCount);//TODO 2. 創建訂單orderFeignClient.create(userId,commodityCode,orderCount);}
}

GateWay

SpringCloud基礎2——Nacos配置、Feign、Gateway-阿里云開發者社區

nacos(七): gateway(單體)-CSDN博客

創建服務

pom.xml引入gateway和loadbalence

 <!--網關--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-gateway</artifactId></dependency><!--消費者--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-loadbalancer</artifactId><version>3.1.5</version></dependency>

新建module

加上服務發現@EnableDiscoveryClient

package com.i7i8i9.gateway;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;@SpringBootApplication
@EnableDiscoveryClient
public class GatewayApplication {public static void main(String[] args) {SpringApplication.run(GatewayApplication.class, args);}
}

啟動

yml

application.yml

spring:active: devapplication:name: gatewaycloud:nacos:discovery:server-addr: 127.0.0.1:8848username: nacospassword: nacosconfig:server-addr: 127.0.0.1:8848file-extension: propertiesusername: nacospassword: nacosloadbalancer:nacos:enabled: truegateway:discovery:locator:enabled: trueroutes: # 網關路由配置#第一組網關路由配置，針對于服務service-auth- id: serviceAuth # 路由id，自定義，只要唯一即可uri: lb://service-auth # 指的是從nacos中按照名稱獲取微服務，并遵循負載均衡策略predicates: # 路由斷言。也就是判斷請求是否符合路由規則的條件。predicates譯為謂語、斷言- Path=/auth/** # 路徑斷言。當請求路徑滿?Path指定的規則時,才進?路由換發filters:- StripPrefix=1    # 拼接好url之后去掉1層路徑也就是p1#http://localhost:10010/auth/token，因為/auth/路徑觸發了第一個路由規則，路由去掉p1這一項，重新拼接為lb://service-auth/auth去獲取訪問的結果。:datasource:driver-class-name: ${i7i8i9.datasource.driver-class-name}url: jdbc:mysql://${i7i8i9.datasource.host}:${i7i8i9.datasource.port}/${i7i8i9.datasource.database}?serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf-8&zeroDateTimeBehavior=convertToNull&useSSL=false&allowPublicKeyRetrieval=trueusername: ${i7i8i9.datasource.username}password: ${i7i8i9.datasource.password}

?- id: serviceAuth # 路由id，自定義，只要唯一即可
? ? ? ? ? ?uri: lb://service-auth # 指的是從nacos中按照名稱獲取微服務，并遵循負載均衡策略
? ? ? ? ? ?predicates: # 路由斷言。也就是判斷請求是否符合路由規則的條件。predicates譯為謂語、斷言
? ? ? ? ? ? ? - Path=/auth/** # 路徑斷言。當請求路徑滿?Path指定的規則時,才進?路由換發
? ? ? ? ? ?filters:
? ? ? ? ? ? ? - StripPrefix=1 ? ?# 拼接好url之后去掉1層路徑也就是p1
? ? #http://localhost:10010/auth/token，因為/auth/路徑觸發了第一個路由規則，路由去掉p1這一項，重新拼接為lb://service-auth/auth去獲取訪問的結果。:

假設有個服務實際調用地址為

? ?http://localhost:8085/token

? ?則也可以用以下兩種方式訪問：

? ??http://localhost:10010/service-auth/token? ? ? 這種service-auth就是實際上nacos服務名稱

? ??http://localhost:10010/auth/token? ? ? ? ? ? ? 這是標準的，auth就是上面的斷言，就是當出現auth時就去調用nacos 里面的service-auth

404：注意如果請求404則可能是最后面多了/

AxiosError {message: 'Network Error', name: 'AxiosError', code: 'ERR_NETWORK', config: {…}, request: XMLHttpRequest, …}

application-dev.yml

server:port: 10010 #當前spring boot工程運行時所占用的端口號i7i8i9:datasource:driver-class-name: com.mysql.cj.jdbc.Driverhost: 120.79.150.231 #主機地址port: 3306 #端口號database: basic #當前需要連接的數據庫username: admin #用戶password: tyuueew333444IIIIOOO88qqq #密碼

服務查看

跨域

可以使用nginx

?nginx: download

默認80端口

D:\soft\nginx-1.27.5\conf

nginx -s reload

npm run build

事務

每個微服務都有對應的數據庫

本地事務

? 主要是單接口測試，自己操作自己的數據庫

操作數據庫的服務的main主類上

? ? ? ?@EnableTransactionManagement

一般ServiceImpl類會加

?@Transactional

? 注意沒有引入mybatis是沒有這個注解的

全局事務-alibaba seata

本地事務要先配好

1.啟動客戶端Seata-綠色軟件

? 下載Seata Java Download | Apache Seata

要使用2.1.0

兩次解壓，找到文件夾seata-server

? ? 點擊bat文件即可啟動

? 登錄 http://localhost:7091/，賬號密碼都是seata? ?7091是網頁端口

?注意服務監聽端口不是7091，而是8091

2.為服務總配置引入seata

? ?在最外層服務pom.xml中，ctrl進入

spring-cloud-alibaba-dependencies

在里面搜索

可見seata的版本是2.1.0所以啟動seata服務端一定要用2.1.0

復制下面的alibaba的seata,注意不是springboot的

    <dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-seata</artifactId><version>2023.0.3.2</version></dependency>

在服務最外層service模塊下的pom.xml引入

不用寫版本號

引入之后在maven依賴中可以看到已經有了

3.服務文件引入

? ?可以配置每個服務的yml用于指定分組

但也可以不在yml配，默認為

default_tx_group，因為如下有默認組

添加file.conf文件，以后也可以放到nacos里面

service {#transaction service group mapping  default_tx_group是默認分組vgroupMapping.default_tx_group = "default"#only support when registry.type=file, please don't set multiple addresses#注意不是seara網頁端口default.grouplist = "127.0.0.1:8091"#degrade, current not supportenableDegrade = false#disable seatadisableGlobalTransaction = false
}

4.標注全局事務

@GlobalTransactional

也就是需要配置TM，它是入口

package com.atguigu.business.service.impl;import com.atguigu.business.feign.OrderFeignClient;
import com.atguigu.business.feign.StorageFeignClient;
import com.atguigu.business.service.BusinessService;
import org.apache.seata.spring.annotation.GlobalTransactional;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;@Service
public class BusinessServiceImpl implements BusinessService {//第一步就是拿到遠程服務客戶端@AutowiredStorageFeignClient storageFeignClient;@AutowiredOrderFeignClient orderFeignClient;
@GlobalTransactional@Overridepublic void purchase(String userId, String commodityCode, int orderCount) {//TODO 1. 扣減庫存storageFeignClient.deduct(commodityCode,orderCount);//TODO 2. 創建訂單orderFeignClient.create(userId,commodityCode,orderCount);}
}

四種事務模式

默認是AT模式，就是自動模式

XA模式：

? ?使用早期數據庫模式，第一階段提交就沒有真正提交，一直占用數據庫，阻塞等待

更改方法

TCC

全手動，適合于夾雜了非數據庫事務，也就是廣義的事務，比如發郵件，發短信

要額外寫接口這三個階段（準備，提交，回滾）要做什么

比如第一階段已經發了短信，只能再第三階段再發一個糾正短信了

Saga

長事務

可能要好多天，比如請假，要經過審批，就不適合于用鎖了

基于消息隊列，第二個人收到第一個人的消息再做事，某個人失敗了就通知所有人失敗了

其他人收到消息后使用自定義處理，也就是補償代碼

其它

1.配置輸出為null

order.timeout=null;order.auto-confirm=nullorder.db-urlnull

原因

proerties:

#spring.cloud.nacos.discovery.server-addr=localhost:8848

yml?

沒用discovery

server:port:8900
spring:application:name: service-ordercloud:nacos:server-addr: localhost:8848config:namespace: devconfig:import:- nacos:common.properties?group=order- nacos:db.properties?group=order

日志

給微服務配置遠程日志

在每個服務的application.yml中給feign包

logging:level:com.i7i8i9.feign: debug

#注意：遠程配置的優先級高于本地server:port:8900    #雖然這里寫了8090,但是實際使用端口還是可以在Edit configurattion中指定
spring:profiles:active: uat       #第1步： 指定本項目激活環境，該名字需要對應nacos的namespaceinclude: feign      #包含yml標識 feign，也就是application-feign.ymlapplication:name: service-ordercloud:nacos:server-addr: localhost:8848config:namespace: ${spring.profiles.active:dev}   #獲取激活環境名稱，找到nacos同名命名空間，如果獲取不到環境名稱就使用冒號后面的默認值
#          :dev是默認值dev的意思，如果找不到這個變量
logging:level:com.i7i8i9.feign: debug---
spring:               #on-profile: dev 也就是說dev需要啟用的配置，每個環境要導入的不一定一樣config:import:- nacos:common.properties?group=order- nacos:db.properties?group=orderactivate:on-profile: dev---
spring:               #on-profile: UAT 也就是說dev需要啟用的配置，每個環境要導入的不一定一樣config:import:- nacos:common.properties?group=order- nacos:db.properties?group=orderactivate:on-profile: uat---
spring:           #on-profile: prod 也就是說dev需要啟用的配置，每個環境要導入的不一定一樣config:import:- nacos:common.properties?group=order- nacos:db.properties?group=orderactivate:on-profile: prod

?然后在微服務的配置類里面把Level放到容器中(就是加上@Bean)

package com.i7i8i9.config;import feign.Logger;
import feign.RetryableException;
import feign.Retryer;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.client.RestTemplate;@Configuration
public class OrderConfig {//    @BeanRetryer retryer(){return new Retryer.Default();}@BeanLogger.Level  feignLoggerLevel(){return  Logger.Level.FULL;}@LoadBalanced   //注解式負載均衡，不要難過其他操作@BeanRestTemplate restTemplate(){return new RestTemplate();}}

注釋

idea創建java類時自動配置注解 idea如何設置類的自動注釋_mob64ca1415f0ab的技術博客_51CTO博客

前端

Vue3與ts中使用axios vue3加ts_mob64ca14031c97的技術博客_51CTO博客

Debug

? ? 1.seata兩段事務debug

? ? ? ?標注斷點

? 全部服務都以debug模式啟動

發送請求

刷新seata

可見因為標記了@GlobalTransactional出現一個全局事務

applicationId就是所屬應用： seata-business

transactionName觸發全局事務入口??purchase(java.lang.String, java.lang.String, int)

status:beigin

timeout: 1分鐘沒做完就過期

還可以點擊最后面查看用到了哪些全局鎖(每個服務修改自己數據前獲得的，以保證別的服務不能穿插著改)

放行

報錯

指向扣庫存,原因是庫存分支事務注冊失敗，超過了上述配置的60s導致

重新來

? 重新發送請求，再加個斷點

放行

就會來到第二個斷點

打開最右側的包括分支事務

就可以查看分支事務，是已經注冊完了的庫存事務

?全局鎖也能看到信息

可以看到在數據表storage_tbl有一把全局鎖

去storage_db數據庫查看

數據此時是98

并且有undo日志

數據復制出來

{"@class":"org.apache.seata.rm.datasource.undo.BranchUndoLog","xid":"192.168.32.1:8091:9628920695037968","branchId":9628920695037969,"sqlUndoLogs":["java.util.ArrayList",[{"@class":"org.apache.seata.rm.datasource.undo.SQLUndoLog","sqlType":"UPDATE","tableName":"storage_tbl","beforeImage":
{"@class":"org.apache.seata.rm.datasource.sql.struct.TableRecords","tableName":"storage_tbl","rows":["java.util.ArrayList",
[{"@class":"org.apache.seata.rm.datasource.sql.struct.Row","fields":["java.util.ArrayList",
[{"@class":"org.apache.seata.rm.datasource.sql.struct.Field","name":"count","keyType":"NULL","type":4,"value":100},
{"@class":"org.apache.seata.rm.datasource.sql.struct.Field","name":"id","keyType":"PRIMARY_KEY","type":4,"value":1}]]}]]},"afterImage":
{"@class":"org.apache.seata.rm.datasource.sql.struct.TableRecords","tableName":"storage_tbl","rows":["java.util.ArrayList",
[{"@class":"org.apache.seata.rm.datasource.sql.struct.Row","fields":["java.util.ArrayList",
[{"@class":"org.apache.seata.rm.datasource.sql.struct.Field","name":"count","keyType":"NULL","type":4,"value":98},
{"@class":"org.apache.seata.rm.datasource.sql.struct.Field","name":"id","keyType":"PRIMARY_KEY","type":4,"value":1}]]}]]}}]]}