从 FIlter 中的 java micornaut 服务读取标头

如何解决从 FIlter 中的 java micornaut 服务读取标头

我想读取响应中返回的标头。为此，我设置了一个过滤器。过滤器被调用（第一个日志语句正在工作），但标题的日志记录不起作用。我有这个：

@Filter("/**")
public class MyFilter implements HttpFilter {

private static final Logger LOG = LoggerFactory.getLogger(AmountFilter.class);

@Override
public Publisher<? extends HttpResponse<?>> doFilter(HttpRequest<?> request,FilterChain chain) {
    request.getHeaders().forEach(h -> LOG.info("Headers sent are: {} <=> {}",h.getKey(),h.getValue()));
    Publisher<? extends HttpResponse<?>> proceed = chain.proceed(request);
    proceed.subscribe(new Subscriber<HttpResponse<?>>() {
        @Override
        public void onSubscribe(Subscription s) {
            s.request(Long.MAX_VALUE);
        }

        @Override
        public void onNext(HttpResponse<?> resp) {
            resp.getHeaders().forEach(h -> LOG.debug("Header received: {} {}",h.getValue()));
        }

        @Override
        public void onError(Throwable t) {
        }

        @Override
        public void onComplete() {
        }
    });
    return proceed;
}

}

解决方法

您发布的代码中有几个问题

1. （较小的问题）您的过滤器未实现 Ordered#getOrder，因此如果另一个过滤器更改了 HttpRespose 的标头，则不能保证此日志记录过滤器会捕获更改的标头。要解决此问题，我们可以实现 getOrder 方法并使其返回 Ordered.HIGHEST_PRECEDENCE，这样您的日志过滤器将位于过滤器链中的第一个。然后，chain.proceed() 调用将调用所有其他过滤器。

2. 直接使用 Publisher 和/或手动实现 Subscriber 并不是很好的做法。您可以通过使用 Flowable.fromPublisher 来避免这样做（假设您使用的是 RxJava）。这使您可以使用更符合人体工程学的 Flowable 类及其 doOnNext 方法。此外，proceed 发布者订阅了两次（一次是通过您的 Subscriber 实现，一次是由 Micronaut 执行请求）。由于 proceed 是一个冷发布者（它只在订阅后开始工作），这会导致过滤器执行两次请求，从而引发 Micronaut 错误。

通过解决这两个问题，我们得到

@Filter("/**")
public class MyFilter implements HttpFilter {

    private static final Logger LOG = LoggerFactory.getLogger(MyFilter.class);

    @Override
    public int getOrder() {
        return Ordered.HIGHEST_PRECEDENCE;
    }

    @Override
    public Publisher<? extends HttpResponse<?>> doFilter(HttpRequest<?> request,FilterChain chain) {
        request.getHeaders().forEach(h -> LOG.info("Headers sent are: {} <=> {}",h.getKey(),h.getValue()));

        Publisher<? extends HttpResponse<?>> proceed = chain.proceed(request);

        return Flowable.fromPublisher(proceed)
                .doOnNext((resp) -> {
                    resp.getHeaders().forEach((key,value) -> LOG.debug("Header received: {} {}",key,value));
                });
    }

}

最后，您的第一个 LOG 语句使用 LOG.info，而您的第二个 LOG 语句使用 LOG.debug。使用默认的 logback.xml 设置，您将看不到任何调试消息。要查看所有调试日志，您可以

    <root level="info">
        <appender-ref ref="STDOUT" />
    </root>

到

    <root level="debug">
        <appender-ref ref="STDOUT" />
    </root>

或者，您可以将第二个语句更改为使用 LOG.info 以避免更改您的 logback.xml 文件。