Spring Cloud Gateway基于服务发现Hystrix配置

2022-12-14 03:19| 来源: 网络整理| 查看: 265

适用版本 spring cloud gateway 2.0.0 及以上之前的版本我没使用过，说不定可以行。最初我们用的是这种配置方式

spring.cloud.gateway.default-filters[1].name=Hystrix spring.cloud.gateway.default-filters[1].args.name=fallbackcmd spring.cloud.gateway.default-filters[1].args.fallbackUri=forward:/fallback

并且我们并没有给每一个服务单独配置路由而是使用了服务发现自动注册路由的方式也就是通过

spring.cloud.gateway.discovery.locator.enabled=true

这样配置会涉及到一个很严重的问题那就是所有服务公用一个熔断 fallbackcmd 这会导致当一个子服务熔断后，所有服务都被熔断了。整个集群都不可用了。

这时我们应该怎么办第一为每个服务单独配置一个route 在这个route的filters里配置hystrix

spring.cloud.gateway.routes[8].id = dsd spring.cloud.gateway.routes[8].uri = lb://TEST-DEMO2 spring.cloud.gateway.routes[8].predicates[0].name = Path spring.cloud.gateway.routes[8].predicates[0].args[pattern] = /TEST-DEMO2/test/** spring.cloud.gateway.routes[8].filters[0].name = Hystrix spring.cloud.gateway.routes[8].filters[0].args.name = fallbackcmd spring.cloud.gateway.routes[8].filters[0].args.fallbackUri = forward:/fallback spring.cloud.gateway.routes[8].filters[1] = StripPrefix=1 spring.cloud.gateway.routes[8].order = -2

这样在兼容原有调用方式的同时添加了熔断机制，并且只对该服务生效

但我们几十个服务都要配这个，并且人工还可能出现遗漏。这时我去翻看了spring cloud gateway 的最新文档发现可以在discovery 里配置 filter 或者 predicates 于是我尝试使用这个配置

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: Hystrix 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}'"

加上之后发现我的服务都没法调用了这时跟进源码 org.springframework.cloud.gateway.discovery.DiscoveryLocatorProperties 在这两个地方debug 这是他默认添加的这两张是我们手动添加后的这里发现他给的示例配置中多了“号去掉

spring.cloud.gateway.discovery.locator.predicates[0].name: Path spring.cloud.gateway.discovery.locator.predicates[0].args[pattern]: '/'+serviceId+'/**' spring.cloud.gateway.discovery.locator.filters[0].name: Hystrix 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}'

变成这样此时启动服务就能按照原先方式调用了，并且他为每个服务添加了一个 hystrix 但是org.springframework.cloud.gateway.discovery.DiscoveryClientRouteDefinitionLocator中

@Override public Flux getRouteDefinitions() { SpelExpressionParser parser = new SpelExpressionParser(); Expression includeExpr = parser .parseExpression(properties.getIncludeExpression()); Expression urlExpr = parser.parseExpression(properties.getUrlExpression()); Predicate includePredicate; if (properties.getIncludeExpression() == null || "true".equalsIgnoreCase(properties.getIncludeExpression())) { includePredicate = instance -> true; } else { includePredicate = instance -> { Boolean include = includeExpr.getValue(evalCtxt, instance, Boolean.class); if (include == null) { return false; } return include; }; } return Flux.fromIterable(discoveryClient.getServices()) .map(discoveryClient::getInstances) .filter(instances -> !instances.isEmpty()) .map(instances -> instances.get(0)).filter(includePredicate) .map(instance -> { String serviceId = instance.getServiceId(); RouteDefinition routeDefinition = new RouteDefinition(); routeDefinition.setId(this.routeIdPrefix + serviceId); String uri = urlExpr.getValue(evalCtxt, instance, String.class); routeDefinition.setUri(URI.create(uri)); final ServiceInstance instanceForEval = new DelegatingServiceInstance( instance, properties); for (PredicateDefinition original : this.properties.getPredicates()) { PredicateDefinition predicate = new PredicateDefinition(); predicate.setName(original.getName()); for (Map.Entry entry : original.getArgs() .entrySet()) { String value = getValueFromExpr(evalCtxt, parser, instanceForEval, entry); predicate.addArg(entry.getKey(), value); } routeDefinition.getPredicates().add(predicate); } // 注意这里他set了Name for (FilterDefinition original : this.properties.getFilters()) { FilterDefinition filter = new FilterDefinition(); filter.setName(original.getName()); // 这里就是参数的值他使用el表达式读取值，如果你想添加一个字符串进来前后加'即可 for (Map.Entry entry : original.getArgs() .entrySet()) { String value = getValueFromExpr(evalCtxt, parser, instanceForEval, entry); filter.addArg(entry.getKey(), value); } routeDefinition.getFilters().add(filter); } return routeDefinition; }); }

最终在这读取到的route 就是如下，我还没找到怎么给他们设置fallbackUri的方式至此我们为每个服务添加了一个默认的hystrix 对于有特殊需求的服务来说可以像我上面单独配置route的方式配置，只要order < 0 就不会匹配到这里，这样我们就可以实现fallbackUrl 并且转到备用服务上如何操作可以参见https://cloud.spring.io/spring-cloud-static/spring-cloud-gateway/2.2.0.M3/reference/html/#hystrix

spring: cloud: gateway: routes: - id: ingredients uri: lb://ingredients predicates: - Path=//ingredients/** filters: - name: Hystrix args: name: fetchIngredients fallbackUri: forward:/fallback - id: ingredients-fallback uri: http://localhost:9994 predicates: - Path=/fallback

上面的配置如果发生了熔断会一直报错，所有我们尝试统一加上fallbackUri 添加了’forward:/fallback’ 不会被识别为el 就能够添加fallbackUri地址了

spring.cloud.gateway.discovery.locator.predicates[0].name=Path spring.cloud.gateway.discovery.locator.predicates[0].args[pattern]= '/'+serviceId+'/**' spring.cloud.gateway.discovery.locator.filters[0].name= RewritePath spring.cloud.gateway.discovery.locator.filters[0].args[regexp]= '/' + serviceId + '/(?.*)' spring.cloud.gateway.discovery.locator.filters[0].args[replacement]='/${remaining}' spring.cloud.gateway.discovery.locator.filters[1].name= Hystrix spring.cloud.gateway.discovery.locator.filters[1].args[name]= serviceId spring.cloud.gateway.discovery.locator.filters[1].args[fallbackUri]= 'forward:/fallback'

【本文地址】

公司简介

联系我们