OFMessageDecoder 分析
OFMessageDecoder 继承了抽象类 FrameDecoder。FrameDecoder 会将接收到的ChannelBuffers 转换成有意义的 frame 对象。在基于流的传输过程中，一般会发生分片和重组的情况，所以就须要一个解码器。依据特定协议的约束，将收到的包理解为相应的。易于应用逻辑层处理的对象。
代码例如以下： public class OFMessageDecoder extends FrameDecoder {
OFMessageFactory factory = new BasicFactory();
// 实现父类的抽象方法，最后一个參数 buffer： // buffer the cumulative buffer of received packets so far. // Note that the buffer might be empty, which means you // should not make an assumption that the buffer contains // at least one byte in your decoder implementation. @Override protected Object decode(ChannelHandlerContext ctx, Channel channel, ChannelBuffer buffer) throws Exception { List<OFMessage> message = factory .parseMessage(buffer); return message; } } 这个decode抽象方法会被FrameDecoder的messageReceived方法所调用，FrameDecoder也是一个UpstreamHandler，当有数据到达的时候就会收集数据到ChannelBuffer中而后解码。
这里调用的是 BasicFactory 的 parseMessage 方法。一次处理一个of msg。然后加入到链表中。这里重要的条件就是 openflow header 的长度和消息类型，然后调用枚举类型中个体的newinstance()方法生成相应的OFMessage。 SRE实战 互联网时代守护先锋，助力企业售后服务体系运筹帷幄！一键直达领取阿里云限量特价优惠。
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 便于各个模块的处理。
更多精彩
