springwebflux—在java reactor中的线程上创建mdc上下文

zqdjd7g9  于 2021-06-29  发布在  Java
关注(0)|答案(0)|浏览(352)

我是一个新的java reactor,在将mdc上下文传递到线程到底层实现时遇到了问题

Response response = Mono.from(
            externalCall.request(request, caller))
            .block();

我确实在这里读过一些博客,但我没能完全理解。我发现这似乎更有用,我试图添加一个做同样的代码添加 doOnNext 以及 doOnEach 但不是这样的

Map<String, String> map = MDC.getCopyOfContextMap();
    Response response = Mono.from(
            externalCall.request(request, caller))
            .doOnEach(value->{
                if(map !=null){
                    MDC.setContextMap(map);
                }
            })
            .block();

我希望这将设置mdc,以便在内部进行大量的日志记录 externalCall.request 但是没有鱼。有没有一种简单的方法可以在正在创建的独立线程中定义mdc?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题