微服务网关Spring Cloud Gateway之Filter

spring.cloud.gateway.routes[0].id=goods-service-route
spring.cloud.gateway.routes[0].uri=lb://newbee-cloud-goods-service
spring.cloud.gateway.routes[0].order=1
spring.cloud.gateway.routes[0].predicates[0]=Path=/newbee-cloud/goods/**
## 访问/newbee-cloud/goods 开头的请求，都会被设置为/goods 开头的请求
spring.cloud.gateway.routes[0].filters[0]=StripPrefix=1

spring.cloud.gateway.routes[1].id=shopcart-service-route
spring.cloud.gateway.routes[1].uri=lb://newbee-cloud-shopcart-service
spring.cloud.gateway.routes[1].order=1
spring.cloud.gateway.routes[1].predicates[0]=Path=/shop-cart/**
## 访问/shop-cart 开头的请求，都会被重定向到掘金官网
spring.cloud.gateway.routes[1].filters[0]=RedirectTo=302,https://juejin.cn

package ltd.gateway.cloud.newbee.filter;

import org.springframework.cloud.gateway.filter.GatewayFilter;
import org.springframework.cloud.gateway.filter.GatewayFilterChain;
import org.springframework.cloud.gateway.filter.factory.AbstractGatewayFilterFa
ctory;
import org.springframework.core.io.buffer.DataBuffer;
import org.springframework.http.HttpStatus;
import org.springframework.stereotype.Component;
import org.springframework.util.StringUtils;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

import java.nio.charset.StandardCharsets;
import java.util.Arrays;
import java.util.List;

@Component
public class GoodsIdGatewayFilterFactory extends AbstractGatewayFilterFactory<GoodsIdGatewayFilterFactory.Config> {

    public GoodsIdGatewayFilterFactory() { //构造函数
        super(Config.class);
    }

    @Override
    public List<String> shortcutFieldOrder() {
        // 定义配置文件中的参数项(最小值和最大值)
        return Arrays.asList("minValue", "maxValue");
    }

    @Override
    public GatewayFilter apply(Config config) {
        return new GatewayFilter() {
            @Override
            public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
                // 获取参数值
                String goodsIdParam = exchange.getRequest().getQueryParams().getFirst("goodsId");
                // 判空
                if (!StringUtils.isEmpty(goodsIdParam)) {
                    int goodsId = Integer.parseInt(goodsIdParam);
                    // 判断goodsId是否在配置区间内，直接放行
                    if (goodsId > config.getMinValue() && goodsId < config.getMaxValue()) {
                        return chain.filter(exchange);
                    } else {
                        // 不符合条件，返回错误的提示信息，不进行后续的路由
                        byte[] bytes = ("BAD REQUEST").getBytes(StandardCharsets.UTF_8);
                        DataBuffer wrap = exchange.getResponse().bufferFactory().wrap(bytes);
                        exchange.getResponse().setStatusCode(HttpStatus.BAD_REQUEST);
                        return exchange.getResponse().writeWith(Flux.just(wrap));
                    }
                }
                // 直接放行
                return chain.filter(exchange);
            }
        };
    }

    //接收配置文件中定义的最大值和最小值
    public static class Config {
        private int minValue;
        private int maxValue;

        public int getMinValue() {
            return minValue;
        }

        public void setMinValue(int minValue) {
            this.minValue = minValue;
        }

        public int getMaxValue() {
            return maxValue;
        }

        public void setMaxValue(int maxValue) {
            this.maxValue = maxValue;
        }
    }
}

spring.cloud.gateway.routes[0].id=goods-service-route
spring.cloud.gateway.routes[0].uri=lb://newbee-cloud-goods-service
spring.cloud.gateway.routes[0].order=1
spring.cloud.gateway.routes[0].predicates[0]=Path=/goods/**
# 自定义过滤器配置，配置项为 goodsId，最大值为 100000，最小值为 10000
spring.cloud.gateway.routes[0].filters[0]=GoodsId=10000,100000

package ltd.gateway.cloud.newbee.filter;

import org.springframework.cloud.gateway.filter.GatewayFilterChain;
import org.springframework.cloud.gateway.filter.GlobalFilter;
import org.springframework.core.Ordered;
import org.springframework.stereotype.Component;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Mono;

//全局过滤器，统计接口调用时间
@Component
public class TimeCalculateGlobalFilter implements GlobalFilter, Ordered {

    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        // 请求开始时间
        long startTime = System.currentTimeMillis();
        String requestURL = String.format("Host:%s Path:%s Params:%s",
                exchange.getRequest().getURI().getHost(),
                exchange.getRequest().getURI().getPath(),
                exchange.getRequest().getQueryParams());

        System.out.println(requestURL);

        return chain.filter(exchange).then(Mono.fromRunnable(() -> {
            // 请求结束时间
            long endTime = System.currentTimeMillis();
            // 打印调用时间
            long requestTime = endTime - startTime;

            System.out.println(exchange.getRequest().getURI().getPath() + "请求时间为" + requestTime + "毫秒");
        }));
    }

    @Override
    public int getOrder() {
        return Ordered.LOWEST_PRECEDENCE;
    }
}

server.port=8147
# 应用名称
spring.application.name=newbee-cloud-gateway-service
# 注册中心 Nacos 的访问地址
spring.cloud.nacos.discovery.server-addr=127.0.0.1:8848
# 登录名(默认为 nacos, 可自行修改)
spring.cloud.nacos.username=nacos
# 密码(默认为 nacos, 可自行修改)
spring.cloud.nacos.password=nacos

spring.cloud.gateway.routes[0].id=goods-service-route
spring.cloud.gateway.routes[0].uri=lb://newbee-cloud-goods-service
spring.cloud.gateway.routes[0].order=1
spring.cloud.gateway.routes[0].predicates[0]=Path=/goods/**

spring.cloud.gateway.routes[1].id=shopcart-service-route
spring.cloud.gateway.routes[1].uri=lb://newbee-cloud-shopcart-service
spring.cloud.gateway.routes[1].order=1
spring.cloud.gateway.routes[1].predicates[0]=Path=/shop-cart/**