我正在尝试使用netty创建http客户机，一切正常，但是我很难解析主体。我的管道如下所示：

pipeline.addLast(new HttpClientCodec())
      pipeline.addLast(new HttpContentDecompressor())
      pipeline.addLast(new HttpObjectAggregator(1024*10))
      pipeline.addLast(new HttpClientHandler[A](key, metrics))

和客户端处理程序（用scala编写）

class HttpClientHandler[A: BodyParser](key: AttributeKey[Callback[A]], metrics: Metrics)
    extends SimpleChannelInboundHandler[FullHttpResponse]
    with LazyLogging {

  override def channelRead0(ctx: ChannelHandlerContext, msg: FullHttpResponse): Unit = {
    val callback = ctx.channel().attr(key).get()
    if (callback != null) {
      val response = buildResponse(msg)
      callback(response)
    } else {
      throw new Exception("Callback not present in channel context ... this is a bug")
    }
  }

  private def buildResponse(msg: FullHttpResponse): Either[Throwable, Response[A]] = {
    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
  }

  override def exceptionCaught(ctx: ChannelHandlerContext, cause: Throwable): Unit = {
    logger.warn(s"error observed for channel ${ctx.channel()}, closing", cause)
    ctx.channel().attr(key).get().apply(Left(cause))
  }

}

主要问题是 msg.content() 也包含http数据（方法，版本，头…），但我只对正文感兴趣。我做错什么了？谢谢！