我们知道，在Netty架构，一个ServerBootstrap用于生成server端的Channel的时候都须要提供一个ChannelPipelineFactory类型的參数，用于服务于建立连接的Channel，流水线处理来自某个client的请求。所以这里的 OpenflowPipelineFactory 就是Floodlight 为建立连接的openflow交换机创建ChannelPipeline。
1. IdleStateHandler 当Channel上没有运行对应的读写操作一定时间的时候出发一个 IdleStateEvent 事件；
2. ReadTimeoutHandler 读超时处理；
3. HandshakeTimeoutHandler 设置一个定时器检查连接的状态，握手阶段 。
4 . OFChannelHandler 核心，处理全部的业务。
代码例如以下：
public class OpenflowPipelineFactory implements ChannelPipelineFactory {
protected Controller controller ;
protected ThreadPoolExecutor pipelineExecutor ;
protected Timer timer ;
protected IdleStateHandler idleHandler ;
protected ReadTimeoutHandler readTimeoutHandler ;
public OpenflowPipelineFactory(Controller controller,
ThreadPoolExecutor pipelineExecutor) {
super ();
this . controller = controller;
this . pipelineExecutor = pipelineExecutor;
this . timer = new HashedWheelTimer();
this . idleHandler = new IdleStateHandler( timer , 20, 25, 0);
this . readTimeoutHandler = new ReadTimeoutHandler( timer , 30);
}
@Override
public ChannelPipeline getPipeline() throws Exception {
OFChannelState state = new OFChannelState();
ChannelPipeline pipeline = Channels. pipeline();
pipeline.addLast( "ofmessagedecoder" , new OFMessageDecoder());
pipeline.addLast( "ofmessageencoder" , new OFMessageEncoder());
pipeline.addLast( "idle" , idleHandler );
pipeline.addLast( "timeout" , readTimeoutHandler );
pipeline.addLast( "handshaketimeout" ,
new HandshakeTimeoutHandler(state, timer , 15));
if ( pipelineExecutor != null )
pipeline.addLast( "pipelineExecutor" ,
new ExecutionHandler( pipelineExecutor ));
//OFChannelHandler 是核心
pipeline.addLast( "handler" , controller .getChannelHandler(state));
return pipeline;
}
}
版权声明：本文博客原创文章，博客，未经同意，不得转载。