如何用服务发现为Spring云网关重写serviceId

Question

spring:
  cloud:
    gateway:
      discovery:
        locator:
          enabled: true
          lower-case-service-id: true
          predicates:
            - name: Path
              args:
                pattern: "'/api/' + serviceId + '/**'"
          filters:
            - name: RewritePath
              args:
                regexp: "'/api/' + serviceId + '/(?<remaining>.*)'"
                replacement: "'/${remaining}'"

Previos zuul配置：

zuul.routes.xxx.service-id=xxx-service
zuul.routes.aaa-bbb.service-id=aaa-bbb-service
zuul.routes.aaa-bbb.path=/aaa/bbb/**
zuul.strip-prefix=true
zuul.prefix=/api

Answer 1

除了@rémi gélibert变体之外，我们还可以实现自己的routelocator。它允许您为您的路由选择和特殊过滤器指定谓词，能够根据您的意愿改变请求。

这样，我们可以将路由配置提取到某种application.properties。

@Component
public class CustomRouteLocator implements RouteLocator {

  Map<String, Pattern> prefixPatternsByServiceNames; // external configuration
  Map<String, String> prefixesByServiceNames;        // external configuration 
  Set<String> servicesNames;                         // external configuration

  @Override
  public Flux<Route> getRoutes() {

    return Flux.fromIterable(servicesNames)
        .map(serviceName -> Route.async()
            .id("ROUTE_" + serviceName)
            .predicate(exchange -> {
              String path = exchange.getRequest().getPath().toString();
              return prefixPatternsByServiceNames.get(serviceName).matcher(path).find();
            })
            .filter((exchange, chain) -> {
              ServerHttpRequest origRequest = exchange.getRequest();
              String query = origRequest.getURI().getQuery();
              String originalPath = origRequest.getPath().toString();
              String newPath = originalPath.substring(prefixesByServiceNames.get(serviceName).length());

              ServerHttpRequest request = exchange.getRequest().mutate()
                  .path(query == null? newPath : newPath + "?" + query)
                  .build();
              return chain.filter(exchange.mutate()
                  .request(request)
                  .build());
            })
            .uri("http://" + serviceName)
            .build());
  }

}

请注意：