网络监控【C4-python代码-源码学习】（mininet+ryu控制器）

学习记录

• 1.将代码复制粘贴到 ryu/ryu/app目录下，保存为python文件。
• 2.打开一个终端Terminal
• 3.再打开一个终端Terminal
• • 1.搭建拓扑
  • 2.配置信息
  • 3.运行
• 4.回到mininet的终端界面
• 结束

源码引用自 基于ryu实现网络的流量监控–monitor

from operator import attrgetter
 
from ryu.app import simple_switch_13
from ryu.controller.handler import set_ev_cls
from ryu.controller.handler import MAIN_DISPATCHER, DEAD_DISPATCHER
from ryu.controller import ofp_event
from ryu.lib import hub
 
 
class MyMonitor(simple_switch_13.SimpleSwitch13):
    def __init__(self, *args, **kwargs):
        super(MyMonitor, self).__init__(*args, **kwargs)
        self.datapaths = {}
        self.monitor_thread = hub.spawn(self._monitor_send_datapath)
 
    @set_ev_cls(ofp_event.EventOFPStateChange,
                [MAIN_DISPATCHER, DEAD_DISPATCHER])
    def _state_change_handler(self, ev):
        """方法用于对交换机的状态进行监听，比如上线或者下线
        例如：
        ryu.controller.handler.HANDSHAKE_DISPATCHER     交换 HELLO 讯息
        ryu.controller.handler.CONFIG_DISPATCHER       接收SwitchFeatures讯息
        ryu.controller.handler.MAIN_DISPATCHER    一般状态
        ryu.controller.handler.DEAD_DISPATCHER    联机中断"""
        datapath = ev.datapath
        if ev.state == MAIN_DISPATCHER:
            if datapath.id not in self.datapaths:
                self.datapaths[datapath.id] = datapath
        elif ev.state == DEAD_DISPATCHER:
            if datapath.id in self.datapaths:
                del self.datapaths[datapath.id]
 
    def _monitor_send_datapath(self):
        """周期性的换机发送请求数据
        通过调用_request_status方法"""
        while True:
            for dp in self.datapaths.values():
                self._request_status(dp)
            hub.sleep(10)
 
    def _request_status(self, datapath):
        """方法用于控制器向交换机发送状态请求信息，
        比如说端口状态信息请求、流表状态信息请求等
        datapath是传递的交换机参数，用于明确向哪一个交换机发送请求信息"""
 
        """对于方法的实现
        在ofproto_v1_3_parser中有例子进行解释
        Example::
        def send_port_stats_request(self, datapath):
            ofp = datapath.ofproto
            ofp_parser = datapath.ofproto_parser
            req = ofp_parser.OFPPortStatsRequest(datapath, 0, ofp.OFPP_ANY)
            datapath.send_msg(req)"""
 
        ofproto = datapath.ofproto
        parser = datapath.ofproto_parser
 
        req = parser.OFPFlowStatsRequest(datapath)
        datapath.send_msg(req)
 
        req = parser.OFPPortStatsRequest(datapath, 0, ofproto.OFPP_ANY)
        datapath.send_msg(req)
 
    @set_ev_cls(ofp_event.EventOFPFlowStatsReply, MAIN_DISPATCHER)
    def _flow_status_reply_handler(self, ev):
        """方法用来解析交换机返回的流表的数据，并将其在终端中打印出来"""
        body = ev.msg.body
        self.logger.info('datapath         '
                         'in-port  eth-dst           '
                         'out-port packets  bytes')
        self.logger.info('---------------- '
                         '-------- ----------------- '
                         '-------- -------- --------')
        for stat in sorted([flow for flow in body if flow.priority == 1],
                           key=lambda flow: (flow.match['in_port'],
                                             flow.match['eth_dst'])):
            self.logger.info('%016x %8x %17s %8x %8d %8d',
                             ev.msg.datapath.id,
                             stat.match['in_port'], stat.match['eth_dst'],
                             stat.instructions[0].actions[0].port,
                             stat.packet_count, stat.byte_count)
 
    @set_ev_cls(ofp_event.EventOFPPortStatsReply, MAIN_DISPATCHER)
    def _port_status_reply_handler(self, ev):
        """方法用来解析交换机返回的流表的数据，并将其在终端中打印出来"""
        body = ev.msg.body
 
        self.logger.info('datapath         port     '
                         'rx-pkts  rx-bytes rx-error '
                         'tx-pkts  tx-bytes tx-error')
        self.logger.info('---------------- -------- '
                         '-------- -------- -------- '
                         '-------- -------- --------')
        for stat in sorted(body, key=attrgetter('port_no')):
            self.logger.info('%016x %8x %8d %8d %8d %8d %8d %8d',
                             ev.msg.datapath.id, stat.port_no,
                             stat.rx_packets, stat.rx_bytes, stat.rx_errors,
                             stat.tx_packets, stat.tx_bytes, stat.tx_errors)

进入目录ryu/ryu/ryu/app.
输入：

ryu-manager --verbose xffapp.py(自定义python文件名)

进入目录 mininet/mininet/examples.
输入：

sudo ./miniedit.py

然后输入密码：

进入mininet可视化界面，搭建拓扑

右键-properties:

c0:

s1:

h1:

edit-preference:

配置好点run

输入

h1 ping h2

点另一个终端看输出信息