我想读取响应中返回的标题。为此,我设置了一个过滤器。过滤器被调用(第一个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;
}
}
1条答案
按热度按时间hjqgdpho1#
你发布的代码中有几个问题
(小问题)您的过滤器没有实现
Ordered#getOrder
,因此,如果另一个过滤器更改了httprespose的头,则不能保证此日志过滤器将捕获更改的头。为了解决这个问题,我们可以实现getOrder
方法并使其返回Ordered.HIGHEST_PRECEDENCE
,这样您的日志过滤器将位于过滤器链的第一位。然后chain.proceed()
call将调用所有其他筛选器。使用
Publisher
直接和/或手动实施Subscriber
不是很好的做法。您可以通过使用Flowable.fromPublisher
(假设您使用的是rxjava)。这让你使用更符合人体工程学的方法Flowable
类及其应用doOnNext
方法。此外proceed
publisher被订阅了两次(一次与您的Subscriber
一次由micronaut执行请求)。自proceed
是一个冷发布者(它只在订阅后才开始工作),这会导致筛选器执行两次请求,从而引发micronaut错误。通过解决这两个问题,我们得到
最后,你的第一次
LOG
语句正在使用LOG.info
,而你的第二个LOG
语句正在使用LOG.debug
. 使用默认值logback.xml
设置您将无法看到任何调试消息。要查看所有调试日志,可以到
或者,您可以将第二条语句更改为
LOG.info
为了避免改变你的想法logback.xml
文件。