一、ModelDrivenSwitchImpl核心类

在上篇中提到了类ModelDrivenSwitchImpl。可以说这个类是openflow交换机的抽象。几乎所有操作都需要调用类的方法,比如:addflow,addgroup等。简单看一下构造函数:



二、Flowmod下发流程

Flowmod分为三种,add、update、remove。这三种类型操作类似,这里以addflow为例进行分析。


代码addflow非常简单,但是有几点需要说明:



上面简单分析了一下最外层逻辑处理,归为两点:

1)创建返回类型UpdateOutput的task并提交到线程池。

2) 接收返回类型UpdateOutput的future并且转成对应的Output,如AddOutput、RemoveOutput。


下面开始flowmod下发流程分析,逻辑层次比较深入还是先放一张流程图:


由上图可知,flowmod下发流程层次很深,这里只分析一下几个方法:


1、toFlowModInput方法,该方法可以说是将业务数据转成标准flowmod消息入口。如果需要扩展flowmod消息,则需要从这个函数着手修改:



代码MatchReactor.getInstance().convert(…),最终会调用到MatchConvertorImpl.convert这个函数中,就有我们常见的协议字段,如:inport,ipv4等。这个函数主要是组建oxm。这些内容没有什么逻辑,只要按照标准协议填写即可,不再累赘阐述。


方法toInstructions,getActions也类似,按照标准协议填写即可。


以上内容主要想说明,当我们扩展flowmod消息的时候,能够知道在哪里修改即可。


2、方法MessageDispatchServiceImpl.flowMod



3、简单分析netty中write方法,此方法功能是将数据包发到网络中。


在说write方法之前,简单说一下netty背景知识吧。netty为了降低应用程开发帮我们做了很多东西,比如说常见的tcp粘包、丢包问题,最简编解码,异步IO等。应用程序基本不要关心这些底层内容,不像C/C++语言开发时,需要由应用程序自己处理粘包,丢包以及自己构造异步IO,这些内容如果处理不好,会带来很大问题。


然而关于编解码问题,netty只是做了最基本的序列化工作,比如说分割符,定长编解码等,对于咱们Openflow协议这种编解码,netty是没有提供的,而且也不应该由netty提供。


我们来看一下write方法:



针对上面的ctx.write(buf, promise);这行代码再多说两句,这个函数只是将消息放到netty队列中,择机发到网络中。那么择机发送是什么时候发送呢?一般有两个条件:

1、队列已满。

2、超时。


然而应用程序若想立即将数据包发送到网络中则需要调用方法writeAndFlush。在这里讨论这些内容,主要因为某些应用要求实时性比较高的时候,所以可以考虑这种方式。


三、再谈序列化OFEncoder.encode

在上一篇中,我们提到了序列化,这个在简单过一下吧。OFEncoder是序列化入口,所有序列化操作都需要调用该类的方法,或者是调用encode方法。



关于序列化工厂注册内容,请参考上一篇文章。

四、Session存储关系图

控制器所有操作都是建立在session基础之上的,换句话说就是建立在连接之上的,下图就是session相关组织结构图。



1.单例模式保存所有session对象

SessionManagerOFImpl是一个单例,保存当前有效session会话。从hello握手成功session一直存在,直到交换机与控制器断链后。


2.SessionListener有两个方法,onSessionAdded,onSessionRemoved。这两方法从便可知道用于管理添加、删除session对象。这两个方法主要是操作HashMap即ConcurrentHashMap


3.Hashmap中键值value是SessionContext,这个上下文包含了一个ModelDrivenSwitchImpl,实则是ODL对交换机的抽象。也就是说ODL用类ModelDrivenSwitchImpl来表示一个交换机。抽象出来的ModelDrivenSwitchImpl进行再次包装,插入到SessionContext的notifaction队列当中。以便能够处理后续的notification消息。


4.在ModelDrivenSwitchImpl中有一个属性OFRpcTaskContext,这个属性是关联SessionContext以及Notification服务等。控制器给交换机发送的消息中大部分都是采用RPC形式,所以rpcTaskContext是至关重要的。




以上全部内容基本上(加上前一篇)就是ODL代码从上到下,从下到上,openflow消息处理流程。有些内容分析不到位,请各位网友多多批评指出,欢迎大家及时讨论。


©著作权归作者所有:来自51CTO博客作者mob604756f52321的原创作品,如需转载,请注明出处,否则将追究法律责任

更多相关文章

  1. 【php基础入门】PHP中常用的数组操作使用方法笔记整理(推荐)
  2. (trunk的两种方法)(单臂路由)
  3. 210426 PHP 输出方法,数据类型,变量,作用域,常量
  4. 关于 class helper for ... 语法
  5. 学用 ASP.Net 之 "字符串" (4): string 类的扩展方法
  6. 学用 ASP.Net 之 "字符串" (3): string 类的非扩展方法
  7. Delphi 正则表达式之TPerlRegEx 类的属性与方法(7): Split 函数
  8. Delphi 正则表达式之TPerlRegEx 类的属性与方法(1): 查找
  9. jQuery中的$.ajax方法,以及基本的vue指令操作

随机推荐

  1. android:process=":remote"
  2. Android指定调用系统自带浏览器打开链接
  3. Android帧布局-实现渐变效果
  4. 搭建Android开发环境01——Java
  5. Android自定义ProgressBar
  6. 查看android路由表
  7. Android修改PackageInstaller自动安装指
  8. Android SDK更新失败对策
  9. 一张图片覆盖在另一个图片上
  10. android:broadcast_01