12.3 服务端响应编码

服务端响应编码总体流程：

NettyCodecAdapter$InternalEncoder.encode(ChannelHandlerContext ctx, Object msg, ByteBuf out)
-->new NettyBackedChannelBuffer(ByteBuf buffer) // 创建一个buffer
-->NettyChannel.getOrAddChannel(io.netty.channel.Channel ch, URL url, ChannelHandler handler)
-->DubboCountCodec.encode(Channel channel, ChannelBuffer buffer, Object msg)
  -->ExchangeCodec.encode(Channel channel, ChannelBuffer buffer, Object msg)
      -->encodeResponse(Channel channel, ChannelBuffer buffer, Response res)
        -->getSerialization(Channel channel)   //获取Hessian2Serialization序列化实例
          -->CodecSupport.getSerialization(URL url)
            -->ExtensionLoader.getExtensionLoader(Serialization.class).getExtension(url.getParameter("serialization", "hessian2"))
        <!-- 构造一个16字节的byte[16] header -->
        -->byte[] header = new byte[16]
        -->Bytes.short2bytes(MAGIC, header)  //设置前两个字节为魔数[-38, -69, 0, ..., 0]
        <!-- 第三个字节：序列化协议ID，如果响应是心跳，添加eventFlag -->
        -->header[2] = serialization.getContentTypeId();
         if (res.isHeartbeat()) header[2] |= FLAG_EVENT;
      <!-- 第四个字节：响应状态 -->
        -->header[3] = res.getStatus();
      <!-- 设置第5~12个字节（long是64bit，即8byte）：respID == requestID -->
      -->Bytes.long2bytes(res.getId(), header, 4);
      <!-- 下面序列化响应体数据 -->
      -->new Hessian2ObjectOutput(out)
      -->DubboCodec.encodeResponseData(Channel channel, ObjectOutput out, Object data)
      -->Bytes.int2bytes(len, header, 12); // 设置第13~16个字节（int是32位，4个字节）：消息体长度
      -->buffer.writeBytes(header); // 将header写入buffer的前16位

与 12.1 客户端请求编码 极其相似。

注意：响应编码中DubboCodec

    @Override
    protected void encodeResponseData(Channel channel, ObjectOutput out, Object data) throws IOException {
        Result result = (Result) data;

        Throwable th = result.getException();
        if (th == null) {
            Object ret = result.getValue();
            if (ret == null) {
                out.writeByte(RESPONSE_NULL_VALUE);
            } else {
                out.writeByte(RESPONSE_VALUE);
                out.writeObject(ret);
            }
        } else {
            out.writeByte(RESPONSE_WITH_EXCEPTION);
            out.writeObject(th);
        }
    }

注意：out.writeByte(RESPONSE_VALUE);写入这个响应类型，是为了将来客户端响应解码用的，具体见 12.4 客户端响应解码

请求编码的byte[] header的最终结构:

• 1~2 byte：魔数
• 3 byte：requestFlag、序列化方式ID、twowayFlag或eventFlag
• 5~12 byte ：requestID
• 13~16：请求体长度

响应编码的byte[] header的最终结构:

• 1~2 byte：魔数
• 3 byte：序列化方式ID、eventFlag（如果响应信息是心跳信息，添加eventFlag）
• 4 byte：响应状态，20代表成功
• 5~12 byte ：reponseID（实际上==requestID）
• 13~16：响应体长度