在 ExchangeFilterFunction 中访问上下文

Question

出于某种原因，doAfterSuccessOrError 方法中的 context 无法从上游获得（填充）。我尝试使用 Mono.subscriberContext() 来访问它（见截图）。我希望它存在，但由于某种原因没有。我做错了什么吗？

public class LoggingRequestExchangeFunction implements ExchangeFilterFunction {

    private final Logger log = LoggerFactory.getLogger(getClass());

    @Override
    public Mono<ClientResponse> filter(ClientRequest request, ExchangeFunction next) {
        long start = System.currentTimeMillis();

        return next.exchange(request).doAfterSuccessOrError((res, ex) -> {
            Mono.subscriberContext().map((ctx -> {
                log.info("doAfterSuccessOrError Context {}",ctx);
                // log req/res ...
                return ctx;
            })).subscribe();

        }).subscriberContext( ctx -> {
            log.info("SubscriberContext: {}" , ctx);
            return ctx;
        });
    }
}

这是日志输出

23:16:59.426  INFO [reactor-http-epoll-2] .p.c.LoggingRequestExchangeFunction [] SubscriberContext: Context1{nexmo-tracing-context=TracingContext{{traceId=f04961da-933a-4d1d-85d5-3bea2c47432f, clientIp=N/A}}}
23:16:59.589  INFO [reactor-http-epoll-2] .p.c.LoggingRequestExchangeFunction [] doAfterSuccessOrError Context Context0{}

Answer 1

原因是您在 doAfterSuccessOrError 中创建了一个新的 Mono，它独立于原始反应器链，因为您单独订阅了它。

如果你只想在里面记录一些东西，你的替代方法是使用 doOnEach 运算符，它除了信号类型之外还可以让你访问上下文。

Mono.just("hello")
    .doOnEach((signal) ->
            {
                if (signal.isOnError() || signal.isOnComplete())
                {
                    Context ctx = signal.getContext();

                    log.info("doAfterSuccessOrError Context {}",ctx);
                    // log req/res ...
                }
            })
    .subscriberContext( ctx -> {
            log.info("SubscriberContext: {}" , ctx);
            return ctx;
      })
    .subscribe();

在 ExchangeFilterFunction 中访问上下文

Accessing Context inside an ExchangeFilterFunction

project-reactor

spring-webflux

spring-webclient