SpringCloud系列之網(wǎng)關(guān)gateway-9.自定義過(guò)濾器實(shí)現(xiàn)接口計(jì)時(shí)功能

首先創(chuàng)建一個(gè)過(guò)濾器

package com.example.gatewaysample;

import lombok.extern.slf4j.Slf4j;
import org.springframework.cloud.gateway.filter.GatewayFilter;
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.util.StopWatch;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Mono;

@Component
@Slf4j
//GlobalFilter 全局filter  GatewayFilter 局部filter
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;
    }
}

配置過(guò)濾器

配置過(guò)濾器很簡(jiǎn)單: .filter(timerFilter)

package com.example.gatewaysample;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.gateway.route.RouteLocator;
import org.springframework.cloud.gateway.route.builder.RouteLocatorBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.annotation.Order;
import org.springframework.http.HttpMethod;

import java.time.ZonedDateTime;

@Configuration
public class GatewayConfiguration {

    @Autowired
    private TimerFilter timerFilter;

    @Bean
    @Order
    public RouteLocator customizedRoutes(RouteLocatorBuilder routeLocatorBuilder){
        return routeLocatorBuilder.routes()
                .route(r->r.path("/java/**")
                        .and().method(HttpMethod.GET)
                        .and().header("name")
                        .filters(f->f.stripPrefix(1)
                                .addResponseHeader("java-param","gateway-config")
//                                .filter(timerFilter)
                        )
                        .uri("lb://feign-client")
                )
                .route(r->r.path("[表情]ckill/**")
                        .and().after(ZonedDateTime.now().plusMinutes(1))
                        .filters(f->f.stripPrefix(1))
                        .uri("lb://feign-client")
                )
                .build();
    }


}

最后需要注意一點(diǎn)的是如果我們配置的是局部的過(guò)濾器就繼承GatewayFilter,如果是全局就繼承GlobalFilter,全局過(guò)濾器是不需要配置在路由規(guī)則中的,因?yàn)槭侨郑运械穆酚啥紩?huì)首先進(jìn)行全局過(guò)濾器的校驗(yàn)。

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時(shí)請(qǐng)結(jié)合常識(shí)與多方信息審慎甄別。
平臺(tái)聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點(diǎn),簡(jiǎn)書(shū)系信息發(fā)布平臺(tái),僅提供信息存儲(chǔ)服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容