主頁 > 後端開發 > SpringCloud Alibaba(二) - Sentinel，整合OpenFeign,GateWay服務網關

SpringCloud Alibaba(二) - Sentinel，整合OpenFeign,GateWay服務網關

2022-11-29 06:50:16 後端開發

1、環境準備

1.1Nacos

單機啟動：startup.cmd -m standalone

1.2 Sentinel

啟動命令：java -Dserver.port=8858 -Dcsp.sentinel.dashboard.server=localhost:8858 -Dproject.name=sentinel-dashboard -jar sentinel-dashboard-1.8.0.jar

1.3 JMeter

2、流控規則限流

2.0 環境搭建

2.0.1 依賴

<!--   nacos 依賴     -->
<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>

<!--   sentinel 流量防衛依賴    -->
<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
</dependency>

<!--   暴露/actuator/sentinel端點 單獨配置，management開頭    -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>

2.0.2 application.yml

# 埠
server:
  port: 9604

# 服務名
spring:
  application:
    name: kgcmall-sentinel

  # 資料源配置
  datasource:
    driver-class-name: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://localhost:3306/kh96_alibaba_kgcmalldb?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=GMT
    username: root
    password: 17585273765

  # jpa配置
  jpa:
    hibernate:
      ddl-auto: update
    show-sql: true

  cloud:
    #nacos 配置
    nacos:
      discovery:
        server-addr: 127.0.0.1:8848

    #sentinel 配置
    sentinel:
      transport:
        dashboard: 127.0.0.1:8858 # sentinel 控制臺地址
        port: 9605 # 客戶端(核心應用)和控制臺的通信埠，默認8719，子當以一個為被使用的唯一埠即可
      web-context-unify: false #關閉收斂 

# 暴露/actuator/sentinel端點 單獨配置，management 開頂格寫
management:
  endpoints:
    web:
      exposure:
        include: '*'

2.0.3 測驗

http://localhost:9604/actuator/sentinel

2.1 流控模式

2.1.1 直接模式

2.1.1.1 測驗請求
/**
* @param : [sentinelDesc]
* @return : java.lang.String
* @author : huayu
* @date : 26/11/2022
* @description : 測驗 Sentinel 流控 - 直接失敗
*/
@GetMapping("testSentinelFlowFail")
public String testSentinelFlowFail(@RequestParam String sentinelDesc) {
    log.info("------ testSentinelFlowFail 介面呼叫 ------ ");
    return sentinelDesc;
}
2.1.1.2 添加直接流控規則
2.1.1.2.1 需要先發起例外請求

2.1.1.2.2 簇點鏈路 添加流控規則

2.1.1.2.3 設定流控規則

2.1.1.3查看流控規則

2.1.1.4 測驗

2.1.1.5 自定義sentinel統一已成回傳處理
/**
 * Created On : 26/11/2022.
 * <p>
 * Author : huayu
 * <p>
 * Description: 自定義sentinel統一已成回傳處理
 */
@Slf4j
@Component
public class MySentinelBlockExceptionHandler implements BlockExceptionHandler {

    @Override
    public void handle(HttpServletRequest httpServletRequest, HttpServletResponse httpServletResponse, BlockException e) throws Exception {
        // 記錄例外日志
        log.warn("------ MySentinelBlockExceptionHandler 規則Rule：{} ------", e.getRule());

        // 增加自定義統一例外回傳物件
        RequestResult<String> requestResult = null;

        // 針對不同的流控例外，統一回傳
        if (e instanceof FlowException) {
            requestResult = ResultBuildUtil.fail("9621", "介面流量限流");
        } else if (e instanceof DegradeException) {
            requestResult = ResultBuildUtil.fail("9622", "介面服務降級");
        } else if (e instanceof ParamFlowException) {
            requestResult = ResultBuildUtil.fail("9623", "熱點引數限流");
        } else if (e instanceof SystemBlockException) {
            requestResult = ResultBuildUtil.fail("9624", "觸發系統保護");
        } else if (e instanceof AuthorityException) {
            requestResult = ResultBuildUtil.fail("9625", "授權規則限制");
        }

        // 統一回傳json結果
        httpServletResponse.setStatus(HttpStatus.FORBIDDEN.value());
        httpServletResponse.setCharacterEncoding("utf-8");
        httpServletResponse.setContentType(MediaType.APPLICATION_JSON_VALUE);

        // 借助SpringMVC自帶的Jackson工具，回傳結果
        new ObjectMapper().writeValue(httpServletResponse.getWriter(), requestResult);
    }


}
2.1.1.6 再次測驗

2.1.2 關聯模式

2.1.2.1 測驗請求
/**
* @param : [sentinelDesc]
* @return : java.lang.String
* @author : huayu
* @date : 26/11/2022
* @description : 測驗 Sentinel 流控 - 關聯
*/
@GetMapping("testSentinelFlowLink")
public String testSentinelFlowLink(@RequestParam String sentinelDesc) {
    log.info("------ testSentinelFlowLink 介面呼叫 ------ ");
    return sentinelDesc;
}
2.1.1.2 添加關聯流控規則

2.1.1.3 JMeter壓測配置
2.1.1.3.1 執行緒組

2.1.1.3.2 Http請求

2.1.1.3.3 測驗 testSentinelFlowLink 介面

2.1.3 鏈路模式

鏈路流控模式指的是，當從某個介面過來的資源達到限流條件時，開啟限流，它的功能有點類似于針對來源配置項，區別在于：針對來源是針對上級微服務，而鏈路流控是針對上級介面，也就是說它的粒度更細，

2.1.3.1 添加呼叫方法
2.1.3.1.1 介面
/**
 * Created On : 26/11/2022.
 * <p>
 * Author : huayu
 * <p>
 * Description: 測驗鏈路 模式
 */
public interface SentinelService {

    void message();

}
2.1.3.1.2 實作類
/**
 * Created On : 26/11/2022.
 * <p>
 * Author : huayu
 * <p>
 * Description: 測驗鏈路 模式 實作類
 */
@Service
public class SentinelServiceImpl implements SentinelService {

    @Override
    @SentinelResource("message") // 在@SentinelResource中指定資源名
    public void message() {
        System.out.println("message");
    }

}
2.1.3.2 兩個介面，呼叫相同的資源
@Slf4j
@RestController
public class KgcMallSentinelController {


    @Autowired
    private SentinelService sentinelService;

  //測驗 Sentinel 流控 - 直接失敗
    @GetMapping("testSentinelFlowFail")
    public String testSentinelFlowFail(@RequestParam String sentinelDesc) {

        log.info("------ testSentinelFlowFail 介面呼叫 ------ ");

        //測驗 鏈路模式呼叫相同的資源
        sentinelService.message();

        return sentinelDesc;
    }


    //測驗 Sentinel 流控 - 關聯
    @GetMapping("testSentinelFlowLink")
    public String testSentinelFlowLink(@RequestParam String sentinelDesc) {

        log.info("------ testSentinelFlowLink 介面呼叫 ------ ");

        //測驗 鏈路模式呼叫相同的資源
        sentinelService.message();
        return sentinelDesc;
    }

}
2.1.3.3 添加鏈路流控規則

2.1.3.4 測驗

如果message觸發流控，指定的入口就會被限流；

2.1.3.4.0 高版本此功能直接使用不生效：

1.7.0 版本開始（對應SCA的2.1.1.RELEASE)，官方在CommonFilter 引入了WEB_CONTEXT_UNIFY 引數，用于控制是否收斂context，將其配置為 false 即可根據不同的URL 進行鏈路限流，

spring:
  cloud:
    #sentinel 配置
    sentinel:
      web-context-unify: false #關閉收斂 
2.1.3.4.1 testSentinelFlowFail 請求

2.1.3.4.2 testSentinelFlowLink請求 (message 資源對此入口進行了限流)

使用鏈路規則，會導致統一回傳處理，無法生效；

2.2 流控規則

2.2.1 快速失敗

快速失敗：直接拋出例外，默認的流量控制方式

當QPS超過任意規則的閾值后，新的請求就會被立即拒絕，這種方式適用于對系統處理能力確切已知的情況下；

2.2.2 Warm Up(激增模式)

Warm Up（激增流量）即預熱/冷啟動方式；

冷加載因子: codeFactor 默認是3，即請求 QPS 從 1 / 3 開始，經預熱時長逐漸升至設定的 QPS 閾值，

當系統長期處于低水位的情況下，當流量突然增加時，直接把系統拉升到高水位可能瞬間把系統壓垮，通過"冷啟動"，讓通過的流量緩慢增加，在一定時間內逐漸增加到閾值上限，給冷系統一個預熱的時間，避免冷系統被壓垮，

2.2.2.1 使用 testSentinelFlowFail 請求測驗

請求方法省略；

2.2.2.2 流控配置

2.2.2.3 壓測配置

2.2.3.4 實時監控

2.2.3 勻速模式

會嚴格控制請求通過的間隔時間，也即是讓請求以均勻的速度通過，其余的排隊等待，對應的是漏桶演算法，

用于處理間隔性突發的流量，例如訊息佇列，在某一秒有大量的請求到來，而接下來的幾秒則處于空閑狀態，這個時候我們不希望一下子把所有的請求都通過，這樣可能會把系統壓垮；同時我們也期待系統以穩定的速度，逐步處理這些請求，以起到“削峰填谷”的效果，而不是第一秒拒絕所有請求，

選擇排隊等待的閾值型別必須是QPS，且暫不支持>1000的模式

2.2.3.1 使用 testSentinelFlowFail 請求測驗

請求方法省略；

單機閾值:每秒通過的請求個數是5，則每隔200ms通過一次請求；每次請求的最大等待時間為500ms=0.5s，超過0.5S就丟棄請求，

2.2.3.2 流控配置

2.2.3.3 壓測配置

2.2.3.4 實時監控

3、降級規則限流

3.1慢呼叫比例-SLOW_REQUEST_RATIO

選擇以慢呼叫比例作為閾值，需要設定允許的慢呼叫 RT（即最大的回應時間），請求的回應時間大于該值則統計為慢呼叫，當單位統計時長（statIntervalMs）內請求數目大于設定的最小請求數目，并且慢呼叫的比例大于閾值，則接下來的熔斷時長內請求會自動被熔斷，經過熔斷時長后熔斷器會進入探測恢復狀態（HALF-OPEN 狀態），若接下來的一個請求回應時間小于設定的慢呼叫 RT 則結束熔斷，若大于設定的慢呼叫 RT 則會再次被熔斷，

3.1.1 模擬慢呼叫請求

/**
* @param : [sentinelDesc]
* @return : java.lang.String
 * @author : huayu
* @date : 26/11/2022
 * @description : 測驗 Sentinel-降級-慢呼叫
*/
@GetMapping("testSentinelDown")
public String testSentinelDown(@RequestParam String sentinelDesc) throws InterruptedException {

    log.info("------ testSentinelDown 介面呼叫 ------ ");

    //模擬慢呼叫
    TimeUnit.MILLISECONDS.sleep(100);

    return sentinelDesc;
}

3.1.2 降級策略

3.1.3 壓測配置

3.1.4 實時監控

3.1.5 從瀏覽器請求測驗

3.2 例外比例-ERROR_RATIO

當單位統計時長（statIntervalMs）內請求數目大于設定的最小請求數目，并且例外的比例大于閾值，則接下來的熔斷時長內請求會自動被熔斷，

經過熔斷時長后熔斷器會進入探測恢復狀態（HALF-OPEN 狀態），若接下來的一個請求成功完成（沒有錯誤）則結束熔斷，否則會再次被熔斷，例外比率的閾值范圍是 [0.0, 1.0]，代表 0% - 100%，

3.2.1 模擬例外比例請求

/**
* @param : [sentinelDesc]
* @return : java.lang.String
* @author : huayu
* @date : 26/11/2022
* @description : 測驗 Sentinel-降級-例外比例    例外數
*/
@GetMapping("testSentinelDownExpScale")
public String testSentinelDownExpScale(@RequestParam String sentinelDesc) throws InterruptedException {

    log.info("------ testSentinelDownExpScale 介面呼叫 ------ ");

    //模擬例外
    int num = new Random().nextInt(10);
    if (num % 2 == 1) {
        num = 10 / 0;
    }
    return sentinelDesc;
}

3.2.2 降級策略

3.2.3 壓測配置

3.2.4 實時監控

3.2.5 從瀏覽器請求測驗

3.3 例外數-ERROR_COUNT

當單位統計時長內的例外數目超過閾值之后會自動進行熔斷，經過熔斷時長后熔斷器會進入探測恢復狀態（HALF-OPEN 狀態），若接下來的一個請求成功完成（沒有錯誤）則結束熔斷，否則會再次被熔斷，

注意：例外降級僅針對業務例外，對 Sentinel 限流降級本身的例外（BlockException）不生效，

3.3.1 模擬例外引數請求

/**
* @param : [sentinelDesc]
* @return : java.lang.String
* @author : huayu
* @date : 26/11/2022
* @description : 測驗 Sentinel-降級-例外比例    例外數
*/
@GetMapping("testSentinelDownExpScale")
public String testSentinelDownExpScale(@RequestParam String sentinelDesc) throws InterruptedException {

    log.info("------ testSentinelDownExpScale 介面呼叫 ------ ");

    //模擬例外
    int num = new Random().nextInt(10);
    if (num % 2 == 1) {
        num = 10 / 0;
    }
    return sentinelDesc;
}

3.3.2 降級策略

3.3.3 壓測配置

3.3.4 實時監控

3.3.5 從瀏覽器請求測驗

4、熱點規則限流

何為熱點？熱點即經常訪問的資料，很多時候我們希望統計某個熱點資料中訪問頻次最高的資料，并對其訪問進行限制，

熱點引數限流會統計傳入引數中的熱點引數，并根據配置的限流閾值與模式，對包含熱點引數的資源呼叫進行限流，熱點引數限流可以看做是一種特殊的流量控制，僅對包含熱點引數的資源呼叫生效

4.1 單機閾值

單機閾值： 針對所有引數的值進行設定的一個公共的閾值

  1. 假設當前 引數 大部分的值都是熱點流量， 單機閾值就是針對熱點流量進行設定， 額外針對普通流量進行引數值流控；
  2. 假設當前 引數 大部分的值都是普通流量， 單機閾值就是針對普通流量進行設定， 額外針對熱點流量進行引數值流控

配置熱點引數規則：

資源名必須是@SentinelResource(value="https://www.cnblogs.com/xiaoqigui/p/資源名")中 配置的資源名，熱點規則依賴于注解；

單獨指定引數例外的引數具體值，必須是指定的7種資料型別才會生效；

4.1.1 模擬 單機閾值請求

/**
* @param : [sentinelDesc]
* @return : java.lang.String
* @author : huayu
* @date : 26/11/2022
* @description : 測驗 Sentinel-熱點
*/
@GetMapping("testSentinelHotParam")
@SentinelResource(value = "https://www.cnblogs.com/xiaoqigui/p/sentinelHotParam", blockHandlerClass = MySentinelHotBlockExceptionHandler.class, blockHandler = "hotBlockExceptionHandle")
//熱點引數，必須使用此注解，指定資源名
//注意使用此注解無法處理BlockExecption,會導致統一例外處理失效
public String testSentinelHotParam(@RequestParam String sentinelDesc) {

    log.info("------ testSentinelHotParam 介面呼叫 ------ ");

    return sentinelDesc;
}

4.1.2注意使用此注解無法處理BlockExecption,會導致統一例外處理失效

4.1.2.1 方法一：類內處理方法
@GetMapping("testSentinelHotParam")
@SentinelResource(value = "https://www.cnblogs.com/xiaoqigui/p/sentinelHotParam",blockHandler = "hotBlockExceptionHandle")
//熱點引數，必須使用此注解，指定資源名
//注意使用此注解無法處理BlockExecption,會導致統一例外處理失效
public String testSentinelHotParam(@RequestParam String sentinelDesc) {
    log.info("------ testSentinelHotParam 介面呼叫 ------ ");
    return sentinelDesc;
}



/**
* @author : huayu
* @date   : 26/11/2022
* @param  : [sentinelDesc, e]
* @return : java.lang.String
* @description : 類內處理方法  增加一個自定義處理方法，引數必須跟入口一致
*/
public String hotBlockExceptionHandle(@RequestParam String sentinelDesc, BlockException e){
    //記錄例外日志
    log.warn("------ hotBlockExceptionHandle 規則Rule：{} ------", e.getRule());
    return JSON.toJSONString(ResultBuildUtil.fail("9623", "熱點引數限流")) ;

}
4.1.2.2 方法二：單獨處理類
@GetMapping("testSentinelHotParam")
@SentinelResource(value = "https://www.cnblogs.com/xiaoqigui/p/sentinelHotParam", blockHandlerClass = MySentinelHotBlockExceptionHandler.class, blockHandler = "hotBlockExceptionHandle")
//熱點引數，必須使用此注解，指定資源名
//注意使用此注解無法處理BlockExecption,會導致統一例外處理失效
public String testSentinelHotParam(@RequestParam String sentinelDesc) {

    log.info("------ testSentinelHotParam 介面呼叫 ------ ");

    return sentinelDesc;
}


//==========處理類
/**
 * Created On : 26/11/2022.
 * <p>
 * Author : huayu
 * <p>
 * Description: 方式2 自定義熱點引數限流處理例外并指定治理方法
 */
@Slf4j
public class MySentinelHotBlockExceptionHandler {

    /**
     * @param : [sentinelDesc, e]
     * @return : java.lang.String
     * @author : huayu
     * @date : 26/11/2022
     * @description : hotBlockExceptionHandle  方法 必須是 靜態的  增加一個自定義處理方法，引數必須跟入口一致
     */
    public static String hotBlockExceptionHandle(@RequestParam String sentinelDesc, BlockException e) {
        //記錄例外日志
        log.warn("------ hotBlockExceptionHandle 規則Rule：{} ------", e.getRule());
        return JSON.toJSONString(ResultBuildUtil.fail("9623", "熱點引數限流"));

    }


}

4.1.3 熱點引數策略和規則(sentinelHotParam)

4.1.4 瀏覽器快速請求測驗

5、授權規則限流

根據呼叫來源來判斷該次請求是否允許放行，這時候可以使用 Sentinel 的來源訪問控制的功能，

來源訪問控制根據資源的請求來源（origin）限制資源是否通過：

  • 若配置白名單，則只有請求來源位于白名單內時才可通過；
  • 若配置黑名單，則請求來源位于黑名單時不通過，其余的請求通過，

配置項：

  • 資源名resource，即限流規則的作用物件
  • 流控應用limitApp，對應的黑名單/白名單，不同 origin 用 , 分隔，如 appA,appB
    • Sentinel提供了 RequestOriginParser 介面來處理來源
    • 只要Sentinel保護的介面資源被訪問，Sentinel就會呼叫 RequestOriginParser 的實作類去決議訪問來源，
  • 限制模式strategy，AUTHORITY_WHITE 為白名單模式，AUTHORITY_BLACK 為黑名單模式，默認為白名單模式

5.1 自定義來源處理規則

/**
 * Created On : 26/11/2022.
 * <p>
 * Author : huayu
 * <p>
 * Description: 自定義授權規則決議 來源 處理類
 */
@Component
public class MySentinelAuthRequestOriginParser implements RequestOriginParser {


    @Override
    public String parseOrigin(HttpServletRequest httpServletRequest) {

        // TODO 實際應用場景中，可以根據請求來源ip,進行ip限制
        //模擬，通過請求引數中，是否攜帶了自定義的來源引數OriginAuth
        //根據授權規則中的流控應用規則指定的引數串列，限制是否可以訪問
        //授權規則，指定白名單，就代表請求攜帶的引數OriginAuth,引數值必須是在流控應用指定的引數串列中，才可以訪問，否者不允許
        //黑名單相反
        return httpServletRequest.getParameter("originAuth");
    }


}

5.2 模擬授權請求

/**
* @param : [sentinelDesc]
* @return : java.lang.String
* @author : huayu
* @date : 26/11/2022
* @description : 測驗 Sentinel-授權
*/
@GetMapping("testSentinelAuth")
public String testSentinelAuth(@RequestParam String sentinelDesc,
                               @RequestParam String originAuth) {

    log.info("------ testSentinelHotParam 介面呼叫 ------ ");

    return "sentinelDesc:" + sentinelDesc + "\n,originAuth:" + originAuth;
}

5.3 白名單

5.3.1 配置白名單

5.3.2 測驗

5.4黑名單

5.4.1 配置黑名單

5.4.2 測驗

6、系統規則限流

系統保護規則是從應用級別的入口流量進行控制，從單臺機器的總體 Load、RT、入口 QPS 、CPU使用
率和執行緒數五個維度監控應用資料，讓系統盡可能跑在最大吞吐量的同時保證系統整體的穩定性，系統
保護規則是應用整體維度的，而不是資源維度的，并且僅對入口流量 (進入應用的流量) 生效，

  • Load 自適應（僅對 Linux/Unix-like 機器生效）：系統的 load1 作為啟發指標，進行自適應系統保護，當系統load1 超過設定的啟發值，且系統當前的并發執行緒數超過估算的系統容量時才會觸發系統保護，系統容量由系統的 maxQps * minRt 估算得出，設定參考值一般是 CPU cores * 2.5，
  • CPU usage（1.5.0+ 版本）：當系統 CPU 使用率超過閾值即觸發系統保護（取值范圍 0.0- - 1.0），比較靈敏，
  • 平均 RT：當單臺機器上所有入口流量的平均 RT 達到閾值即觸發系統保護，單位是毫秒，
  • 并發執行緒數：當單臺機器上所有入口流量的并發執行緒數達到閾值即觸發系統保護，
  • 入口 QPS：當單臺機器上所有入口流量的 QPS 達到閾值即觸發系統保護

6.1 模擬系統限流請求

/**
* @param : [sentinelDesc]
* @return : java.lang.String
* @author : huayu
* @date : 26/11/2022
* @description : 測驗 Sentinel-系統
* //設定一個， 全部請求都受限制
*/
@GetMapping("testSentinelSys")
public String testSentinelSys(@RequestParam String sentinelDesc) {

    log.info("------ testSentinelHotParam 介面呼叫 ------ ");

    return "sentinelDesc:" + sentinelDesc;
}

6.2 系統規則配置

6.3 壓測配置

6.4 瀏覽器測驗

7、Sentinel 規則持久化

Dashboard控制臺來為每個Sentinel客戶端設定各種各樣的規則，但是這里有一個問題，就是這些規則默認是存放在記憶體中，每次微服務重新啟動，設定的各種規則都會消失，

7.1 方式1：本地檔案（測驗，線上不推薦）

本地檔案資料源會定時輪詢檔案的變更，讀取規則，這樣我們既可以在應用本地直接修改檔案來更新規則，也可以通過 Sentinel 控制臺推送規則，

原理：首先 Sentinel 控制臺通過 API 將規則推送至客戶端并更新到記憶體中，接著注冊的寫資料源會將新的規則保存到本地的檔案中，

7.1.1 配置類

創建配置類： SentinelFilePersistence

點擊查看代碼 
import com.alibaba.csp.sentinel.command.handler.ModifyParamFlowRulesCommandHandler;
import com.alibaba.csp.sentinel.datasource.*;
import com.alibaba.csp.sentinel.init.InitFunc;
import com.alibaba.csp.sentinel.slots.block.authority.AuthorityRule;
import com.alibaba.csp.sentinel.slots.block.authority.AuthorityRuleManager;
import com.alibaba.csp.sentinel.slots.block.degrade.DegradeRule;
import com.alibaba.csp.sentinel.slots.block.degrade.DegradeRuleManager;
import com.alibaba.csp.sentinel.slots.block.flow.FlowRule;
import com.alibaba.csp.sentinel.slots.block.flow.FlowRuleManager;
import com.alibaba.csp.sentinel.slots.block.flow.param.ParamFlowRule;
import com.alibaba.csp.sentinel.slots.block.flow.param.ParamFlowRuleManager;
import com.alibaba.csp.sentinel.slots.system.SystemRule;
import com.alibaba.csp.sentinel.slots.system.SystemRuleManager;
import com.alibaba.csp.sentinel.transport.util.WritableDataSourceRegistry;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.TypeReference;
import lombok.extern.slf4j.Slf4j;

import java.io.File;
import java.io.IOException;
import java.util.List;

/**
 * Created On : 26/11/2022.
 * <p>
 * Author : huayu
 * <p>
 * Description: MySentinelRulePersistenceDunc
 */
public class MySentinelRulePersistencefunc implements InitFunc{

//    String ruleDir = System.getProperty("user.home") + "/sentinel/rules/";
    //填寫 規則存放的絕對路徑
    String ruleDir = "D:/KEGONGCHANG/DaiMa/IDEA/KH96/SpringCloud/springcloud-alibaba-96/kgcmall96-sentinel/sentinel/rules/";
//    String ruleDir = "/kgcmall96-sentinel/sentinel/rules/";

    String flowRulePath = ruleDir + "/flow-rule.json";
    String degradeRulePath = ruleDir + "/degrade-rule.json";
    String systemRulePath = ruleDir + "/system-rule.json";
    String authorityRulePath = ruleDir + "/authority-rule.json";
    String paramFlowRulePath = ruleDir + "/param-flow-rule.json";

    @Override
    public void init() throws Exception {

        // 創建規則存放目錄
        this.mkdirIfNotExits(ruleDir);

        // 創建規則存放檔案
        this.createFileIfNotExits(flowRulePath);
        this.createFileIfNotExits(degradeRulePath);
        this.createFileIfNotExits(systemRulePath);
        this.createFileIfNotExits(authorityRulePath);
        this.createFileIfNotExits(paramFlowRulePath);


        // 注冊一個可讀資料源，用來定時讀取本地的json檔案，更新到規則快取中
        // 流控規則
        ReadableDataSource<String, List<FlowRule>> flowRuleRDS =
                new FileRefreshableDataSource<>(flowRulePath, flowRuleListParser);

        // 將可讀資料源注冊至FlowRuleManager，這樣當規則檔案發生變化時，就會更新規則到記憶體
        FlowRuleManager.register2Property(flowRuleRDS.getProperty());
        WritableDataSource<List<FlowRule>> flowRuleWDS = new FileWritableDataSource<>(
                flowRulePath,
                this::encodeJson
        );

        // 將可寫資料源注冊至transport模塊的WritableDataSourceRegistry中
        // 這樣收到控制臺推送的規則時，Sentinel會先更新到記憶體，然后將規則寫入到檔案中
        WritableDataSourceRegistry.registerFlowDataSource(flowRuleWDS);

        // 降級規則
        ReadableDataSource<String, List<DegradeRule>> degradeRuleRDS = new FileRefreshableDataSource<>(
                degradeRulePath,
                degradeRuleListParser
        );
        DegradeRuleManager.register2Property(degradeRuleRDS.getProperty());
        WritableDataSource<List<DegradeRule>> degradeRuleWDS = new FileWritableDataSource<>(
                degradeRulePath,
                this::encodeJson
        );
        WritableDataSourceRegistry.registerDegradeDataSource(degradeRuleWDS);

        // 系統規則
        ReadableDataSource<String, List<SystemRule>> systemRuleRDS = new FileRefreshableDataSource<>(
                systemRulePath,
                systemRuleListParser
        );
        SystemRuleManager.register2Property(systemRuleRDS.getProperty());
        WritableDataSource<List<SystemRule>> systemRuleWDS = new FileWritableDataSource<>(
                systemRulePath,
                this::encodeJson
        );
        WritableDataSourceRegistry.registerSystemDataSource(systemRuleWDS);

        // 授權規則
        ReadableDataSource<String, List<AuthorityRule>> authorityRuleRDS = new FileRefreshableDataSource<>(
                authorityRulePath,
                authorityRuleListParser
        );
        AuthorityRuleManager.register2Property(authorityRuleRDS.getProperty());
        WritableDataSource<List<AuthorityRule>> authorityRuleWDS = new FileWritableDataSource<>(
                authorityRulePath,
                this::encodeJson
        );
        WritableDataSourceRegistry.registerAuthorityDataSource(authorityRuleWDS);

        // 熱點引數規則
        ReadableDataSource<String, List<ParamFlowRule>> paramFlowRuleRDS = new FileRefreshableDataSource<>(
                paramFlowRulePath,
                paramFlowRuleListParser
        );
        ParamFlowRuleManager.register2Property(paramFlowRuleRDS.getProperty());
        WritableDataSource<List<ParamFlowRule>> paramFlowRuleWDS = new FileWritableDataSource<>(
                paramFlowRulePath,
                this::encodeJson
        );
        ModifyParamFlowRulesCommandHandler.setWritableDataSource(paramFlowRuleWDS);

    }

        private Converter<String, List<FlowRule>> flowRuleListParser = source -> JSON.parseObject(
                source,
                new TypeReference<List<FlowRule>>() {
                }
        );
        private Converter<String, List<DegradeRule>> degradeRuleListParser = source -> JSON.parseObject(
                source,
                new TypeReference<List<DegradeRule>>() {
                }
        );
        private Converter<String, List<SystemRule>> systemRuleListParser = source -> JSON.parseObject(
                source,
                new TypeReference<List<SystemRule>>() {
                }
        );

        private Converter<String, List<AuthorityRule>> authorityRuleListParser = source -> JSON.parseObject(
                source,
                new TypeReference<List<AuthorityRule>>() {
                }
        );

        private Converter<String, List<ParamFlowRule>> paramFlowRuleListParser = source -> JSON.parseObject(
                source,
                new TypeReference<List<ParamFlowRule>>() {
                }
        );

        private void mkdirIfNotExits(String filePath) throws IOException {
            File file = new File(filePath);
            if (!file.exists()) {
                file.mkdirs();
            }
        }

        private void createFileIfNotExits(String filePath) throws IOException {
            File file = new File(filePath);
            if (!file.exists()) {
                file.createNewFile();
            }
        }

        private <T> String encodeJson(T t) {
            return JSON.toJSONString(t);
        }

}

7.1.2 InitFunc 檔案

在resources檔案下創建META-INF/services檔案夾；

創建檔案com.alibaba.csp.sentinel.init.InitFunc，檔案名就是配置類實作介面的全類名；

在檔案中添加第一步配置類的全類名即可；

測驗：啟動服務，當訪問系統規則限流介面，自動創建目錄和檔案，添加規則后，重啟服務，剛進來，之前的配置看不到，必須先訪問對應的入口才可以，要注意

com.kgc.scda.config.MySentinelRulePersistencefunc

8、Openfeign 遠程呼叫

8.1 依賴

<!--    openfeign 遠程呼叫    -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-openfeign</artifactId>
    <version>2.1.1.RELEASE</version>
</dependency>

8.2 配置

# 整合Sentinel 和OpenFeign ,默認關閉
feign:
  sentinel:
    enabled: true  #開啟

8.3 注解

著啟動類： @EnableFeignClients

介面：@FeignClient(value = "https://www.cnblogs.com/xiaoqigui/p/服務名")

8.4 測驗 (與單獨使用Openfeign一樣不在贅述)

9、GateWay 服務網關

9.1 依賴

<!--  Gatway 網關會和springMvc沖突，不能添加web依賴      -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter</artifactId>
</dependency>

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

9.2 配置

# 埠
server:
  port: 9606

# 服務名
spring:
  application:
    name: kgcmall-gatway

  cloud:
    #nacos 配置
    nacos:
      discovery:
        server-addr: 127.0.0.1:8848

    # 網關配置
    gateway:
      routes: # 路由，是list集合，可以配置多個路由
      	#product模塊
        - id: kh96_route_first # 當前route路由的唯一標識，不能重復
          #uri: http://localhost:9602 # 路由轉發的目標資源地址，不支持多負載呼叫，不利于擴展，不推薦
          uri: lb://kgcmall96-prod # lb 從nacos注冊中心的服務串列中，根據指定的服務名，呼叫服務，推薦用法
          predicates: # 指定路由斷言配置，支持多個斷言，只要斷言成功（滿足路由轉發條件），才會執行轉發到目標資源地址訪問
            - Path=/prod-gateway/** # 指定path路徑斷言，必須滿足請求地址是/prod-gateway開始，才會執行路由轉發
          filters: # 指定路由過濾配置，支持多個過濾器，在斷言成功，執行路由轉發時，對請求和回應資料進行過濾處理
            - StripPrefix=1 # 在請求斷言成功后，執行路由轉發時，自動去除第一層的訪問路徑/prod-gateway
        #user模塊
        - id: kh96_route_second
          uri: lb://kgcmall96-user
          predicates:
            - Path=/user-gateway/**
          filters:
            - StripPrefix=1

9.3 測驗

9.3.1 nacos

9.3.2 請求測驗

9.3.2.1 通過gateway網關呼叫prod模塊

9.3.2.1 通過gateway網關呼叫user模塊




轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/538581.html

標籤：Java

上一篇：Python: 你所不知道的星號 * 用法

下一篇：大趨智能列印機java api

標籤雲
其他(157675) Python(38076) JavaScript(25376) Java(17977) C(15215) 區塊鏈(8255) C＃(7972) AI(7469) 爪哇(7425) MySQL(7132) html(6777) 基礎類(6313) sql(6102) 熊猫(6058) PHP(5869) 数组(5741) R(5409) Linux(5327) 反应(5209) 腳本語言(PerlPython)(5129) 非技術區(4971) Android(4554) 数据框(4311) css(4259) 节点.js(4032) C語言(3288) json(3245) 列表(3129) 扑(3119) C++語言(3117) 安卓(2998) 打字稿(2995) VBA(2789) Java相關(2746) 疑難問題(2699) 细绳(2522) 單片機工控(2479) iOS(2429) ASP.NET(2402) MongoDB(2323) 麻木的(2285) 正则表达式(2254) 字典(2211) 循环(2198) 迅速(2185) 擅长(2169) 镖(2155) 功能(1967) .NET技术(1958) Web開發(1951) python-3.x(1918) HtmlCss(1915) 弹簧靴(1913) C++(1909) xml(1889) PostgreSQL(1872) .NETCore(1853) 谷歌表格(1846) Unity3D(1843) for循环(1842)

熱門瀏覽
  • 【C++】Microsoft C++、C 和匯編程式檔案

    ......

    uj5u.com 2020-09-10 00:57:23 more
  • 例外宣告

    相比于斷言適用于排除邏輯上不可能存在的狀態，例外通常是用于邏輯上可能發生的錯誤。 例外宣告 Item 1：當函式不可能拋出例外或不能接受拋出例外時，使用noexcept 理由 如果不打算拋出例外的話，程式就會認為無法處理這種錯誤，并且應當盡早終止，如此可以有效地阻止例外的傳播與擴散。 示例 //不可 ......

    uj5u.com 2020-09-10 00:57:27 more
  • Codeforces 1400E Clear the Multiset(貪心 + 分治)

    鏈接：https://codeforces.com/problemset/problem/1400/E 來源：Codeforces 思路：給你一個陣列，現在你可以進行兩種操作，操作1：將一段沒有 0 的區間進行減一的操作，操作2：將 i 位置上的元素歸零。最終問：將這個陣列的全部元素歸零后操作的最少 ......

    uj5u.com 2020-09-10 00:57:30 more
  • UVA11610 【Reverse Prime】

    本人看到此題沒有翻譯，就附帶了一個自己的翻譯版本 思考 這一題，它的第一個要求是找出所有 $7$ 位反向質數及其質因數的個數。 我們應該需要質數篩篩選1~$10^{7}$的所有數，這里就不慢慢介紹了。但是，重讀題，我們突然發現反向質數都是 $7$ 位，而將它反過來后的數字卻是 $6$ 位數，這就說明 ......

    uj5u.com 2020-09-10 00:57:36 more
  • 統計區間素數數量

    1 #pragma GCC optimize(2) 2 #include <bits/stdc++.h> 3 using namespace std; 4 bool isprime[1000000010]; 5 vector<int> prime; 6 inline int getlist(int ......

    uj5u.com 2020-09-10 00:57:47 more
  • C/C++編程筆記：C++中的 const 變數詳解，教你正確認識const用法

    1、C中的const 1、區域const變數存放在堆疊區中，會分配記憶體（也就是說可以通過地址間接修改變數的值）。測驗代碼如下： 運行結果： 2、全域const變數存放在只讀資料段（不能通過地址修改，會發生寫入錯誤）， 默認為外部聯編，可以給其他源檔案使用（需要用extern關鍵字修飾） 運行結果： ......

    uj5u.com 2020-09-10 00:58:04 more
  • 【C++犯錯記錄】VS2019 MFC添加資源不懂如何修改資源宏ID

    1. 首先在資源視圖中，添加資源 2. 點擊新添加的資源，復制自動生成的ID 3. 在解決方案資源管理器中找到Resource.h檔案，編輯，使用整個專案搜索和替換的方式快速替換 宏宣告 4. Ctrl+Shift+F 全域搜索，點擊查找全部，然后逐個替換 5. 為什么使用搜索替換而不使用屬性視窗直 ......

    uj5u.com 2020-09-10 00:59:11 more
  • 【C++犯錯記錄】VS2019 MFC不懂的批量添加資源

    1. 打開資源頭檔案Resource.h，在其中預先定義好宏 ID（不清楚其實ID值應該設定多少，可以先新建一個相同的資源項，再在這個資源的ID值的基礎上遞增即可） 2. 在資源視圖中選中專案資源，按F7編輯資源檔案，按 ID 型別 相對路徑的形式添加 資源。（別忘了先把檔案拷貝到專案中的res檔案 ......

    uj5u.com 2020-09-10 01:00:19 more
  • C/C++編程筆記：關于C++的參考型別，專供新手入門使用

    今天要講的是C++中我最喜歡的一個用法——參考，也叫別名。 參考就是給一個變數名取一個變數名，方便我們間接地使用這個變數。我們可以給一個變數創建N個參考，這N + 1個變數共享了同一塊記憶體區域。(參考型別的變數會占用記憶體空間，占用的記憶體空間的大小和指標型別的大小是相同的。雖然參考是一個物件的別名，但 ......

    uj5u.com 2020-09-10 01:00:22 more
  • 【C/C++編程筆記】從頭開始學習C ++：初學者完整指南

    眾所周知，C ++的學習曲線陡峭，但是花時間學習這種語言將為您的職業帶來奇跡，并使您與其他開發人員區分開。您會更輕松地學習新語言，形成真正的解決問題的技能，并在編程的基礎上打下堅實的基礎。 C ++將幫助您養成良好的編程習慣（即清晰一致的編碼風格，在撰寫代碼時注釋代碼，并限制類內部的可見性），并且由 ......

    uj5u.com 2020-09-10 01:00:41 more
最新发布
  • Rust中的智能指標:Box<T> Rc<T> Arc<T> Cell<T> RefCell<T> Weak

    Rust中的智能指標是什么 智能指標（smart pointers）是一類資料結構，是擁有資料所有權和額外功能的指標。是指標的進一步發展 指標（pointer）是一個包含記憶體地址的變數的通用概念。這個地址參考，或 ” 指向”（points at）一些其 他資料 。參考以 & 符號為標志并借用了他們所 ......

    uj5u.com 2023-04-20 07:24:10 more
  • Java的值傳遞和參考傳遞

    值傳遞不會改變本身，參考傳遞（如果傳遞的值需要實體化到堆里）如果發生修改了會改變本身。 1.基本資料型別都是值傳遞 package com.example.basic; public class Test { public static void main(String[] args) { int ......

    uj5u.com 2023-04-20 07:24:04 more
  • [2]SpinalHDL教程——Scala簡單入門

    第一個 Scala 程式 shell里面輸入 $ scala scala> 1 + 1 res0: Int = 2 scala> println("Hello World!") Hello World! 檔案形式 object HelloWorld { /* 這是我的第一個 Scala 程式 * 以 ......

    uj5u.com 2023-04-20 07:23:58 more
  • 理解函式指標和回呼函式

    理解 函式指標 指向函式的指標。比如： 理解函式指標的偽代碼 void (*p)(int type, char *data); // 定義一個函式指標p void func(int type, char *data); // 宣告一個函式func p = func; // 將指標p指向函式func ......

    uj5u.com 2023-04-20 07:23:52 more
  • Django筆記二十五之資料庫函式之日期函式

    本文首發于公眾號：Hunter后端 原文鏈接：Django筆記二十五之資料庫函式之日期函式 日期函式主要介紹兩個大類，Extract() 和 Trunc() Extract() 函式作用是提取日期，比如我們可以提取一個日期欄位的年份，月份，日等資料 Trunc() 的作用則是截取，比如 2022-0 ......

    uj5u.com 2023-04-20 07:23:45 more
  • 一天吃透JVM面試八股文

    什么是JVM？ JVM，全稱Java Virtual Machine（Java虛擬機），是通過在實際的計算機上仿真模擬各種計算機功能來實作的。由一套位元組碼指令集、一組暫存器、一個堆疊、一個垃圾回收堆和一個存盤方法域等組成。JVM屏蔽了與作業系統平臺相關的資訊，使得Java程式只需要生成在Java虛擬機 ......

    uj5u.com 2023-04-20 07:23:31 more
  • 使用Java接入小程式訂閱訊息！

    更新完微信服務號的模板訊息之后，我又趕緊把微信小程式的訂閱訊息給實作了！之前我一直以為微信小程式也是要企業才能申請，沒想到小程式個人就能申請。 訊息推送平臺🔥推送下發【郵件】【短信】【微信服務號】【微信小程式】【企業微信】【釘釘】等訊息型別。 https://gitee.com/zhongfuch ......

    uj5u.com 2023-04-20 07:22:59 more
  • java -- 緩沖流、轉換流、序列化流

    緩沖流 緩沖流, 也叫高效流, 按照資料型別分類： 位元組緩沖流：BufferedInputStream，BufferedOutputStream 字符緩沖流：BufferedReader，BufferedWriter 緩沖流的基本原理，是在創建流物件時，會創建一個內置的默認大小的緩沖區陣列，通過緩沖 ......

    uj5u.com 2023-04-20 07:22:49 more
  • Java-SpringBoot-Range請求頭設定實作視頻分段傳輸

    老實說，人太懶了，現在基本都不喜歡寫筆記了，但是網上有關Range請求頭的文章都太水了 下面是抄的一段StackOverflow的代碼...自己大修改過的，寫的注釋挺全的，應該直接看得懂，就不解釋了 寫的不好...只是希望能給視頻網站開發的新手一點點幫助吧. 業務場景：視頻分段傳輸、視頻多段傳輸（理 ......

    uj5u.com 2023-04-20 07:22:42 more
  • Windows 10開發教程_編程入門自學教程_菜鳥教程-免費教程分享

    教程簡介 Windows 10開發入門教程 - 從簡單的步驟了解Windows 10開發，從基本到高級概念，包括簡介，UWP，第一個應用程式，商店，XAML控制元件，資料系結，XAML性能，自適應設計，自適應UI，自適應代碼，檔案管理，SQLite資料庫，應用程式到應用程式通信，應用程式本地化，應用程式 ......

    uj5u.com 2023-04-20 07:22:35 more

Copyright © 2010-2020 有解無憂