如何解析Netty（Java）中的各种对象？

Question

我使用netty，我想将各种对象从客户端发送到服务器，反之亦然。

我在客户端和服务器上创建了相同的解码器和编码器类；

解码器：

public class UserInfoDecoder extends ByteToMessageDecoder {
    @Override
    protected void decode(ChannelHandlerContext channelHandlerContext, ByteBuf byteBuf, List<Object> list) throws Exception {
...
list.add(new UserInfo(...))
 }
}

编码器：

public class UserInfoEncoder extends MessageToByteEncoder<UserInfo> {
        @Override
        protected void encode(ChannelHandlerContext ctx, UserInfo msg, ByteBuf out) {
...
 out.writeBytes(...);
}

下面是我的服务器initChannel方法：

public void initChannel(SocketChannel ch) throws Exception {
                            ChannelPipeline p = ch.pipeline();
                            if (sslCtx != null) {
                                p.addLast(sslCtx.newHandler(ch.alloc()));
                            }
                            p.addLast(
                                  //  new ObjectEncoder(),
                                  //  new ObjectDecoder(ClassResolvers.cacheDisabled(null)),

                                    new UserInfoDecoder(),
                                    new UserInfoEncoder(),

                                    new ObjectEchoServerHandler());
}

服务器处理程序类中有一个方法channelRead

@Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) {


...
    }

如何区分客户端发送的对象？对于例如，现在我只有“UserInfo”类，我可以将channelRead中的“object Msg”转换为“UserInfo”，但我也想发送“UserSCAR”对象，例如，如何通过发送的类型来区别对象？

Answer 1

按照当前的实现方式，最简单的实现方法是在通过通道发送编码字节之前，在编码字节中添加一个“魔术字节”前缀。

public class UserInfoEncoder extends MessageToByteEncoder<UserInfo> {
    @Override
    protected void encode(ChannelHandlerContext ctx, UserInfo msg, ByteBuf out) {
    final int USER_BYTE = 0;
    out.writeBytes(USER_BYTE);
    out.writeBytes(msg.toBytes());
}

然后在服务器端，当消息被解码时，检查这个神奇的字节，并根据读取的值分配适当的解码器。例如。如果第一个未解码字节的值为0，则使用UserInfo解码器。如果第一个未解码字节的值为1，则使用UsersCar解码器。

@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) {
   final ByteBuf message = (ByteBuf) msg;
   final byte magicByte= message.getByte(0);

   if(magicByte == 0){
      new UserInfoDecoder().decode(message);
   }else if {
    ....
   }
}

不是最利索的解决方案，而是最简单的。

注意：这是假设您使用的处理程序是扩展ChannelInboundHandlerAdapter

了解Netty编码/解码的一个很好的示例：http://shengwangi.blogspot.ie/2016/03/netty-tutorial-hello-world-example.html