日本综合一区二区|亚洲中文天堂综合|日韩欧美自拍一区|男女精品天堂一区|欧美自拍第6页亚洲成人精品一区|亚洲黄色天堂一区二区成人|超碰91偷拍第一页|日韩av夜夜嗨中文字幕|久久蜜综合视频官网|精美人妻一区二区三区

RELATEED CONSULTING
相關(guān)咨詢
選擇下列產(chǎn)品馬上在線溝通
服務(wù)時(shí)間:8:30-17:00
你可能遇到了下面的問題
關(guān)閉右側(cè)工具欄

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營銷解決方案
SpringCloudGateway路由元信息作用及路由超時(shí)配置詳解

環(huán)境:Spring Cloud Gateway 3.1.4

路由元信息配置

你可以使用元數(shù)據(jù)為每個(gè)路由配置其他參數(shù),如下所示:

spring:
  cloud:
    gateway:
      routes:
      - id: route_with_metadata
        uri: https://pack.com
        metadata:
          zone: "xj"
          infos:
            name: "value"
          weight: 0.2

可以通過ServerWebExchange中獲取所有元數(shù)據(jù)屬性,如下所示:

// 獲取路由對象
Route route = exchange.getAttribute(GATEWAY_ROUTE_ATTR);
// 獲取路由元信息
route.getMetadata();
// 獲取某一個(gè)元信息
route.getMetadata(someKey);

上面exchange.getAttribute方法獲取路由對象是在通過HandlerMapping對象查找路由對象時(shí)設(shè)置到當(dāng)前的上下文中的,如下:

public class RoutePredicateHandlerMapping extends AbstractHandlerMapping {
  private final FilteringWebHandler webHandler;
  public RoutePredicateHandlerMapping(FilteringWebHandler webHandler, ...) {
    this.webHandler = webHandler;
    // ...
  }
  protected Mono getHandlerInternal(ServerWebExchange exchange) {
    // 查找路由
    return lookupRoute(exchange)
      .flatMap((Function>) r -> {
        exchange.getAttributes().remove(GATEWAY_PREDICATE_ROUTE_ATTR);
        // 將查找到的路由保存到當(dāng)前的執(zhí)行上下文中
        exchange.getAttributes().put(GATEWAY_ROUTE_ATTR, r);
        return Mono.just(webHandler);
      }).switchIfEmpty(Mono.empty().then(Mono.fromRunnable(() -> {
        exchange.getAttributes().remove(GATEWAY_PREDICATE_ROUTE_ATTR);
      })));
  }
}

路由的超時(shí)配置就是通過元信息的配置來設(shè)置的,接下來就是路由超時(shí)相關(guān)的講解。

路由(http)超時(shí)配置

Http超時(shí)(響應(yīng)和連接)可以為所有路由配置,并為還可以為每個(gè)特定路由覆蓋。

  • 全局超時(shí)配置

要配置全局http超時(shí):
連接超時(shí)必須以毫秒為單位指定。
響應(yīng)超時(shí)必須指定為java.time.Duration

spring:
  cloud:
    gateway:
      httpclient:
        connect-timeout: 1000
        response-timeout: 5s
  • 每個(gè)路由配置超時(shí)

要配置每個(gè)路由超時(shí):
連接超時(shí)必須以毫秒為單位指定。
響應(yīng)超時(shí)必須以毫秒為單位指定。

- id: per_route_timeouts
  uri: https://example.org
  predicates:
  - name: Path
    args:
    pattern: /delay/{timeout}
  metadata:
    response-timeout: 200
    connect-timeout: 200

使用Java DSL的每個(gè)路由超時(shí)配置:

import static org.springframework.cloud.gateway.support.RouteMetadataUtils.CONNECT_TIMEOUT_ATTR;
import static org.springframework.cloud.gateway.support.RouteMetadataUtils.RESPONSE_TIMEOUT_ATTR;
@Bean
public RouteLocator customRouteLocator(RouteLocatorBuilder routeBuilder){
  return routeBuilder.routes()
    .route("test1", r -> {
      return r.host("*.somehost.org").and().path("/somepath")
        .filters(f -> f.addRequestHeader("header1", "header-value-1"))
        .uri("http://someuri")
        .metadata(RESPONSE_TIMEOUT_ATTR, 200)
        .metadata(CONNECT_TIMEOUT_ATTR, 200);
  })
  .build();
}

超時(shí)時(shí)間配置為負(fù)值的每條路由響應(yīng)超時(shí)將禁用全局響應(yīng)超時(shí)值。

- id: per_route_timeouts
  uri: https://example.org
  predicates:
  - name: Path
    args:
    pattern: /delay/{timeout}
  metadata:
    response-timeout: -1

流式的Java路由API

@Bean
public RouteLocator customRouteLocator(RouteLocatorBuilder builder, ThrottleGatewayFilterFactory throttle) {
  return builder.routes()
    .route(r -> r.host("**.abc.org").and().path("/image/png")
      .filters(f -> f.addResponseHeader("X-TestHeader", "foobar"))
      .uri("http://httpbin.org:80")
    )
    .route(r -> r.path("/image/webp")
      .filters(f -> f.addResponseHeader("X-AnotherHeader", "baz"))
      .uri("http://httpbin.org:80")
      .metadata("key", "value")
    )
    .route(r -> r.order(-1)
      .host("**.throttle.org").and().path("/get")
      .filters(f -> f.filter(throttle.apply(1,1,10,TimeUnit.SECONDS)))
      .uri("http://httpbin.org:80")
      .metadata("name", "pack")
    )
    .build();
}

這種風(fēng)格還允許更多的自定義謂詞斷言。RouteDefinitionLocator bean定義的謂詞使用邏輯和進(jìn)行組合。通過使用流暢的Java API,可以在Predicate類上使用and()、or()和negate()操作符。

  • DiscoveryClient路由定義定位器

你可以將網(wǎng)關(guān)配置為基于在DiscoveryClient兼容服務(wù)注冊表中注冊的服務(wù)創(chuàng)建路由。直接通過服務(wù)實(shí)例訪問路由

要啟用此功能,需要將spring.cloud.gateway.decovery.locator.enabled設(shè)置為true,并確保DiscoveryClient實(shí)現(xiàn)(如Netflix Eureka、Consul、Zookeeper或Nacos)位于類路徑上并已啟用。

默認(rèn)情況下,網(wǎng)關(guān)為使用DiscoveryClient創(chuàng)建的路由定義一個(gè)謂詞和篩選器。

默認(rèn)謂詞是使用模式/serviceId/**定義的路徑謂詞,其中serviceId是DiscoveryClient中服務(wù)的ID(注冊中心注冊的服務(wù)名稱,主要就是spring.application.name)。

默認(rèn)的過濾器是重寫路徑過濾器,regex /serviceId/?(? .*)和替換的/${remaining}。這將在請求發(fā)送到下游之前從路徑中剝離服務(wù)ID。

如果你想自定義DiscoveryClient路由使用的謂詞或過濾器,請?jiān)O(shè)置
spring.cloud.gateway.discovery.locator.predicates[x]和
spring.cloud.gateway.discovery.locator.filters[y]。這樣做時(shí),如果你希望保留該功能,則需要確保包含前面所示的默認(rèn)謂詞和過濾器。下面的例子展示了它的樣子:

spring.cloud.gateway.discovery.locator.predicates[0].name: Path
spring.cloud.gateway.discovery.locator.predicates[0].args[pattern]: "'/'+serviceId+'/**'"
spring.cloud.gateway.discovery.locator.predicates[1].name: Host
spring.cloud.gateway.discovery.locator.predicates[1].args[pattern]: "'**.foo.com'"
spring.cloud.gateway.discovery.locator.filters[0].name: CircuitBreaker
spring.cloud.gateway.discovery.locator.filters[0].args[name]: serviceId
spring.cloud.gateway.discovery.locator.filters[1].name: RewritePath
spring.cloud.gateway.discovery.locator.filters[1].args[regexp]: "'/' + serviceId + '/?(?.*)'"
spring.cloud.gateway.discovery.locator.filters[1].args[replacement]: "'/${remaining}'"

完畢?。?!


標(biāo)題名稱:SpringCloudGateway路由元信息作用及路由超時(shí)配置詳解
文章路徑:http://www.dlmjj.cn/article/ccshccj.html