当前位置: 代码迷 >> 综合 >> OpenDaylight(氢版本)数据通信代码解读
  详细解决方案

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

热度:79   发布时间:2024-01-14 06:03:41.0

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


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

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

首先Openflow插件的结构如下:

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

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

 ■IController.java定义了openflow 控制器与交换机交互的抽象接口,无具体实现代码

 ■Controller.java 控制器核心操作

 ■ControllerIO.java主要是处理交换机的连接请求,一个java的线程,每五秒检测一次

internal openflow1.0插件上层的服务

 ■DataPacketMuxDemux.java

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

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

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

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

 ■处理交换机发来的event,保存一个event队列

 ■控制器启动一个线程处理Event队列

 ■每种消息使用一个listener

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

Event队列的Event是从哪里来的呢?来自SwitchHandler.java,因为每个Switch有一个SwitchHandler的线程,SwitchHandler收到消息就封装成Event后加入到ControllerEvent队列里。请仔细阅读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.javaContrllerIO.javaSwitchHandler.javaMessageReadWriteService.java(这里是和Switch通信的Socket的实现),DataPacketServices.java这几个文件,需要认真阅读。

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

作者简介:

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

点击阅读原文