网关路由配置

Pig 3.0 采用的是spring官方的网关组件，通过异步背压的高性能网关。路由配置是整个微服务中最为核心的功能

① 配置路由解释

访问 nacos /pig-gateway-dev.yml 我们以UPMS 的路由为例子，注意注释

spring:
  cloud:
    gateway:
      routes:
      #UPMS 模块
      - id: pig-upms      # 唯一的服务ID
        uri: lb://pig-upms # 注册中心的服务名称，实现负载均衡
        predicates:
        - Path=/admin/**  #所有业务的请求前缀，会在② 中自动去除

② 全局的路由过滤器

PigRequestGlobalFilter,对全部的微服务提供了安全过滤（这个后边会讲）和全局StripPrefix=1配置，意味着你在使用Pig的时候，网关转发到业务模块时候会自动截取前缀，不用再每个微服务路由配置了StripPrefixFilter

public class PigRequestGlobalFilter implements GlobalFilter, Ordered {
    private static final String HEADER_NAME = "X-Forwarded-Prefix";
    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        // 1. 清洗请求头中from 参数
        ServerHttpRequest request = exchange.getRequest().mutate()
            .headers(httpHeaders -> httpHeaders.remove(SecurityConstants.FROM))
            .build();
        // 2. 重写StripPrefix
        addOriginalRequestUrl(exchange, request.getURI());
        String rawPath = request.getURI().getRawPath();
        String newPath = "/" + Arrays.stream(StringUtils.tokenizeToStringArray(rawPath, "/"))
            .skip(1L).collect(Collectors.joining("/"));
        ServerHttpRequest newRequest = request.mutate()
            .path(newPath)
            .build();
        exchange.getAttributes().put(GATEWAY_REQUEST_URL_ATTR, newRequest.getURI());
        return chain.filter(exchange.mutate()
            .request(newRequest.mutate()
                .build()).build());
    }
    @Override
    public int getOrder() {
        return -1000;
    }
}

❤ 问题咨询