springcloudgateway中使用BodyInserter类方法实现 XSS过滤

在Spring Cloud Gateway中，可以使用BodyInserter类方法来实现XSS过滤。

首先，你需要创建一个实现了BodyInserter接口的自定义类，用于对请求和响应的body进行修改。例如：

public class XssBodyInserter implements BodyInserter<Object, ReactiveHttpOutputMessage> {

    private final BodyInserter<Object, ReactiveHttpOutputMessage> delegate;

    public XssBodyInserter(BodyInserter<Object, ReactiveHttpOutputMessage> delegate) {
        this.delegate = delegate;
    }

    @Override
    public Mono<Void> insert(
            Publisher<? extends Object> input,
            ReactiveHttpOutputMessage outputMessage) {
        // 对请求或响应的body进行XSS过滤
        return delegate.insert(input, outputMessage);
    }

    @Override
    public List<HttpMessageWriter<?>> messageWriters() {
        return delegate.messageWriters();
    }
}

然后，在路由定义中使用该自定义类来对请求和响应的body进行修改。例如：

@Bean
public RouteLocator customRouteLocator(RouteLocatorBuilder builder) {
    return builder.routes()
            .route(r -> r.path("/api/**")
                    .filters(f -> f.modifyRequestBody(String.class, Object.class,
                            MediaType.APPLICATION_JSON_VALUE,
                            (exchange, s) -> {
                                // 对请求的body进行XSS过滤
                                return Mono.just(XssUtils.xssEncode(s));
                            })
                            .modifyResponseBody(Object.class, String.class,
                                    MediaType.APPLICATION_JSON_VALUE,
                                    (exchange, s) -> {
                                        // 对响应的body进行XSS过滤
                                        return Mono.just(XssUtils.xssEncode(s));
                                    }))
                    .uri("lb://backend-service"))
            .build();
}

在上面的示例中，我们使用了`modifyRequestBody`和`modifyResponseBody`方法来分别对请求和响应的body进行修改，并调用自定义的`XssUtils.xssEncode`方法来进行XSS过滤。

需要注意的是，该方法只能对JSON格式的请求和响应进行XSS过滤，如果请求和响应是其他格式的，需要进行相应的修改。