Netty客户端从HttpResponse获取响应体字节时遇到问题

看起来你遇到的问题大概率是调试时的误解——FullHttpResponse的content()本身只包含响应体，你看到的HTTP方法、版本、头信息其实是这个响应对象的其他元数据部分，而不是content里的内容。

先理清FullHttpResponse的结构 #

Netty的FullHttpResponse是完整的HTTP响应封装，它的各个部分是分开存储的：

• HTTP版本、状态码：通过msg.protocolVersion()、msg.status()获取
• 响应头：通过msg.headers()获取
• 响应体：才是msg.content()对应的ByteBuf

你可能在调试时直接打印了msg对象（比如调用println(msg)），而FullHttpResponse的toString()方法会输出完整的响应信息（包括状态行、头、体），这就让你误以为content里包含了这些元数据。

验证方法 #

你可以在buildResponse方法里单独打印响应体的内容，确认是不是只有响应体：

import io.netty.util.CharsetUtil

private def buildResponse(msg: FullHttpResponse): Either[Throwable, Response[A]] = {
  // 临时打印响应体内容，验证是否正确
  println("实际响应体内容：" + msg.content().toString(CharsetUtil.UTF_8))
  
  val result = {
    try {
      val parsedBody = BodyParser[A].parse(msg.content().asReadOnly())
      if (msg.status() == HttpResponseStatus.OK) {
        Right(Response.Ok(parsedBody))
      } else {
        Right(Response.Other(msg.status().code(), parsedBody))
      }
    } catch {
      case e: Throwable => Left(e)
    }
  }
  result.fold(metrics.bodyParseFailure, metrics.successfulResponse)
  result
}

如果确实content里包含了元数据，排查这几个点 #

如果上面的验证显示content里真的有HTTP方法、头这些数据，那可能是以下问题：

1. 请求构造错误：检查你发送的FullHttpRequest是否正确，有没有误将请求的头、方法等元数据写入到请求的content()里？比如构造请求时错误地把请求行信息写到了body中，服务器可能原样返回了这些内容？
2. ByteBuf读取位置异常：虽然asReadOnly()会返回一个readerIndex为0的新ByteBuf，但如果前面的Handler（比如HttpContentDecompressor）异常修改了原ByteBuf的读取位置，可能导致你读取到错误的内容。可以尝试在读取前重置readerIndex：

   val content = msg.content().asReadOnly()
   content.resetReaderIndex() // 重置读取位置到开头
   val parsedBody = BodyParser[A].parse(content)
   

3. BodyParser实现问题：检查你的BodyParser.parse方法是不是错误地解析了ByteBuf之外的信息？比如有没有依赖其他上下文（比如当前Channel的请求信息），而不是只处理传入的ByteBuf？

补充你的Pipeline配置 #

你的Pipeline顺序是正确的：HttpClientCodec -> HttpContentDecompressor -> HttpObjectAggregator -> 自定义Handler，这个顺序能确保你拿到的是解压后的完整响应体，没有问题。

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