码迷,mamicode.com
首页 > 其他好文 > 详细

Ryubook_1_switch_hub_源码

时间:2018-09-18 11:53:04      阅读:320      评论:0      收藏:0      [点我收藏+]

标签:self   des   out   manager   prot   simple   -o   parse   odi   

一、switching hub by openflow:

用Ryu实现一个有如下功能的switching hub。

 

? Learns the MAC address of the host connected to a port and retains it in the MAC address table.
? When receiving packets addressed to a host already learned, transfers them to the port connected to the host.
? When receiving packets addressed to an unknown host, performs flooding.

 

openflow交换机能够通过接收openflow控制器的的指令完成以下功能:

? Rewrites the address of received packets or transfers the packets from the specified port.
? Transfers the received packets to the controller (Packet-In).
? Transfers the packets forwarded by the controller from the specified port (Packet-Out).

以上几个功能结合起来,可以实现上面的switching hub。

 

总体代码:

 

技术分享图片
from ryu.base import app_manager
from ryu.controller import ofp_event
from ryu.controller.handler import CONFIG_DISPATCHER, MAIN_DISPATCHER
from ryu.controller.handler import set_ev_cls
from ryu.ofproto import ofproto_v1_3
from ryu.lib.packet import packet
from ryu.lib.packet import ethernet


class ExampleSwitch13(app_manager.RyuApp):   #继承ryu.base.app_manager.RyuApp
    OFP_VERSIONS = [ofproto_v1_3.OFP_VERSION]  #指定openflow版本

    def __init__(self, *args, **kwargs):
        super(ExampleSwitch13, self).__init__(*args, **kwargs)
        self.mac_to_port = {}    # initialize mac address table. a dict(or map)

    #set_ev_cls装饰器以 事件类型 和 交换机状态 为参数
    @set_ev_cls(ofp_event.EventOFPSwitchFeatures, CONFIG_DISPATCHER)
    def switch_features_handler(self, ev):
        datapath = ev.msg.datapath  #描述一个交换机
        ofproto = datapath.ofproto  #用于导出协商好版本的openflow定义的模块
        parser = datapath.ofproto_parser  #用于导出协商好版本的openflow编码器和解码器的模块
        # install the table-miss flow entry.
        match = parser.OFPMatch()  #ofproto_parser.OFPxxxx准备将要发送给交换机的消息
        # OFPActionOutput(port,max_len)定义一个action,将数据包输出到指定port
        actions = [parser.OFPActionOutput(ofproto.OFPP_CONTROLLER,  #输出端口指定为控制器端口
            ofproto.OFPCML_NO_BUFFER)] #在ovs上不缓存packet,将收到的整个packet发送至controller
        self.add_flow(datapath, 0, match, actions)  #添加Table-miss流表项


    def add_flow(self, datapath, priority, match, actions):
        ofproto = datapath.ofproto
        parser = datapath.ofproto_parser
        # construct flow_mod message and send it.
        inst = [parser.OFPInstructionActions(ofproto.OFPIT_APPLY_ACTIONS,actions)]
        #instruction type = APPLY_ACTIONS,立即执行actions list
        mod = parser.OFPFlowMod(datapath=datapath, priority=priority,
                                match=match, instructions=inst)
        datapath.send_msg(mod)


    @set_ev_cls(ofp_event.EventOFPPacketIn, MAIN_DISPATCHER)
    def _packet_in_handler(self, ev):
        msg = ev.msg
        datapath = msg.datapath  #交换机
        ofproto = datapath.ofproto
        parser = datapath.ofproto_parser
        # get Datapath ID to identify OpenFlow switches.
        dpid = datapath.id  #dpip区分交换机
        self.mac_to_port.setdefault(dpid, {})  #设置该交换机的MAC地址表
        # analyse the received packets using the packet library.
        pkt = packet.Packet(msg.data)  # packet.Packet A packet decoder/encoder class.
        eth_pkt = pkt.get_protocol(ethernet.ethernet)  #获得以太网的协议(头)
        dst = eth_pkt.dst
        src = eth_pkt.src
        # get the received port number from packet_in message.
        in_port = msg.match[in_port]
        self.logger.info("packet in %s %s %s %s", dpid, src, dst, in_port)
        # learn a mac address to avoid FLOOD next time.
        self.mac_to_port[dpid][src] = in_port

        # if the destination mac address is already learned,
        # decide which port to output the packet, otherwise FLOOD.
        if dst in self.mac_to_port[dpid]:
            out_port = self.mac_to_port[dpid][dst]
        else:
            out_port = ofproto.OFPP_FLOOD  #将输出端口指定为洪泛
        # construct action list.
        actions = [parser.OFPActionOutput(out_port)]
        # install a flow to avoid packet_in next time.
        if out_port != ofproto.OFPP_FLOOD:  #端口已学习,下发流表项
            match = parser.OFPMatch(in_port=in_port, eth_dst=dst)
            self.add_flow(datapath, 1, match, actions)
        # construct packet_out message and send it.
        out = parser.OFPPacketOut(datapath=datapath,
                                  buffer_id=ofproto.OFP_NO_BUFFER,
                                  in_port=in_port, actions=actions,
                                  data=msg.data)
        datapath.send_msg(out)  #send packetout
simpleSwitch

 

 

 

 

  首先,控制器接收交换机发送的packet-in包学习MAC地址。则交换机分析接收到的数据包中的发送方和接收方主机的MAC地址以及接收到消息的端口信息,在自己的流表中进行匹配,若失配,则将这些信息通过packet-in传给控制器;若成功匹配,则根据流表项将数据包传到指定的端口,而控制器不介入。

  当接收的数据包在交换机上失配,控制器通过packet-in进行学习,之后将接收到数据包进行传输:

  1、若目的主机地址控制器已经学习到,则使用packet-out包向交换机下发流表项,交换机根据本该流表项从指定端口传出数据包。

  2、若目的主机地址控制器未曾学习到,则使用packet-out包向交换机下发洪泛指令(flooding),交换机将数据包从除源端口外的所有端口传出。

 

二、使用Ryu实现:

1、控制器类定义和初始化:

为了实现Ryu应用,

1)需要继承ryu.base.app_manager.RyuApp类,

2)通过OFP_VERSION指定Openflow的版本,

3)定义MAC地址表mac_to_port

    class ExampleSwitch13(app_manager.RyuApp):
      OFP_VERSIONS
= [ofproto_v1_3.OFP_VERSION]
      
def __init__(self, *args, **kwargs):         super(ExampleSwitch13, self).__init__(*args, **kwargs)         # initialize mac address table.         self.mac_to_port = {}     # ...

 

2、事件处理(event handler)

  使用Ryu控制器,当接收到Openflow消息时,产生一个与消息一致的事件。Ryu应用需要实现一个和应用期望收到信息相一致的event handler。

  event handler是一个以事件对象为参数且使用ryu.controller.handler.set_ev_cls装饰器装饰的函数。set_ev_cls装饰器使用事件类型(event class)和Openflow交换机状态为参数。

  事件类型以ryu.controller.ofp_event.EventOFP + <OpenFlow message name>命名。例:Packet-in message的事件类型为ofp_event.EventOFPPacketIn。

  交换机状态(state):

技术分享图片

 

 

2.1 添加Table-miss Flow Entry

  在控制器和交换机handshake之后,在流表中添加Table-miss Flow Entry以准备接收Packet-in消息。具体来说,是在接收到Switch Feature(Feature Reply) message后添加。

      @set_ev_cls(ofp_event.EventOFPSwitchFeatures, CONFIG_DISPATCHER)
      def switch_features_handler(self, ev):
          datapath = ev.msg.datapath
          ofproto = datapath.ofproto
          parser = datapath.ofproto_parser
        # ...

  在ev.msg中存放着与事件一致的Openflow message的实例,此处message为ryu.ofproto.ofproto_v1_3_parser.OFPSwitchFeatures。

  在msg.datapath中存放着与发出message的交换机一致的ryu.controller.controller.Datapath类的实例,这个类用于描述Openflow交换机。Datapath类承担着非常重要的任务:与交换机通信和保证event和message一致。datapath中常用的属性有:

技术分享图片

  Datapath类中被Ryu应用用到的主要的方法是:send_msg(msg),用于发送Openflow message。其中msg是ryu.ofproto.ofproto_parser.MsgBase类的子类,与要发送的Openflow message一致。

 

  Switching hub不会使用Switch Feature message本身,而是通过处理这个event得到一个添加Table-miss flow Entry的时机。

 

      def switch_features_handler(self, ev):
          # ...
          # install the table-miss flow entry.
          match = parser.OFPMatch()
          actions = [parser.OFPActionOutput(ofproto.OFPP_CONTROLLER,
          ofproto.OFPCML_NO_BUFFER)]
          self.add_flow(datapath, 0, match, actions)

 

  Table-miss flow entry拥有最低的优先级(0),这个表项能够匹配上所有数据包,该表项的指令将output action指定为输出到控制器的端口,发出Packet-in消息。

  首先,一个空匹配用来匹配所有数据包,OFPMatch类用作匹配。

  然后,一个OUTPUT action类的实例OFPActionOutput生成并传输到控制器端口,控制器为output的目的地并且OFPCML_NO_BUFFER被设置为max_len(设置交换机的缓存),用于接收所有数据包

  最后,通过add_flow()方法发送Flow Mod message,将Table-miss Flow Entry下发至交换机流表中。

 

2.2 Packet-in Message:

  创建一个packet_in_handler用于接受收到的目的未知的数据包。

 

      @set_ev_cls(ofp_event.EventOFPPacketIn, MAIN_DISPATCHER)
      def _packet_in_handler(self, ev):
          msg = ev.msg
          datapath = msg.datapath
          ofproto = datapath.ofproto
          parser = datapath.ofproto_parser
        # ...

 

  ev.msg是event对应的message,此处为ryu.ofproto.ofproto_v1_3_parser.OFPPacketIn,其中常用属性有:

技术分享图片

 

2.3 更新MAC地址表:

    def _packet_in_handler(self, ev):
    # ...
        # get the received port number from packet_in message.
        in_port = msg.match[in_port]
        self.logger.info("packet in %s %s %s %s", dpid, src, dst, in_port)
        # learn a mac address to avoid FLOOD next time.
        self.mac_to_port[dpid][src] = in_port
    # ...

  使用OFPPacketIn中match方法获得in_port。目的MAC和源MAC通过Ryu’s packet library在接收到的数据包的以太网头部中获取。

  为支持控制器与多个交换机连接,datapath ID用于区分不同的交换机。

 

2.4判断传输的目的端口:

  当目的MAC地址存在于MAC地址表中时,目的MAC地址对应的端口号也在表中可以得到。如果目的MAC未知,OUTPUT action类的实例指定洪泛(OFPP_FLOOD),并产生目的端口。

 

        def _packet_in_handler(self, ev):
        # ...
            # if the destination mac address is already learned,
            # decide which port to output the packet, otherwise FLOOD.
            if dst in self.mac_to_port[dpid]:
               out_port = self.mac_to_port[dpid][dst]
            else:
              out_port = ofproto.OFPP_FLOOD
             # construct action list.
            actions = [parser.OFPActionOutput(out_port)]
           # install a flow to avoid packet_in next time.
           if out_port != ofproto.OFPP_FLOOD:
             match = parser.OFPMatch(in_port=in_port, eth_dst=dst)
             self.add_flow(datapath, 1, match, actions)
        # ...  

   如果目的地址已经被学习到,那么需要向交换机下发一条流表项,设置好匹配规则(match)、优先级和action,再调用add_flow()方法。这次优先级设为1,这条表项将在Table-miss flow entry之前进行参与匹配。

  通过Openflow,让数据包都传输到指定端口,这样使Openflow switch表现得像一个switching hub(switching hub给我的感觉就是一个传统交换机)。

 

2.5添加流表项(add_flow):

 

    def add_flow(self, datapath, priority, match, actions):
        ofproto = datapath.ofproto
        parser = datapath.ofproto_parser
        # construct flow_mod message and send it.
        inst = [parser.OFPInstructionActions(ofproto.OFPIT_APPLY_ACTIONS,actions)]
    # ...

   对于要添加的表项,设置match用于指明目标数据包的条件(target packet conditions)、instruction用于指明在目标数据包上的操作、表项优先级和有效时间。

  在上面代码中的APPLY_ACTIONS用于指明设置的action立即被使用。

  最后发出Flow Mod message添加表项到流表。

      def add_flow(self, datapath, priority, match, actions):
          # ...
          mod = parser.OFPFlowMod(datapath=datapath, priority=priority,
          match=match, instructions=inst)
          datapath.send_msg(mod)

   Flow Mod message对应着OFPFlowMod类。将OFPFlowMod实例化并使用Datapath.send_msg()方法发送到Openflow交换机。

OFPFlowMod的构造器有很多参数,通常很多都有默认值:

技术分享图片

 

1)datapath:Datapath的实例,通常从event对应的msg中获得。

2)cookie (0):由控制器设置的可选参数,在更新或删除流表项是用作过滤。

3)cookie_mask (0):在更新或删除流表项时,当该参数值非0时,用流表项的cookie值来过滤对目标表项的操作。

4)table_id (0):用于指定操作的目标流表。

5)command (ofproto_v1_3.OFPFC_ADD):用于指明进行什么操作:

技术分享图片

 

 

技术分享图片

 

6)idle_timeout (0):指明表项的有效期,单位为秒,如果表项一直未被引用,当idle_timeout时间用完,该表项将被删除,当表项被引用时,该参数值重置。

7)hard_timeout (0):指明表项的有效期,单位为秒,但是当表项被使用时参数值不会重置,时间用完则删除表项。

8)priority (0):优先级。

9)buffer_id (ofproto_v1_3.OFP_NO_BUFFER):指明数据包缓存到交换机哪个buffer。

10)out_port (0):当command为OFPFC_DELETE或OFPFC_DELETE_STRICT时,输出端口将对目标表项进行过滤,若command为其它,则忽略该参数。将值设为OFPP_ANY,输出端口不进行过滤。

11)out_group (0):功能与out_port相似,将值设为OFPG_ANY,输出端口不进行过滤。

12)flags (0):下列flag可组合使用。

技术分享图片

13)match (none):指定match。

14)instructions ([]):指定指令列表。

 

2.6 数据包传输:

Packet-In handler最后一个步骤是数据包传输。

无论是否在MAC地址表中找到目的地址,最后都要发出Packet-out message并且交换机将传输收到的数据包。 

        def _packet_in_handler(self, ev):
        # ...
            # construct packet_out message and send it.
            out = parser.OFPPacketOut(datapath=datapath,buffer_id=ofproto.OFP_NO_BUFFER,
                          in_port=in_port, actions=actions,data=msg.data)         datapath.send_msg(out)

 Packet-out message对应OFPPacketOut类,其构造器的参数有:datapath、buffer_id、in_port、actions、data。

in_port:指定接收数据包的端口。

data:数据包的二进制数据,当buffer指定为OFP_NO_BUFFER时使用,当交换机上使用buffer时,可以忽略该参数。

Ryubook_1_switch_hub_源码

标签:self   des   out   manager   prot   simple   -o   parse   odi   

原文地址:https://www.cnblogs.com/jasonlixuetao/p/9549069.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!