关于您问题的第一部分,让我们看一个基本的第 2 层交换机,它只是将传入的数据包泛洪到所有输出端口:
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
dp = msg.datapath
ofp = dp.ofproto
ofp_parser = dp.ofproto_parser
actions = [ofp_parser.OFPActionOutput(ofp.OFPP_FLOOD)]
out = ofp_parser.OFPPacketOut(
datapath=dp, buffer_id=msg.buffer_id, in_port=msg.in_port,
actions=actions)
dp.send_msg(out)
最后两个语句是
out = ofp_parser.OFPPacketOut(
datapath=dp, buffer_id=msg.buffer_id, in_port=msg.in_port,
actions=actions)
dp.send_msg(out)
这些语句会生成一条packet_out
消息,但是,我认为不会为packet_out
消息引发相应的事件(就像packet_in
消息会生成EventOFPPacketIn
可以在代码中检测到的事件,并且可以附加一个方法)。我没有太多使用 Ryu API,但我认为原因很简单。通过packet_out
代码本身发送消息,您可以在生成此事件的行之后简单地添加几行代码。packet_out
这几行可以在生成消息时执行您想要执行的任何操作。例如,在上面的代码中,您可以在该行之后添加将控制流量镜像到特定端口的dp.send_msg(out)
行。如果我错了,请更正/编辑我的答案。