Netty中的消息处理

Question

我是Netty的新手，需要以自定义方式处理消息。我有以下接口：

public interface Command{ }

public interface CommandFactory{
    Command(byte b)
}

public interface CommandProcessor{
    void process(Command c, Object arg)
}

现在我从客户端收到一些数据，并希望对其进行处理。我正在实现ReplayingDecoder

public class CommandDecoder extends ReplayingDecoder<Void>{
    private CommandFactory cmf;
    private CommandProcessor cmp;

   void decode(ChannelHandlerContext ctx, ByteBuf in, List<AnyRef> out){
       Command command = cmf.command (
         in.readByte()
       );

       String arg = new String (
         in.readBytes (
           in.readShort()
         ).array()
       );

      cmp.process(command, arg); //<------------ Here
  }
}

问题是我不确定。我在解码器中处理命令。至少可以说看起来很奇怪。也许我应该通过解码的通信和arg进一步到通道管道。

但是，要选择哪个ChannelInundHandler用于命令处理？




Answer 1

你是对的。最好将解码器和实际业务逻辑分离，以便进行命令处理。在这种情况下，最好的处理程序是SimpleChannelInboundHandler。通常，它只接受特定类型的消息。

可能是这样的：

public class MyCommandHandler extends SimpleChannelInboundHandler<Command> {

    @Override
    protected void channelRead0(ChannelHandlerContext ctx, Command command) throws Exception {
         //process here your message
         //command.type;
         //command.args  
    }

}

因此，在您解码命令之后：

Command command = cmf.command (
         in.readByte(),
         new String (in.readBytes (in.readShort()).array())
       );

您可以通过以下方式将其传递到管道中的下一个MyCommandHandler：

out.add(command);