在 webflux 中读取请求正文

Question

public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
    Flux<DataBuffer> body = exchange.getRequest().getBody();
    //Return different according to body content...
    if (condition) {
        return chain.filter(exchange);
    } else {
        return Mono.empty();
    }
}  

spring-webflux with spring 5如何获取请求体做一些自定义判断？

Answer 1

您的问题并不完全清楚。我假设您的疑问是您在代码 sn-p cmets 中输入的内容。

可能有不同的方法来实现你想要的。一种简单的方法是使用flatMap 运算符。大致如下：

public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
    Flux<DataBuffer> body = exchange.getRequest().getBody()
       .flatMap(data -> {
           if (condition) {
              return chain.filter(exchange);
           } 
           return Mono.empty();
       });
  //...
}