Higress如何实现gateway的自定义filter功能？

Higress是一个高性能的API网关，它支持自定义filter功能，通过自定义filter，我们可以对请求和响应进行一些预处理和后处理操作，以满足特定的业务需求，下面是实现gateway的自定义filter功能的详细步骤：

（图片来源网络，侵删）

1、创建自定义filter类

我们需要创建一个自定义filter类，该类需要实现org.springframework.cloud.gateway.filter.GatewayFilter接口。

在自定义filter类中，我们需要重写apply(GatewayFilterChain chain)方法，该方法是过滤器的核心逻辑。

2、实现自定义filter逻辑

在apply(GatewayFilterChain chain)方法中，我们可以对请求和响应进行一些预处理和后处理操作。

我们可以获取请求头信息、修改请求参数、添加响应头等。

3、注册自定义filter

在Spring配置类中，我们需要将自定义filter注册到gateway中。

可以使用@Bean注解将自定义filter实例化为一个bean，并使用GatewayFilterFactory将其注册到gateway中。

4、使用自定义filter

在gateway路由配置中，我们可以为某个route或全局配置添加自定义filter。

可以使用@Bean注解将自定义filter实例化为一个bean，并使用RouteLocatorBuilder将其添加到gateway路由配置中。

下面是一个示例代码，演示了如何实现一个简单的自定义filter：

import org.springframework.cloud.gateway.filter.GatewayFilter;
import org.springframework.cloud.gateway.filter.factory.AbstractGatewayFilterFactory;
import org.springframework.stereotype.Component;
@Component
public class CustomFilter extends AbstractGatewayFilterFactory<CustomFilter.Config> {
    public CustomFilter() {
        super(Config.class);
    }
    @Override
    public GatewayFilter apply(Config config) {
        return (exchange, chain) > {
            // 在这里实现自定义filter的逻辑
            // 获取请求头信息、修改请求参数、添加响应头等
            // ...
            return chain.filter(exchange); // 继续执行后续过滤器和路由处理器
        };
    }
    public static class Config {
        // 可以在这里定义一些配置参数，用于初始化自定义filter
        // ...
    }
}

在Spring配置类中注册自定义filter：

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.cloud.gateway.filter.GlobalFilter;
import org.springframework.cloud.gateway.route.RouteLocator;
import org.springframework.cloud.gateway.route.builder.RouteLocatorBuilder;
import org.springframework.cloud.gateway.route.builder.RouteLocatorBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Mono;
@Configuration
public class GatewayConfig {
    @Bean
    public CustomFilter customFilter() {
        return new CustomFilter(); // 创建自定义filter实例并返回
    }
}

在gateway路由配置中使用自定义filter：

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.web.bind.annotation.*;
import reactor.core.publisher.Mono;
@RestController
@RequestMapping("/api") // 设置请求路径前缀为/api，所有以/api开头的请求都会被gateway拦截并处理
public class MyController {
    // ...其他控制器逻辑...
}