SpringBoot(三)

2022-10-30 12:00:45

1、Ribbon使用者端負載均衡

1.1 依賴

1.2 設定資訊

# feign預設載入了ribbon負載均衡,預設負載均衡機制是:輪詢
# 負載均衡機制是新增在消費端(使用者端)的,如果改為隨機,指定服務名,指定規則
edocmall-server:
  ribbon:
    NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule

1.3 測試

1.3.0 測試準備

1.3.0.1 複製一個伺服器端

1.3.0.2 eureka檢視服務

1.3.0.3 查詢資料

1.3.1 預設是輪詢

1.3.1.1 第一個伺服器端

1.3.1.2 第二個伺服器端

1.3.2 指定為隨機 後

1.3.2.1 第一個伺服器端

1.3.2.2 第二個伺服器端

1.3.3 可以自定義 負載均衡規則(省略)

2、Zuul閘道器

2.1 模組說明

2.2 主要依賴

<!--   eureka 使用者端依賴     -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-eureka</artifactId>
</dependency>

<!-- zuul 依賴 -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-zuul</artifactId>
</dependency>

2.3 設定資訊

# 埠
server:
  port: 8100

# 服務名
spring:
  application:
    name: edocmall-zuul

# eureka 註冊中心的設定
eureka:
  client:
    service-url:
      defaultZone: http://127.0.0.1:8096/eureka
  # 關閉自我保護機制,保證不可用的服務及時剔除
  server:
    enable-self-preservation: false

# zuul 閘道器設定
zuul:
  ignored-services: '*'  # 預設情況下,zuul閘道器服務會自動將eureka上的所有註冊服務名(serviceId)設定為預設路由地址(path),如果只能按照path設定路徑進行路由,必須手動遮蔽預設路由; *:表示所有的服務名不能作為路由地址,也可以指定具體服務名不能作為路由地址
  routes:
    edocmall-web-kgc: #預設路由的服務名,可以寫真實的服務名也可以自定義
      #方式一
#      path: /edocmall-web/**  # 指定自定義閘道器的對映路勁字首,代理的請求,必須是指定的存取路徑,才可以進入閘道器,否者無法進行閘道器對映處理
#      url: http://127.0.0.1:8098 # 指定請求服務的真實地址(一定要確保可以進行存取即地址有效),注意,無法進行叢集處理,不利於維護和擴充套件
      #方式二
      path: /edocmall-zuul/** #指定自定義閘道器路徑,配合service使用,實現通過指定服務名進行介面呼叫
      serviceId: edocmall-web  # 指定的是eureka註冊中心上,真實服務名,好處:(不需要維護請求地址)只需要指定服務名,自動根據服務名路由到對應的所有叢集服務上
    edocmall-server-kgc:
      path: /edocmall-zuul2/**
      serviceId: edocmall-server

2.4 主啟動類上的註解

@EnableEurekaClient
@EnableZuulProxy //開啟閘道器代理功能

2.5 測試

2.5.1 不遮蔽預設路由

serviceId: edocmall-web
和
path: /edocmall-zuul/**
都可以存取

2.5.2 遮蔽預設路由 ignored-services: '*'

只有
path: /edocmall-zuul/**
都可以存取

2.6 自定義閘道器過濾器

2.6.1 自定義閘道器過濾器

//Description: 自定義閘道器過濾器
@Component
public class AuthZuulFilter extends ZuulFilter {
    @Override
    public String filterType() {
        //指定閘道器過濾器的型別,允許返回值只能是:pre,post,route,error
        //pre : 在請求被路由轉發前呼叫,通常用於許可權校驗,紀錄檔處理等
        //post : 在請求被路由轉發後呼叫,一般都是收集服務呼叫資訊
        //route : 在請求被路由轉發是呼叫(服務被呼叫前),通常使用者在特定服務呼叫前增加引數處理
        //error: 在請求被路由轉發過程中,出現異常是呼叫
        return "pre";
    }

    @Override
    public int filterOrder() {
        //指定閘道器過濾器的優先順序,允許值是int型別整數,值越小優先順序越高
        return 0;
    }

    @Override
    public boolean shouldFilter() {
        //指定閘道器過濾器是否需要執行自定義的業務邏輯處理,如果是false不執行,true執行,執行自定義業務邏輯處理,就是下面的run方法內的業務邏輯
        return true;
    }

    @Override
    public Object run() {
        //自定義閘道器過濾器需要執行的業務邏輯處理

        //模擬場景:當請求到達閘道器,閘道器接收請求進行請求對映處理,把必須要先校驗許可權,
        // 如果許可權校驗失敗,不進行路由轉發,只有許可權校驗成功,才可以路由轉發到真實服務上

        //引入知識點:使用者在登入狀態保持,一般是通過token令牌實現的,當用戶登入成功,會返回一個token令牌給使用者端儲存,
        // 如果再次請求,自動攜帶改=該令牌,如果令牌有效,許可權通過,否者登入校驗失敗,不允許存取

        //為了方便演示,token變為請求引數,方便獲取(正常流程是後端登入成功後返回給使用者端,且必須要儲存在請求頭,方便攜帶),如果請求地址中沒有token引數,就不給存取,如果有,可以存取

        RequestContext requestContext = RequestContext.getCurrentContext();
        HttpServletRequest request = requestContext.getRequest();

        //根據請求物件獲取請求引數
        String token = request.getParameter("token");

        // TOO 必須要校驗token的有效性

        //許可權校驗,如果token令牌是有效的,可以進行路由轉發,否者需要重新登陸
        if(StringUtils.isBlank(token)){
            //token失敗,許可權校驗失敗,必須過濾調當前請求,不能進行路由轉發
            requestContext.setSendZuulResponse(false);

            //修改返回提示資訊
            requestContext.setResponseStatusCode(HttpStatus.FORBIDDEN.value());
//            requestContext.setResponseBody(HttpStatus.FORBIDDEN.getReasonPhrase());
            requestContext.setResponseBody("token令牌校驗失敗,請求非法,被攔截");

            //設定響應的內容格式,防止中文亂碼
            HttpServletResponse response = requestContext.getResponse();
            response.setContentType("text/html;charset=utf-8");

        }

        //返回RequestContext 物件
        return requestContext;
    }
}

2.6.2 測試

3、Config設定中心

3.1 模組介紹

3.2 conf-sever 設定伺服器端

3.2.1 依賴

<!--   eureka 使用者端依賴     -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-eureka</artifactId>
</dependency>

<!-- config 設定中心伺服器端依賴 -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-config-server</artifactId>
</dependency>

3.2.2 設定資訊 application.yml

# 埠
server:
  port: 8101

# 服務名
spring:
  application:
    name: edocmall-conf-server
  # 指定環境,適用於本地環境設定,即:將公共設定中心內部檔案作為公共組態檔,提供給使用者端使用
#  profiles:
#    active: native
# git 倉設定資訊
  cloud:
    config:
      server:
        git:
          uri: https://gitee.com/wangsong_huayu/kh96-conf-server.git
          username: username
          password: password

# eureka 註冊中心的設定
eureka:
  client:
    service-url:
      defaultZone: http://127.0.0.1:8096/eureka

3.2.3 主啟動類上的註解

@EnableEurekaClient  //config伺服器端註冊到eureka註冊中心
@EnableConfigServer  //開啟 congfig 設定中心伺服器端

3.2.4 本地公共設定 config-native.properties

# 自定義公共設定
kh96.conf.server=kh96-conf-server-native

3.2.5 git 倉 管理的設定資訊

3.2.5.1 本地倉

2.3.5.2 遠端倉

3.3 conf-client 設定使用者端

3.3.1 依賴

<!--   eureka 使用者端依賴     -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-eureka</artifactId>
</dependency>

<!-- config 設定中心 使用者端依賴 -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-config</artifactId>
</dependency>

3.3.2 設定資訊application.yml

# 埠
server:
  port: 8102

# 服務名
spring:
  application:
    name: edocmall-conf-client

3.3.3 設定資訊 bootstrap.properties

# 什麼時候使用此組態檔
# 1、當使用SpringCloud的config設定中心時,在使用者端需要註冊到eureka註冊中心時,eureka設定資訊必須增加在此檔案中,才會生效
# 2、當設定資訊不能被其它的組態檔覆蓋時,可以將內容設定到此檔案中,優先順序高於application(雲可以遮住太陽)

# config使用者端,設定eureka註冊中心
eureka.client.service-url.defaultZone=http://127.0.0.1:8096/eureka

# config使用者端,開啟主動發現eureka註冊中心上 註冊的config設定中心伺服器端,預設是關閉的,必須手動開
spring.cloud.config.discovery.enabled=true

# config使用者端,指定eureka註冊中心上註冊的config設定中心伺服器端的服務名
spring.cloud.config.discovery.service-id=edocmall-conf-server

# 讀取本地 設定組態檔
# config使用者端,指定從config設定中心伺服器端讀取 本地 的公共組態檔名,注意:不需要加字尾,只要檔名
#spring.cloud.config.name=config-native

# 讀取遠端組態檔
# config使用者端,指定從 config設定中伺服器端讀取的檔名,對應遠端創庫檔名 符號 - ,前面的名稱
spring.cloud.config.name=config

# config使用者端,指定從 config設定中伺服器端讀取的檔名,對應遠端創庫檔名 符號 - ,後面的名稱
spring.cloud.config.profile=dev

# config使用者端,指定從 config設定中伺服器端讀取 對應git遠端倉庫中設定所在的分支名,預設是master主線分支,也可以指定其他分支
spring.cloud.config.label=master

3.3.4 請求方法

//測試讀取config設定中心伺服器端提供的公共設定資訊
@RestController
public class ConfigClientController {

    @Value("${kh96.conf.server:kh96-conf-client-native}")
    private String kh96ConfigServer;

    // 使用者端,測試讀取伺服器端的公共設定資訊
    @GetMapping("/testConfigServer")
    public String testGetPropertiesFromConfServer(){
        return kh96ConfigServer;
    }

}

3.3.5 主啟動類上的註解

@EnableEurekaClient

3.4 測試

3.4.0 設定伺服器端與設定使用者端

3.4.1 本地公共設定讀取

3.4.2 git 倉管理的設定資訊讀取