Java Web Flux : How to fetch body from ServerHttpResponse?(Java Web Flux:如何从ServerHttpResponse获取正文?)
本文介绍了Java Web Flux:如何从ServerHttpResponse获取正文?的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!
问题描述
我已实现自定义ServerHttpRequestDecorator来获取请求正文,但无法对响应执行相同的操作。
@Override
public Mono<Void> filter(ServerWebExchange exchange, WebFilterChain chain)
{
long start = System.currentTimeMillis();
LogServerWebExchangeDecorator exchangeDecorator = new LogServerWebExchangeDecorator(
exchange);
exchangeDecorator.getResponse().beforeCommit(() ->
{
logRequest(exchangeDecorator.getRequest(), exchangeDecorator.getRequestBody());
logResponse(exchangeDecorator.getRequest(), exchangeDecorator.getResponse(), start);
return Mono.empty();
});
return chain.filter(exchangeDecorator);
}
如何实现同样的目标?
推荐答案
private class LogServerHttpResponseDecorator extends ServerHttpResponseDecorator
{
private final FastByteArrayOutputStream fastByteArrayOutputStream;
public LogServerHttpResponseDecorator(ServerHttpResponse response, LoggingContext loggingContext)
{
super(response);
fastByteArrayOutputStream = new FastByteArrayOutputStream();
response.beforeCommit(LoggingContextUtils.withContext(loggingContext, (Supplier<Mono<Void>>) () ->
{
logResponse(byteArrayToString(fastByteArrayOutputStream.toByteArray(),
getHeaders()));
return Mono.empty();
}));
}
@Override
public Mono<Void> writeWith(Publisher<? extends DataBuffer> body)
{
return super.writeWith(Flux.from(body).map(buffer ->
{
readBuffer(fastByteArrayOutputStream, buffer);
return buffer;
}));
}
@Override
public Mono<Void> writeAndFlushWith(
Publisher<? extends Publisher<? extends DataBuffer>> body)
{
return super.writeAndFlushWith(Flux.from(body).map(publisher ->
Flux.from(publisher).map(buffer ->
{
readBuffer(fastByteArrayOutputStream, buffer);
return buffer;
})));
}
}
private void readBuffer(FastByteArrayOutputStream fastByteArrayOutputStream, DataBuffer buffer)
{
try
{
Channels.newChannel(fastByteArrayOutputStream)
.write(buffer.asByteBuffer().asReadOnlyBuffer());
}
catch (IOException e)
{
if (LoggingUtils.isLoggable(LOGGER, Level.ERROR))
{
LoggingUtils.log(LOGGER, Level.ERROR, null, "Unable to log", e);
}
}
}
这篇关于Java Web Flux:如何从ServerHttpResponse获取正文?的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持编程学习网!
织梦狗教程
本文标题为:Java Web Flux:如何从ServerHttpResponse获取正文?


基础教程推荐
猜你喜欢
- REST Web 服务返回 415 - 不支持的媒体类型 2022-01-01
- 无法复制:“比较方法违反了它的一般约定!" 2022-01-01
- 如何对 Java Hashmap 中的值求和 2022-01-01
- RabbitMQ:消息保持“未确认"; 2022-01-01
- 存储 20 位数字的数据类型 2022-01-01
- Spring AOP错误无法懒惰地为此建议构建thisJoinPoin 2022-09-13
- Struts2 URL 无法访问 2022-01-01
- 修改 void 函数的输入参数,然后读取 2022-01-01
- 问题http://apache.org/xml/features/xinclude测试日志4j 2 2022-01-01
- 使用堆栈算法进行括号/括号匹配 2022-01-01