java - 在 mono.compose() 内部添加 doOnSuccess() 与简单的 mono.doOnSuccess() 有什么好处

Question

研究 Spring 执行器MetricsWebFilter

看到了这段代码:

@Override
public Mono<Void> filter(ServerWebExchange exchange, WebFilterChain chain) {
    return chain.filter(exchange).compose((call) -> filter(exchange, call));
}

private Publisher<Void> filter(ServerWebExchange exchange, Mono<Void> call) {
    long start = System.nanoTime();
    ServerHttpResponse response = exchange.getResponse();
    return call.doOnSuccess((done) -> success(exchange, start))
    ... more code ...
}

如果没有 compose() 映射会有什么不同吗？

@Override
public Mono<Void> filter(ServerWebExchange exchange, WebFilterChain chain) {
    return chain.filter(exchange).doOnSuccess( ... ) ... more code...
}

我的线索是，与 transform() 相比，compose() 对每个订阅者执行一次。然而，doOnSuccess() 也会为每个订阅者执行一次。

使用 filter(...) 函数而不是内联代码只是为了方便吗？

Answer 1

这在可读性方面有几个小好处:

• 代码更好地封装在过滤器方法中
• 调用更具可读性(在发生转换时读取)。与传统调用该方法相比:return filter(exchange, chain.filter(exchange))。

但在我看来，更重要的一点是 compose 是特定于订阅者的。因此，filter(exchange, call) 将在每个订阅上调用。因此开头的计时代码将是相关的;)