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

学习记录

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

1.将代码复制粘贴到 ryu/ryu/app目录下，保存为python文件。

from operator import attrgetterfrom 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 hubclass 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.datapathif ev.state == MAIN_DISPATCHER:if datapath.id not in self.datapaths:self.datapaths[datapath.id] = datapathelif 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.ofprotoofp_parser = datapath.ofproto_parserreq = ofp_parser.OFPPortStatsRequest(datapath, 0, ofp.OFPP_ANY)datapath.send_msg(req)"""ofproto = datapath.ofprotoparser = datapath.ofproto_parserreq = 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.bodyself.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.bodyself.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)

2.打开一个终端Terminal

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

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

3.再打开一个终端Terminal

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

sudo ./miniedit.py

然后输入密码：

1.搭建拓扑

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

2.配置信息

右键-properties:

c0:

s1:

h1:

edit-preference:

3.运行

配置好点run

4.回到mininet的终端界面

输入

h1 ping h2

点另一个终端看输出信息

结束