2

我正在尝试处理以下消息：

CMD (string) FLAG (byte) CMD_OPT (string)

字符串由包含长度的单个前导字节表示，后跟最多 255 个字节。所以举一个具体的例子：

 EQ_REGISTER 0 flaux

有 19 个字节。在我的管道中，我从 LengthFieldBasedFrameDecoder 开始，然后在确认第一个字符串的值后，我尝试删除第一个解码器。问题是，解码器在 FLAG 字节上再次被调用，我的逻辑是关闭的。

这是我的管道：

    ChannelPipeline pipeline = Channels.pipeline();

    pipeline.addLast("commandDecoder", new CerbStringDecoder());
    pipeline.addLast("commandHandler", new EventQueueCmdServerHandler());

CerbStringDecoder 是这样的：

   class CerbStringDecoder extends LengthFieldBasedFrameDecoder {
    public CerbStringDecoder() {
        super(255, 0, 1, 0, 1);
    }


    protected Object decode(
            ChannelHandlerContext ctx, Channel channel, ChannelBuffer buffer) throws Exception {
        ChannelBuffer buf = (ChannelBuffer) super.decode(ctx, channel, buffer);

        if (buf == null)
            return null;

        return buf.toString(Charset.forName("UTF-8"));
    }
}


 public class EventQueueCmdServerHandler extends SimpleChannelHandler {

    @Override
    public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) {

        String command = (String) e.getMessage();

        if (EQ_REGISTER.equals(command)) {
            System.out.println("COMMAND: [" + command + "]");
            ctx.getPipeline().addLast("handler", new EventQueueRegisterHandler());
            ctx.getPipeline().remove("commandDecoder");

       ....

EventQueueRegisterHandler 期望获取 FLAG 和 CMD_OPT 等。

关于我做错了什么的任何建议，或者这是否是 Netty 中的错误/限制？

谢谢

4

1 回答 1

1

您需要使用“replace(..)”方法来确保在删除它时所有缓冲的字节都被清除。请参阅 javadocs [1]。

[1] http://static.netty.io/3.5/api/org/jboss/netty/handler/codec/frame/FrameDecoder.html#replace(java.lang.String,%20org.jboss.netty.channel.通道处理程序）

于 2012-09-13T06:05:56.327 回答