12. Http 超时配置
Http 超时(响应和连接)可以为所有路由配置,也可以为每个特定路由覆盖。
12.1. 全局超时
要配置全局 http 超时:
必须以毫秒为单位指定。
必须指定为 java.time.Durationconnect-timeout
response-timeout
spring:
cloud:
gateway:
httpclient:
connect-timeout: 1000
response-timeout: 5s
12.2. 每条路由超时
要配置每路由超时:
必须以毫秒为单位指定。
必须以毫秒为单位指定。connect-timeout
response-timeout
- id: per_route_timeouts
uri: https://example.org
predicates:
- name: Path
args:
pattern: /delay/{timeout}
metadata:
response-timeout: 200
connect-timeout: 200
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();
}
12.3. Fluent Java 路由 API
为了允许在 Java 中进行简单的配置,该 bean 包含一个 Fluent API。
下面的清单显示了它是如何工作的:RouteLocatorBuilder
// static imports from GatewayFilters and RoutePredicates
@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("key", "value")
)
.build();
}
这种样式还允许更多自定义谓词断言。
由 bean 定义的谓词使用 logical 进行组合。
通过使用 Fluent Java API,您可以在类上使用 、 和 运算符。RouteDefinitionLocator
and
and()
or()
negate()
Predicate
12.4. DiscoveryClient
路由定义定位器
您可以将网关配置为基于在兼容的服务注册表中注册的服务创建路由。DiscoveryClient
要启用此功能,请设置并确保实现(例如 Netflix Eureka、Consul 或 Zookeeper)位于 Classpath 上并启用。spring.cloud.gateway.discovery.locator.enabled=true
DiscoveryClient
12.4.1. 为 DiscoveryClient
路由配置 Predicates 和 Filter
默认情况下,网关为使用 .DiscoveryClient
默认谓词是使用 pattern 定义的路径谓词,其中 is
来自 ./serviceId/**
serviceId
DiscoveryClient
默认过滤器是带有 regex 和 replacement 的重写路径过滤器。
这会在将请求发送到下游之前从路径中剥离服务 ID。/serviceId/?(?<remaining>.*)
/${remaining}
如果要自定义路由使用的谓词或筛选条件,请设置 和 。
执行此操作时,如果要保留该功能,则需要确保包含前面显示的默认谓词和筛选条件。
以下示例显示了这是什么样子的:DiscoveryClient
spring.cloud.gateway.discovery.locator.predicates[x]
spring.cloud.gateway.discovery.locator.filters[y]
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 + '/?(?<remaining>.*)'" spring.cloud.gateway.discovery.locator.filters[1].args[replacement]: "'/${remaining}'"