我正在尝试处理以下消息:
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 中的错误/限制?
谢谢