Gateway 自定义过滤器的实现

Myth丶恋晨 2023-01-03 14:08 105阅读 0赞

这里我们实现一个自定义的定时过滤器，打印一下请求信息

@Slf4j
    @Component
    public class TimerFilter implements GatewayFilter, Ordered { 
    
        @Override
        public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) { 
            StopWatch timer = new StopWatch();
            timer.start(exchange.getRequest().getURI().getRawPath());
    
            return chain.filter(exchange).then(
                    Mono.fromRunnable(() -> { 
                        timer.stop();
                        log.info(timer.prettyPrint());
                    })
            );
        }
    
        @Override
        public int getOrder() { 
            return 0;
        }
    }

然后在java过滤器配置中直接引用`TimerFilter`

@Configuration
    public class GatewayConfiguration { 
    
    	@Autowired
        private TimerFilter timerFilter;
    
        @Bean
        @Order
        public RouteLocator customizedRoutes(RouteLocatorBuilder builder) { 
            return builder.routes()
                    .route(r -> r.path("/java/**")
                        .filters(f -> f.stripPrefix(1)
                        .filter(timerFilter)
                        )
                        .uri("lb://FEIGN-CLIENT")
                    )
                    .build();
        }
    
    }

没错，配置就是这么简单，到这里就结束了！  
我们可以启动服务，然后尝试着调用一下，可以看到控制台中打印出了`timer.prettyPrint()`信息  
![在这里插入图片描述][20210108150904696.png]

##### 拓展 #####

上面的配置方式，是我们在某个`route.filters()`下进行单独配置，如果想将其设置为全局过滤器，只要将`TimerFilter`的继承类`GatewayFilter`，修改为`GlobalFilter`即可！

[20210108150904696.png]: /images/20221119/3ad7784a764a45e4aab0ec46743d9b4f.png