reactive应用程序中正确的日志记录-WebFlux

Question

上次我在考虑如何在我们的应用程序中正确使用记录器。例如，我有一个控制器，它返回一个用户流，但在日志中，我看到“Fetch users”日志是由另一个线程记录的，而不是处理管道上的线程，但这是一个好的方法吗？

@Slf4j
class AwesomeController {
    
    @GetMapping(path = "/users")
    public Flux<User> getUsers() {
        log.info("Fetch users..");
        
        return Flux.just(...)..subscribeOn(Schedulers.newParallel("my-custom"));
    
    }
}

在这种情况下，使用了两个线程，从我的角度来看，这不是一个好的选择，但我找不到在反应应用程序中使用记录器的好做法。我认为下面的方法更好，因为分配内存是来自处理线程，而不是来自spring webflux线程，这可能会阻塞但记录器。

   @GetMapping(path = "/users")
    public Flux<User> getUsers() {

        return Flux.defer(() -> {
            return Mono.fromCallable(() -> {
                log.info("Fetch users..");
                    .....
            })
        }).subscribeOn(Schedulers.newParallel("my-custom"))
    }

Answer 1

通常要做的事情是将记录器配置为异步（根据注释，这通常必须是显式的，但所有现代日志记录框架都支持它），然后“正常地”包含它（可以像您在这里那样作为单独的一行，或者在副作用方法中，如doonnext()，如果您希望它在反应链的一半。）

如果您想确保记录器的调用没有阻塞，那么使用BlockHound来确保（无论如何，这从来都不是一个坏主意。）但是在任何情况下，我都看不到第二个示例的用例--这使得代码很难遵循，没有真正的优势。

最后要注意的一点是，请记住，如果您像上面那样单独包含日志语句，而不是作为反应链的一部分，那么它将在调用时而不是订阅时执行方法。在这种情况下，两者几乎同时发生，这可能无关紧要，但如果（例如）返回一个可能订阅多次的发布服务器，则会相当混乱--在这种情况下，您只会看到“Fetch Users...”语句，这在浏览代码时并不明显。