首页 > 代码库 > OFMessageDecoder 分析
OFMessageDecoder 分析
OFMessageDecoder 继承了抽象类 FrameDecoder。FrameDecoder 会将接收到的ChannelBuffers 转换成有意义的 frame 对象,在基于流的传输过程中,通常会发生分片和重组的情况,所以就需要一个解码器,根据特定协议的约束,将收到的包理解为相应的,易于应用逻辑层处理的对象。
这里调用的是 BasicFactory 的 parseMessage 方法,一次处理一个of msg,然后添加到链表中,这里重要的条件就是 openflow header 的长度和消息类型,然后调用枚举类型中个体的newinstance()方法生成对应的OFMessage。
public List< OFMessage> parseMessage(ChannelBuffer data) throws MessageParseException {
List<OFMessage> msglist = new ArrayList< OFMessage>();
OFMessage msg = null;
while (data.readableBytes() >= OFMessage.MINIMUM_LENGTH) {
data.markReaderIndex();
msg = this .parseMessageOne(data);
if (msg == null ) {
data.resetReaderIndex();
break ;
}
else {
msglist.add(msg);
}
}
if (msglist.size() == 0) {
return null ;
}
return msglist;
}
这样就使得进入流水线的所有信息都是具体的 OFMessage 便于各个模块的处理。
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。