网络监控【C4-python代码-源码学习】（mininet+ryu控制器）
学习记录
文章目录
- 1.将代码复制粘贴到 ryu/ryu/app目录下，保存为python文件。
- 2.打开一个终端Terminal
- 3.再打开一个终端Terminal
- 1.搭建拓扑
- 2.配置信息
- 3.运行
- 4.回到mininet的终端界面
- 结束
源码引用自 基于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
点另一个终端看输出信息
结束
本文来自互联网用户投稿，文章观点仅代表作者本人，不代表本站立场，不承担相关法律责任。如若转载，请注明出处。 如若内容造成侵权/违法违规/事实不符，请点击【内容举报】进行投诉反馈！