OpenDaylight(氢版本)数据通信代码解读

最近看了Opendaylight的源码,仔细研读openflow_plugin,SAL,上层服务(Arphandler)。以下分析是基于Opendaylight的Hydrogen版本。不过讲的这些插件应该可以在Helium适用,毕竟各个成熟的bundle不会大幅度变化。

Opendaylight(hydrogen)data tele code

Opendaylight使用OSGi框架,这个框架的巨大好处是可以热插拔各个组件,即不用关闭应用就能为ODL安装各个应用。其结构如下:

ODL  ODGi

ODL控制器有多个小项目,每个小项目是一个bundle(组件),组件之间可以为其他组件提供服务。openflow1.0插件属于其南向各种plugin的一个。

首先Openflow插件的结构如下:

Openflow插件的结构

这个插件的位置位于controller/opendaylight/protocol_plugins/openflow/src/main/java/org/opendaylight/controller/protocol_plugin/,它里面有两个文件夹,core和internal 。

core是openflow1.0的核心代码,里面有一些重要java文件讲一下,

  • IController.java定义了openflow 控制器与交换机交互的抽象接口,无具体实现代码
  • Controller.java 控制器核心操作
  • ControllerIO.java主要是处理交换机的连接请求,一个java的线程,每五秒检测一次

internal 是openflow1.0插件上层的服务

  • DataPacketMuxDemux.java

下面分析一下几个重要的文件:

ControllerIO.java,这是一个java的线程,每五秒检测一次,是否有新连接请求进来,有则处理。

这是一个java的线程,每五秒检测一次,是否有新连接请求进来,有则处理

它会调用Controller.java的handlerNewConnection,这里会给这一个新的交换机生成一个SwitchHandler,它是一个线程,专门和交换机进行通信。SwitchHandler的handleMessages()函数用来处理各类消息;SwitchHandler用MessageReadWriteService.java文件实现与交换机的Socket连接,这也是为什么一个交换机对应一个SwitchHandler。SwitchHandler就在SwitchHandler.java文件内。

SwitchHandler就在SwitchHandler.java文件

在Internal里的核心在Controller.java,他的主要作用:

  • 处理交换机发来的event,保存一个event队列
  • 控制器启动一个线程处理Event队列
  • 每种消息使用一个listener

处理Event的队列线程也在Controller.java实现,Switch_message就是交换机发送来的openflow消息。Event队列的Event定义在SwithEvent.java文件。

Event队列的Event定义在SwithEvent.java文件

Event队列的Event是从哪里来的呢?来自SwitchHandler.java,因为每个Switch有一个SwitchHandler的线程,SwitchHandler收到消息就封装成Event后加入到Controller的Event队列里。请仔细阅读SwitchHandler.java的代码,它里面会区分各个openflow的消息。

阅读SwitchHandler.java的代码,它里面会区分各个openflow的消息

Controller对的Event的处理中,假如是消息的Event,也就是MessageEvent,调用 receive(ISwitch sw, OFMessage msg),这个函数在DataPacketMuxDemux.java实现。

这里大家一定很奇怪,为什么DataPacketMuxDemux.java能收到消息,我们需要明白,opendaylight定义了很多接口,DataPacketMuxDemux.java里实现了接口IMessageListener,而Opendaylight为每个openflow消息都定义了一种IMessageListener,如果要监听这种消息,我们只需要设置addMessageListener(OFType, this)函数里加上自己要监听的Openflow的消息类型,不信你看看DataPacketMuxDemux是否有这个函数,它因此可以收到Pack_in消息。

这个函数处理中,调用receiveDataPacket,数据就会进入SAL层,SAL层收到openflow_plugin发出的Pack_in消息同样是实现了一个接口IPluginOutDataPacketService,这个接口由SAL层的DataPacketService.java实现,大家看了代码肯定会发现它还实现了另一个接口IDataPacketService,这个接口是接收从SAL上层各个服务发送的数据包。所以SAL层起到了一个处理分发的作用。在SAL层收到下层plugin发送到包后,会送入上层的各个服务

各个服务(如ArpHandler)会通过监听IListenDataPacket接口来收到从SAL层发来的数据。这里有个问题讲明白,上层监听这个端口的可能有很多个服务,那么每个监听此接口的服务都会收到SAL转发的数据包备份。

下面是整个数据传输结构图:

整个数据传输结构图

SAL层中处理数据包的是DataPacketService,而处理流表操作FlowProgrammerService。所以SAL的每个Service都可以看成是处理南北数据通路的一种服务。关键需要搞懂的是南北通路中的数据传输过程和机制。上面组件之间传输通过接口实现。

需要主要注意的是Openflow_plugin内的Controller.java,ContrllerIO.java,SwitchHandler.java,MessageReadWriteService.java(这里是和Switch通信的Socket的实现),DataPacketServices.java这几个文件,需要认真阅读。

基本上ODL的代码还算易懂。

作者简介:
王钰琪,2013/07-至今 北京邮电大学网络技术研究院 网络与交换技术国家重点实验室攻读硕士研究生


  • 本站原创文章仅代表作者观点,不代表SDNLAB立场。所有原创内容版权均属SDNLAB,欢迎大家转发分享。但未经授权,严禁任何媒体(平面媒体、网络媒体、自媒体等)以及微信公众号复制、转载、摘编或以其他方式进行使用,转载须注明来自 SDNLAB并附上本文链接。 本站中所有编译类文章仅用于学习和交流目的,编译工作遵照 CC 协议,如果有侵犯到您权益的地方,请及时联系我们。
  • 本文链接https://www.sdnlab.com/9735.html
分享到:
相关文章
条评论

登录后才可以评论

wyqbupt 发表于15-03-26
2