如何将Netty Reactor的HTTP响应日志整合为单条记录？

自定义ChannelHandler聚合响应内容 #

Netty的响应拆分是因为底层按ByteBuf分片传输，你可以自定义一个ChannelInboundHandlerAdapter，在channelRead方法中累积所有响应分片，直到确认收到完整响应后再统一输出日志。

以HTTP响应为例，通过判断LastHttpContent标记确认响应结束：

public class AggregateResponseLogger extends ChannelInboundHandlerAdapter {
    private ByteBuf aggregatedBuffer;
    private String requestId; // 用于并发场景下关联请求，可通过Channel属性传递

    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        if (msg instanceof HttpContent) {
            HttpContent content = (HttpContent) msg;
            if (aggregatedBuffer == null) {
                aggregatedBuffer = ctx.alloc().buffer();
            }
            aggregatedBuffer.writeBytes(content.content());

            if (msg instanceof LastHttpContent) {
                // 完整响应已接收，输出单条日志
                String responseBody = aggregatedBuffer.toString(CharsetUtil.UTF_8);
                LOGGER.info("Request {} complete response: {}", requestId, responseBody);
                aggregatedBuffer.release();
                aggregatedBuffer = null;
            }
        }
        // 传递消息给后续handler
        super.channelRead(ctx, msg);
    }

    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
        if (aggregatedBuffer != null) {
            aggregatedBuffer.release();
        }
        LOGGER.error("Request {} response aggregation failed", requestId, cause);
        ctx.close();
    }
}

使用时将该Handler添加到客户端ChannelPipeline，同时通过Channel的自定义属性传递唯一requestId，确保并发场景下日志关联准确。

利用Reactor Netty响应钩子聚合日志 #

Reactor Netty提供了响应式钩子方法，可直接在回调中获取完整响应体，无需操作底层ChannelHandler：

// 定义存储requestId的Channel属性
AttributeKey<String> REQUEST_ID_ATTR = AttributeKey.valueOf("REQUEST_ID");

HttpClient.create()
        .wiretap(false) // 关闭默认Wiretap，避免冗余日志干扰
        .doOnResponse((response, connection) -> {
            // 自动聚合响应分片，读取完整响应体
            response.receive()
                    .aggregate()
                    .asString()
                    .subscribe(responseBody -> {
                        String requestId = connection.channel().attr(REQUEST_ID_ATTR).get();
                        LOGGER.info("Request {} response: {}", requestId, responseBody);
                    });
        })
        .get()
        .uri("http://your-proxy-server")
        .send()
        .response()
        .block();

这种方式贴合Reactor响应式模型，通过aggregate()自动合并分片，一次性输出完整响应日志。

过滤Wiretap冗余日志 #

若需保留Wiretap部分调试信息，可通过日志框架（如Logback）过滤握手等无关内容：

1. 将Netty Wiretap日志级别设为DEBUG，避免INFO级别的冗余握手日志。
2. 在日志配置中定向输出自定义聚合的INFO级日志，屏蔽Netty自带Wiretap日志：

<!-- Logback配置示例 -->
<logger name="io.netty" level="DEBUG" additivity="false">
    <appender-ref ref="NETTY_DEBUG_FILE"/>
</logger>
<logger name="your.custom.logger" level="INFO" additivity="true">
    <appender-ref ref="PROD_APP_LOG"/>
</logger>

生产环境仅展示你聚合后的单条响应日志，同时保留Debug级Netty日志用于问题排查。

内容的提问来源于stack exchange，提问作者Steve