从筛选器中的java micornaut服务读取头

wko9yo5t  于 2021-06-29  发布在  Java
关注(0)|答案(1)|浏览(315)

我想读取响应中返回的标题。为此,我设置了一个过滤器。过滤器被调用(第一个log语句正在工作),但是头的日志记录没有工作。我有这个:

@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.getKey(), h.getValue()));
        }

        @Override
        public void onError(Throwable t) {
        }

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

}
hjqgdpho

hjqgdpho1#

你发布的代码中有几个问题
(小问题)您的过滤器没有实现 Ordered#getOrder ,因此,如果另一个过滤器更改了httprespose的头,则不能保证此日志过滤器将捕获更改的头。为了解决这个问题,我们可以实现 getOrder 方法并使其返回 Ordered.HIGHEST_PRECEDENCE ,这样您的日志过滤器将位于过滤器链的第一位。然后 chain.proceed() call将调用所有其他筛选器。
使用 Publisher 直接和/或手动实施 Subscriber 不是很好的做法。您可以通过使用 Flowable.fromPublisher (假设您使用的是rxjava)。这让你使用更符合人体工程学的方法 Flowable 类及其应用 doOnNext 方法。此外 proceed publisher被订阅了两次(一次与您的 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 文件。

相关问题