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