SpringCloud局部过滤器自定义

港控/mmm° 2021-12-16 22:55 321阅读 0赞

# 一、实现步骤： #

1.  在gateway\_service中编写MyParamGatewayFilterFactory类
2.  实现业务代码：循环请求参数中是否包含name，如果包含则输出参数值
3.  修改配置文件
4.  访问请求测试，带name参数

# 二、在gateway\_service中编写MyParamGatewayFilterFactory类 #

package com.william.filters;
    import org.springframework.cloud.gateway.filter.GatewayFilter;
    import org.springframework.cloud.gateway.filter.GatewayFilterChain;
    import org.springframework.cloud.gateway.filter.factory.AbstractGatewayFilterFactory;
    import org.springframework.http.server.reactive.ServerHttpRequest;
    import org.springframework.stereotype.Component;
    import org.springframework.util.StringUtils;
    import org.springframework.web.server.ServerWebExchange;
    import reactor.core.publisher.Mono;
    import java.util.Arrays;
    import java.util.List;
    /**
     * 命名有要求：
     * MyParam(自定义) GatewayFilterFactory(固定写法)
     */
    @Component//千万不要忘记注入Spring容器
    public class MyParamGatewayFilterFactory extends AbstractGatewayFilterFactory<MyParamGatewayFilterFactory.Config> {
        /**
         * Prefix key.
         */
        public static final String PARAM_NAME = "name";
    
    
        public MyParamGatewayFilterFactory() {
            super(Config.class);
        }
    
        @Override
        public List<String> shortcutFieldOrder() {
            return Arrays.asList(PARAM_NAME);
        }
    
        public GatewayFilter apply(Config config) {
    
            GatewayFilter gatewayFilter  = new GatewayFilter() {
                @Override
                public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
                    /**
                     * 拦截所有请求，如果参数中包含name,把参数打印到控制台
                     */
                    //获取请求对象
                    ServerHttpRequest request = exchange.getRequest();
                    //获取所有参数
                    String name = request.getQueryParams().getFirst("name");
                    //如果name有值 = null "" "  " "   "
                    if (!StringUtils.isEmpty(name)) {
                        System.out.printf("局部过滤器，拦截 name=%s !!!!", name);
                    }
                    return chain.filter(exchange);//放行所有请求
                }
            };
            return gatewayFilter;
        }
    
        public static class Config {
    
            private String name;
    
            public String getName() {
                return name;
            }
    
            public void setName(String name) {
                this.name = name;
            }
        }
    }

# 三、 修改配置文件 #

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NpbmF0XzM5MTc5OTkz_size_16_color_FFFFFF_t_70]

# 四、访问请求测试，带name参数 #

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NpbmF0XzM5MTc5OTkz_size_16_color_FFFFFF_t_70 1]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NpbmF0XzM5MTc5OTkz_size_16_color_FFFFFF_t_70 2]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NpbmF0XzM5MTc5OTkz_size_16_color_FFFFFF_t_70]: /images/20211214/bed58dc2172e4756b4b5368ac6665f17.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NpbmF0XzM5MTc5OTkz_size_16_color_FFFFFF_t_70 1]: /images/20211214/0c73ec4eaa934cababf3cdd0b8e66f25.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NpbmF0XzM5MTc5OTkz_size_16_color_FFFFFF_t_70 2]: /images/20211214/00b5d5179b88497ea0afab3006941030.png