首页 > 代码库 > OFMessageDecoder 分析

OFMessageDecoder 分析

2024-07-09 07:42:42   224人阅读


     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 便于各个模块的处理。


联系
我们