如何使反应式@WebFilter与@Request estbody一起正常工作？

Question

我正在尝试制作一个反应式@WebFilter，它在实际服务器交换之前和之后执行内容（即处理请求的控制器代码）：

public static class Foobar implements WebFilter {

    @Override
    public Mono<Void> filter(ServerWebExchange exchange, WebFilterChain chain) {
        return Mono.empty()
                .doOnEach(s -> /* BEFORE */))
                .then(chain.filter(exchange) /* CONTROLLER */)
                .and(Mono.empty().doOnEach(s -> /* AFTER */))
                .and(Mono.empty().doFinally(s -> /* FINALLY */));
    }
}

对于返回Mono的简单GET请求，一切都按预期工作：

@RestController
@RequestMapping
public static class Foo {

    @GetMapping
    @PostMapping(value = "foo")
    public Mono<String> foo(ServerWebExchange exchange) {
        return Mono.just("FOOBAR").map(e -> "OK");
    }
}

但是当控制器收到一个注释为@Request estbody的参数时，会发生一些真正意想不到的事情。例如，一个接受Mono的POST请求

@RestController
@RequestMapping
public static class Bar {

    @PostMapping(value = "bar")
    public Mono<String> bar(ServerWebExchange exchange, @RequestBody Mono<String> text) {
        return text.map(s -> "OK");
    }
}

在这种情况下，我的过滤器中的所有步骤都在控制器完成请求之前执行。这意味着Web交换是独立于过滤器提交的，因此我无法在响应发送回客户端后正确执行任何操作。

所以我想知道：

• 这是Spring的虫子吗

我创建了一个小要点，其中包含一个再现问题的测试用例：

• https://gist.github.com/guillermocalvo/740b4fcab471ebc6fe69227fee6d79d5

在Brian的评论后编辑：

我仍然认为这可能是一个bug，因为Mono。那么看来根本没有任何效果：

        @Override
        public Mono<Void> filter(ServerWebExchange exchange, WebFilterChain chain) {
            return chain.filter(exchange)
                .doOnSubscribe(s -> logger.info("onSubscribe response committed:" +
                        exchange.getResponse().isCommitted()))
                .then().doOnEach(s -> logger.info("then doOnEach response committed:" +
                        exchange.getResponse().isCommitted()))
                .doFinally(s -> logger.info("doFinally response committed:" +
                        exchange.getResponse().isCommitted()));
        }

此外，如果我把东西放在doOnEach中，也不会执行：

        @Override
        public Mono<Void> filter(ServerWebExchange exchange, WebFilterChain chain) {
            return chain.filter(exchange)
                    .doOnSubscribe(s -> logger.info("FILTER-BEFORE-CHAIN/commited=" +
                        response.isCommitted()))
                    .doOnEach(s -> logger.info("FILTER-AFTER-CHAIN/commited=" +
                        response.isCommitted()))
                    .doFinally(s -> logger.info("FILTER-FINALLY/commited=" +
                        response.isCommitted()));
        }




Answer 1

匿名用户

我不认为这是Spring中的错误（在这种情况下也不是Retor中的错误），而是错误地选择了运算符来实现您正在尝试做的事情。

• Mono.doOneach为每个信号执行（下一个元素、完成、错误、取消）；在我们的例子中，每个请求都会执行几次。
• Mono.and加入终止信号-因此它等待两个Mono完成，然后完成。但是两个Monos不是按顺序执行的，它们是同时订阅的。Mono.just立即完成，与过滤器链发生的情况无关。

在您的情况下，不需要比在处理开始时添加一个操作符（映射完成并且我们开始执行处理程序时发生doOnSubscribe）和完成时添加另一个操作符（完成、错误或取消）更复杂的操作。

    @Component
    public class MyFilter implements WebFilter {

        Logger logger = LoggerFactory.getLogger(getClass());

        @Override
        public Mono<Void> filter(ServerWebExchange exchange, WebFilterChain chain) {
            return chain.filter(exchange)
                .doOnSubscribe(s -> logger.info("onSubscribe response committed:" +
                        exchange.getResponse().isCommitted()))
                .doFinally(s -> logger.info("doFinally response committed:" + 
                        exchange.getResponse().isCommitted()));
        }
    }

请注意，只要不在DoOnXYZ方法中执行阻塞操作，这种方法就可以工作，因为它们是副作用方法。这样做会在应用程序中造成严重的性能问题（reactor甚至可能会异常拒绝该操作）。因此，记录日志、向映射中添加元素是可以的，但将某些内容发布到事件队列则不行。在这种情况下，您应该将链式操作改为与Mono一起使用。然后（）。

我认为Mono没有bug。then（）-doOnEach只对发送到下游的信号起作用（next，error，complete）。在这种情况下，您应该只获得完整的信号。如果您想了解所有情况下的上下文，可以查看Mono。延迟上下文。