国产xxxx99真实实拍_久久不雅视频_高清韩国a级特黄毛片_嗯老师别我我受不了了小说

資訊專欄INFORMATION COLUMN

阿里Sentinel支持Spring Cloud Gateway啦

chengtao1633 / 844人閱讀

摘要:應對突發(fā)請求時額外允許的請求數(shù)目。勻速排隊模式下的最長排隊時間,單位是毫秒,僅在勻速排隊模式下生效。和為后續(xù)參數(shù)匹配特性預留,目前未實現(xiàn)。

1. 前言

4月25號,Sentinel 1.6.0 正式發(fā)布,帶來 Spring Cloud Gateway 支持、控制臺登錄功能、改進的熱點限流和注解 fallback 等多項新特性,該出手時就出手,緊跟時代潮流,昨天剛發(fā)布,今天我就要給大家分享下如何使用!

2. 介紹(本段來自Sentinel文檔)

Sentinel 1.6.0 引入了 Sentinel API Gateway Adapter Common 模塊,此模塊中包含網關限流的規(guī)則和自定義 API 的實體和管理邏輯:

GatewayFlowRule:網關限流規(guī)則,針對 API Gateway 的場景定制的限流規(guī)則,可以針對不同 route 或自定義的 API 分組進行限流,支持針對請求中的參數(shù)、Header、來源 IP 等進行定制化的限流。

ApiDefinition:用戶自定義的 API 定義分組,可以看做是一些 URL 匹配的組合。比如我們可以定義一個 API 叫 my_api,請求 path 模式為 /foo/ 和 /baz/ 的都歸到 my_api 這個 API 分組下面。限流的時候可以針對這個自定義的 API 分組維度進行限流。

其中網關限流規(guī)則 GatewayFlowRule 的字段解釋如下:

resource:資源名稱,可以是網關中的 route 名稱或者用戶自定義的 API 分組名稱。

resourceMode:規(guī)則是針對 API Gateway 的 route(RESOURCE_MODE_ROUTE_ID)還是用戶在 Sentinel 中定義的 API 分組(RESOURCE_MODE_CUSTOM_API_NAME),默認是 route。

grade:限流指標維度,同限流規(guī)則的 grade 字段

count:限流閾值

intervalSec:統(tǒng)計時間窗口,單位是秒,默認是 1 秒

controlBehavior:流量整形的控制效果,同限流規(guī)則的 controlBehavior 字段,目前支持快速失敗和勻速排隊兩種模式,默認是快速失敗。

burst:應對突發(fā)請求時額外允許的請求數(shù)目。

maxQueueingTimeoutMs:勻速排隊模式下的最長排隊時間,單位是毫秒,僅在勻速排隊模式下生效。

paramItem:參數(shù)限流配置。若不提供,則代表不針對參數(shù)進行限流,該網關規(guī)則將會被轉換成普通流控規(guī)則;否則會轉換成熱點規(guī)則。其中的字段:

parseStrategy:從請求中提取參數(shù)的策略,目前支持提取來源 IP(PARAM_PARSE_STRATEGY_CLIENT_IP)、Host(PARAM_PARSE_STRATEGY_HOST)、任意 Header(PARAM_PARSE_STRATEGY_HEADER)和任意 URL 參數(shù)(PARAM_PARSE_STRATEGY_URL_PARAM)四種模式。

fieldName:若提取策略選擇 Header 模式或 URL 參數(shù)模式,則需要指定對應的 header 名稱或 URL 參數(shù)名稱。

pattern 和 matchStrategy:為后續(xù)參數(shù)匹配特性預留,目前未實現(xiàn)。

用戶可以通過 GatewayRuleManager.loadRules(rules) 手動加載網關規(guī)則,或通過 GatewayRuleManager.register2Property(property) 注冊動態(tài)規(guī)則源動態(tài)推送(推薦方式)。

3. 使用 3.1 快速體驗

首先你的有一個Spring Cloud Gateway的項目,如果沒有,新建一個,增加Gateway和sentinel-spring-cloud-gateway-adapter的依賴,如下:

</>復制代碼

  1. org.springframework.cloud
  2. spring-cloud-starter-gateway
  3. com.alibaba.csp
  4. sentinel-spring-cloud-gateway-adapter
  5. 1.6.0

新建一個application.yml配置文件,用來配置路由:

</>復制代碼

  1. server:
  2. port: 2001
  3. spring:
  4. application:
  5. name: spring-cloud-gateway
  6. cloud:
  7. gateway:
  8. routes:
  9. - id: path_route
  10. uri: http://cxytiandi.com
  11. predicates:
  12. - Path=/course

配置了Path路由,等會使用 http://localhost:2001/course 進行訪問即可。

增加一個GatewayConfiguration 類,用于配置Gateway限流要用到的類,目前是手動配置的方式,后面肯定是可以通過注解啟用,配置文件中指定限流規(guī)則的方式來使用,當然這部分工作會交給Spring Cloud Alibaba來做,后面肯定會發(fā)新版本的,大家耐心等待就行了。

</>復制代碼

  1. @Configuration
  2. public class GatewayConfiguration {
  3. private final List viewResolvers;
  4. private final ServerCodecConfigurer serverCodecConfigurer;
  5. public GatewayConfiguration(ObjectProvider> viewResolversProvider,
  6. ServerCodecConfigurer serverCodecConfigurer) {
  7. this.viewResolvers = viewResolversProvider.getIfAvailable(Collections::emptyList);
  8. this.serverCodecConfigurer = serverCodecConfigurer;
  9. }
  10. /**
  11. * 配置SentinelGatewayBlockExceptionHandler,限流后異常處理
  12. * @return
  13. */
  14. @Bean
  15. @Order(Ordered.HIGHEST_PRECEDENCE)
  16. public SentinelGatewayBlockExceptionHandler sentinelGatewayBlockExceptionHandler() {
  17. return new SentinelGatewayBlockExceptionHandler(viewResolvers, serverCodecConfigurer);
  18. }
  19. /**
  20. * 配置SentinelGatewayFilter
  21. * @return
  22. */
  23. @Bean
  24. @Order(-1)
  25. public GlobalFilter sentinelGatewayFilter() {
  26. return new SentinelGatewayFilter();
  27. }
  28. @PostConstruct
  29. public void doInit() {
  30. initGatewayRules();
  31. }
  32. /**
  33. * 配置限流規(guī)則
  34. */
  35. private void initGatewayRules() {
  36. Set rules = new HashSet<>();
  37. rules.add(new GatewayFlowRule("path_route")
  38. .setCount(1) // 限流閾值
  39. .setIntervalSec(1) // 統(tǒng)計時間窗口,單位是秒,默認是 1 秒
  40. );
  41. GatewayRuleManager.loadRules(rules);
  42. }
  43. }

我們定義的資源名稱是path_route,也就是application.yml中的路由ID,一致就行。

在一秒鐘內多次訪問http://localhost:2001/course就可以看到限流啟作用了。

3.2 指定參數(shù)限流

上面的配置是針對整個路由來限流的,如果我們只想對某個路由的參數(shù)做限流,那么可以使用參數(shù)限流方式:

</>復制代碼

  1. rules.add(new GatewayFlowRule("path_route")
  2. .setCount(1)
  3. .setIntervalSec(1)
  4. .setParamItem(new GatewayParamFlowItem()
  5. .setParseStrategy(SentinelGatewayConstants.PARAM_PARSE_STRATEGY_URL_PARAM).setFieldName("vipType")
  6. )
  7. );

通過指定PARAM_PARSE_STRATEGY_URL_PARAM表示從url中獲取參數(shù),setFieldName指定參數(shù)名稱

3.3 自定義API分組

假設我有下面兩個路由,我想讓這兩個路由共用一個限流規(guī)則,那么我們可以自定義進行組合:

</>復制代碼

  1. - id: path2_route
  2. uri: http://cxytiandi.com
  3. predicates:
  4. - Path=/article
  5. - id: path3_route
  6. uri: http://cxytiandi.com
  7. predicates:
  8. - Path=/blog/**

自定義分組代碼:

</>復制代碼

  1. private void initCustomizedApis() {
  2. Set definitions = new HashSet<>();
  3. ApiDefinition api1 = new ApiDefinition("customized_api")
  4. .setPredicateItems(new HashSet() {{
  5. // article完全匹配
  6. add(new ApiPathPredicateItem().setPattern("/article"));
  7. // blog/開頭的
  8. add(new ApiPathPredicateItem().setPattern("/blog/**")
  9. .setMatchStrategy(SentinelGatewayConstants.PARAM_MATCH_STRATEGY_PREFIX));
  10. }});
  11. definitions.add(api1);
  12. GatewayApiDefinitionManager.loadApiDefinitions(definitions);
  13. }

然后我們需要給customized_api這個資源進行配置:

</>復制代碼

  1. rules.add(new GatewayFlowRule("customized_api")
  2. .setCount(1)
  3. .setIntervalSec(1)
  4. );
3.4 自定義異常提示

前面我們有看到,當觸發(fā)限流后頁面顯示的是Blocked by Sentinel: FlowException,正常情況下,就算給出提示也要跟后端服務的數(shù)據(jù)格式一樣,如果你后端都是JSON格式的數(shù)據(jù),那么異常的提示也要是JSON的格式,所以問題來了,我們怎么去自定義異常的輸出?

前面我們有配置SentinelGatewayBlockExceptionHandler,我的注釋寫的限流后異常處理,我們可以進去看下源碼就知道是不是異常處理了。下面貼出核心的代碼:

</>復制代碼

  1. private Mono writeResponse(ServerResponse response, ServerWebExchange exchange) {
  2. return response.writeTo(exchange, contextSupplier.get());
  3. }
  4. @Override
  5. public Mono handle(ServerWebExchange exchange, Throwable ex) {
  6. if (exchange.getResponse().isCommitted()) {
  7. return Mono.error(ex);
  8. }
  9. // This exception handler only handles rejection by Sentinel.
  10. if (!BlockException.isBlockException(ex)) {
  11. return Mono.error(ex);
  12. }
  13. return handleBlockedRequest(exchange, ex)
  14. .flatMap(response -> writeResponse(response, exchange));
  15. }

重點在于writeResponse這個方法,我們只要把這個方法改掉,返回自己想要返回的數(shù)據(jù)就行了,可以自定義一個SentinelGatewayBlockExceptionHandler的類來實現(xiàn)。

比如:

</>復制代碼

  1. public class JsonSentinelGatewayBlockExceptionHandler implements WebExceptionHandler {
  2. // ........
  3. }

然后復制SentinelGatewayBlockExceptionHandler中的代碼到JsonSentinelGatewayBlockExceptionHandler 中,只改動writeResponse一個方法即可。

</>復制代碼

  1. private Mono writeResponse(ServerResponse response, ServerWebExchange exchange) {
  2. ServerHttpResponse serverHttpResponse = exchange.getResponse();
  3. serverHttpResponse.getHeaders().add("Content-Type", "application/json;charset=UTF-8");
  4. byte[] datas = "{"code":403,"msg":"限流了"}".getBytes(StandardCharsets.UTF_8);
  5. DataBuffer buffer = serverHttpResponse.bufferFactory().wrap(datas);
  6. return serverHttpResponse.writeWith(Mono.just(buffer));
  7. }

最后將配置的SentinelGatewayBlockExceptionHandler改成JsonSentinelGatewayBlockExceptionHandler 。

</>復制代碼

  1. @Bean
  2. @Order(Ordered.HIGHEST_PRECEDENCE)
  3. public JsonSentinelGatewayBlockExceptionHandler sentinelGatewayBlockExceptionHandler() {
  4. return new JsonSentinelGatewayBlockExceptionHandler(viewResolvers, serverCodecConfigurer);
  5. }

歡迎加入我的知識星球,一起交流技術,免費學習猿天地的課程(http://cxytiandi.com/course) PS:目前星球中正在星主的帶領下組隊學習Spring Cloud,等你哦!

文章版權歸作者所有,未經允許請勿轉載,若此文章存在違規(guī)行為,您可以聯(lián)系管理員刪除。

轉載請注明本文地址:http://m.specialneedsforspecialkids.com/yun/74315.html

相關文章

  • 阿里Sentinel整合Zuul網關詳解

    摘要:前面我們講解了整合,詳細請查看文章阿里支持啦目前來說,大部分公司線上的網關應該是,所以今天我們就來看看如何在中整合。 前面我們講解了Sentinel整合Spring Cloud Gateway,詳細請查看文章:阿里Sentinel支持Spring Cloud Gateway啦 目前來說,大部分公司線上的網關應該是Zuul,所以今天我們就來看看如何在Zuul中整合Sentinel。本來想...

    miqt 評論0 收藏0
  • Spring Cloud Gateway 擴展支持動態(tài)限流

    摘要:以流量為切入點,從流量控制熔斷降級系統(tǒng)負載保護等多個維度保護服務的穩(wěn)定性分布式系統(tǒng)的流量防衛(wèi)兵。歡迎關注我們獲得更多的好玩實踐 之前分享過 一篇 《Spring Cloud Gateway 原生的接口限流該怎么玩》, 核心是依賴Spring Cloud Gateway 默認提供的限流過濾器來實現(xiàn) 原生RequestRateLimiter 的不足 配置方式 spring: clou...

    妤鋒シ 評論0 收藏0
  • Spring Cloud Gateway 擴展支持動態(tài)限流

    摘要:以流量為切入點,從流量控制熔斷降級系統(tǒng)負載保護等多個維度保護服務的穩(wěn)定性分布式系統(tǒng)的流量防衛(wèi)兵。歡迎關注我們獲得更多的好玩實踐 之前分享過 一篇 《Spring Cloud Gateway 原生的接口限流該怎么玩》, 核心是依賴Spring Cloud Gateway 默認提供的限流過濾器來實現(xiàn) 原生RequestRateLimiter 的不足 配置方式 spring: clou...

    beanlam 評論0 收藏0
  • Sentinel: 分布式系統(tǒng)的流量防衛(wèi)兵

    摘要:有沒有那么一個框架能夠把熔斷跟限流都給做了,以前沒有,但是現(xiàn)在有了,我這屬于自問自答哈這個框架就是阿里最新開源的。后來我才發(fā)現(xiàn)我錯了,大錯特錯,這是一個新的框架,潛力實力阿里開源。 前言 在 Spring Cloud 體系中,熔斷降級我們會使用 Hystrix 框架,限流通常會在 Zuul 中進行處理,Zuul 中沒有自帶限流的功能,我們可以自己做限流或者集成第三方開源的限流框架。最新...

    jifei 評論0 收藏0

發(fā)表評論

0條評論

最新活動
閱讀需要支付1元查看
<