Java中的gateway自定義過濾器詳解

更新時間：2023年11月17日 11:30:46 作者：小菜雞9527

這篇文章主要介紹了Java中的gateway自定義過濾器詳解,過濾器是指gateway在路由過程中(A地址路由到B地址)生效進行過濾操作的,所有首先你得先配一個地址路由,本文提供了部分實現(xiàn)代碼,需要的朋友可以參考下

全局過濾器（GloabalFilter）

注意:

過濾器是指gateway在路由過程中（A地址路由到B地址）生效進行過濾操作的，所有首先你得先配一個地址路由。比如我站在這里設置將//localhost:8000/gateway/* 請求路由到//localhost:8010/user/*，那么下面的兩個樣例過濾器遍對這個過程進行過濾

        - id: user_route
          uri: lb://server-user
          #uri: http://localhost:8010
          predicates:
            - Path=/gateway/**
          filters:
            - RewritePath=/gateway/(?<segment>.*),/user/$\{segment}

開啟gateway的日志，方便后面查看過程

logging:
  level:
    org.springframework.cloud.gateway: DEBUG

前置過濾器

@Component
public class MyHeadFilter implements GlobalFilter, Ordered {
    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        System.out.println("123123");
        return chain.filter(exchange);
    }

    @Override
    public int getOrder() {
        return 0;
    }
}

后置過濾器

@Component
public class MyTailFilter implements GlobalFilter, Ordered {

    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        return chain.filter(exchange)
                .then(Mono.fromRunnable(
                        () -> System.out.println("abcabc")
                ));
    }
    @Override
    public int getOrder() {
        return 0;
    }
}

運行結果

然后訪問//localhost:8000/gateway/listAll，路由到//localhost:8010/user/listAll成功

控制臺輸出

在這里插入圖片描述

局部過濾器

有兩種方式：

在上面全局模式的基礎上，改為實現(xiàn)gatewayFilter和Ordered接口
繼承AbstractGatewayFilterFactory類（推薦)

局部過濾器實現(xiàn)

public class MyPartGatewayFilterFactory extends AbstractGatewayFilterFactory<MyPartGatewayFilterFactory.Config> {

    private static final Log log = LogFactory.getLog(GatewayFilter.class);
    private static final String NAME = "name";

    public MyPartGatewayFilterFactory() {
        super(Config.class);
    }

    @Override
    public List<String> shortcutFieldOrder() {
        return Arrays.asList(NAME);
    }

    @Override
    public GatewayFilter apply(Config config) {
        return (exchange, chain) -> {
            return chain.filter(exchange).then(
                    Mono.fromRunnable(() -> {
                        StringBuilder sb = new StringBuilder("這是2022年7月25日8點半之后的請求，請求者name（入?yún)ⅲ?);
                        sb.append(config.getName());
                        log.info(sb.toString());
                    })
            );
        };
    }
    public static class Config{
        private String name；
        public String getName() {
            return name;
        }
        public void setName(String name) {
            this.name = name;
        }
    }
}

在gateway的啟動類上進行注冊

@Bean
    public MyPartGatewayFilterFactory myGatewayFilterFactory(){
        return new MyPartGatewayFilterFactory();
    }

對應的配置文件部分

        - id: my_route
          uri: http://127.0.0.1:8010
          filters:
            - name: MyPart
              args:
                name: yuan
          predicates:
#            - After=2017-01-20T17:42:47.789-07:00[America/Denver]
            - After=2022-07-25T08:30:00.003+08:00[Asia/Shanghai]

運行結果

訪問//localhost:8000/user/test

8000是我的gateaway運行端口

在這里插入圖片描述