简单RYU实现二层交换机泛洪代码解析

一个简单的交换机实现，使得交换机将所有收到的数据包在各个端口泛洪发送，代码如下：

from ryu.base import app_manager
from ryu.controller import ofp_event
from ryu.controller.handler import MAIN_DISPATCHER
from ryu.controller.handler import set_ev_cls
class L2Switch(app_manager.RyuApp):
    def __init__(self, *args, **kwargs):
        super(L2Switch, self).__init__(*args, **kwargs)
    @set_ev_cls(ofp_event.EventOFPPacketIn, MAIN_DISPATCHER)
    def packet_in_handler(self, ev):
        msg = ev.msg
        datapath = msg.datapath
        ofproto = datapath.ofproto
        ofp_parser = datapath.ofproto_parser

        actions = [ofp_parser.OFPActionOutput(ofp.OFPP_FLOOD)]
        out = ofp_parser.OFPPacketOut(
        datapath=datapath, buffer_id=msg.buffer_id,   in_port=msg.in_port,
        actions=actions)
        datapath.send_msg(out)

packet_in_handler函数的函数体：

• ev.msg：每一个事件类ev中都有msg成员，用于携带触发事件的数据包，（此处是packet_in的消息对象，存储着消息的数据部分）
• msg.datapath:已经格式化的msg其实就是一个packet_in报文，msg.datapath直接可以获得packet_in报文的datapath结构。datapath用于描述一个交换网桥。也是和控制器通信的实体单元。
• datapath.send_msg():函数用于发送数据到指定datapath。
• datapath.ofproto对象是一个OpenFlow协议数据结构的对象，成员包含OpenFlow协议的数据结构，如动作类型OFPP_FLOOD。
• datapath.ofp_parser则是一个按照OpenFlow解析的数据结构。
• actions是一个列表，用于存放action list，可在其中添加动作。
• 通过ofp_parser类，可以构造构造packet_out数据结构。括弧中填写对应字段的赋值即可。如果datapath.send_msg()函数发送的是一个OpenFlow的数据结构，RYU将把这个数据发送到对应的datapath。

每当RYU控制器收到OpenFlow协议中的packet_in消息时，packet_in_handler函数就会被调用，因为这个函数被注册到装饰器set_ev_cls中，并且装饰器将packet_in_handler注册到packet_in消息上，每当收到packet_in消息时就调用该函数。

set_ev_cls装饰器的参数：

• 第一个参数指触发函数的调用事件，这里指packet_in事件。
• 第二个参数指交换机的状态。比如，当交换机处于与控制器协商（negotiation）阶段时,可能你想忽略此时的packet_in消息，那我们就可以使用MAIN_DISPATCHER作为参数来表明当协商完成后该函数才被调用（即握手后才可以被调用）。