Python中文网 - 问答频道, 解决您学习工作中的Python难题和Bug
Python常见问题
我正在使用用python编写的Ryu open flow controller开关来监视我的虚拟mininet中的数据包。我有3台主机，正在阻止从host2到host3和从host3到host2的传输。其他数据包被添加到交换流表中。 我的问题是，在添加流之后，如果它们是在交换机流表中有规则的两个主机之间的数据包，则不会触发我的事件。 例如，如果交换机看到从host1到host2的数据包，则该数据包是合法的，因此该流将被添加到表中，但如果从host1到host2的另一个数据包被发送，则它将不再通过该方法。我查看了Ryu指南，但是没有找到任何关于这个案例的信息，因为一个流已经被添加到交换流表中。 我怎样才能拿到包裹？
提前谢谢。
这是我的代码：
import logging
import struct
from ryu.base import app_manager
from ryu.controller import mac_to_port
from ryu.controller import ofp_event
from ryu.controller.handler import MAIN_DISPATCHER
from ryu.controller.handler import set_ev_cls
from ryu.ofproto import ofproto_v1_0
from ryu.lib.mac import haddr_to_str
class SimpleSwitch(app_manager.RyuApp):
OFP_VERSIONS = [ofproto_v1_0.OFP_VERSION]
counterTraffic=0
def __init__(self, *args, **kwargs):
super(SimpleSwitch, self).__init__(*args, **kwargs)
self.mac_to_port = {}
def add_flow(self, datapath, in_port, dst, actions):
ofproto = datapath.ofproto
wildcards = ofproto_v1_0.OFPFW_ALL
wildcards &= ~ofproto_v1_0.OFPFW_IN_PORT
wildcards &= ~ofproto_v1_0.OFPFW_DL_DST
match = datapath.ofproto_parser.OFPMatch(
wildcards, in_port, 0, dst,
0, 0, 0, 0, 0, 0, 0, 0, 0)
mod = datapath.ofproto_parser.OFPFlowMod(
datapath=datapath, match=match, cookie=0,
command=ofproto.OFPFC_ADD, idle_timeout=0, hard_timeout=0,
priority=ofproto.OFP_DEFAULT_PRIORITY,
flags=ofproto.OFPFF_SEND_FLOW_REM, actions=actions)
datapath.send_msg(mod)
@set_ev_cls(ofp_event.EventOFPPacketIn, MAIN_DISPATCHER)
def _packet_in_handler(self, ev):
print("Im in main function")
msg = ev.msg
datapath = msg.datapath
ofproto = datapath.ofproto
dst, src, _eth_type = struct.unpack_from('!6s6sH', buffer(msg.data), 0)
dpid = datapath.id
self.mac_to_port.setdefault(dpid, {})
self.logger.info("packet in %s %s %s %s",
dpid, haddr_to_str(src), haddr_to_str(dst),
msg.in_port)
if (haddr_to_str(dst) == "00:00:00:00:00:01"):
print "dst"
self.counterTraffic +=1
if not ((haddr_to_str(src) == "00:00:00:00:00:02" and haddr_to_str(dst) =="00:00:00:00:00:03")or (haddr_to_str(src) == "00:00:00:00:00:03" and haddr_to_str(dst) =="00:00:00:00:00:02")):
# learn a mac address to avoid FLOOD next time.
print("after condition")
self.mac_to_port[dpid][src] = msg.in_port
if dst in self.mac_to_port[dpid]:
out_port = self.mac_to_port[dpid][dst]
else:
out_port = ofproto.OFPP_FLOOD
actions = [datapath.ofproto_parser.OFPActionOutput(out_port)]
# install a flow to avoid packet_in next time
if out_port != ofproto.OFPP_FLOOD:
self.add_flow(datapath, msg.in_port, dst, actions)
out = datapath.ofproto_parser.OFPPacketOut(
datapath=datapath, buffer_id=msg.buffer_id, in_port=msg.in_port,
actions=actions)
datapath.send_msg(out)
if (haddr_to_str(src) == "00:00:00:00:00:01"):
print "src"
self.counterTraffic +=1
print(self.counterTraffic)
@set_ev_cls(ofp_event.EventOFPPortStatus, MAIN_DISPATCHER)
def _port_status_handler(self, ev):
msg = ev.msg
reason = msg.reason
port_no = msg.desc.port_no
ofproto = msg.datapath.ofproto
if reason == ofproto.OFPPR_ADD:
self.logger.info("port added %s", port_no)
elif reason == ofproto.OFPPR_DELETE:
self.logger.info("port deleted %s", port_no)
elif reason == ofproto.OFPPR_MODIFY:
self.logger.info("port modified %s", port_no)
else:
self.logger.info("Illeagal port state %s %s", port_no, reason)
Tags： toinfromimportselfportmacmsg
热门问题
- Django:。是不是“超级用户”字段不起作用
- Django:'DeleteQuery'对象没有属性'add'
- Django:'ModelForm'对象没有属性
- Django:'python manage.py runserver'返回'TypeError:'WindowsPath'类型的对象没有len（）
- Django:'Python管理.pysyncdb'不创建我的架构表
- Django:'Python管理.py迁移“耗时数小时（和其他奇怪的行为）
- Django:'readonly'属性在我的ModelForm上不起作用
- Django:'RegisterEmployeeView'对象没有属性'object'
- Django:'str'对象没有属性'get'
- Django：'创建' 不能被指定为Order模型表单中的值，因为它是一个不可编辑的字段
- Django:“'QuerySet'类型的对象不是JSON可序列化的”
- Django:“'utf8'编解码器无法解码位置19983中的字节0xe9：无效的连续字节”，加载临时文件时
- Django:“<…>”需要有一个字段“id”的值，然后才能使用这个manytomy关系
- Django:“AnonymousUser”对象没有“get_full_name”属性
- Django:“ascii”编解码器无法解码位置1035中的字节0xc3：序号不在范围内（128）
- Django:“BaseTable”对象不支持索引
- Django:“collections.OrderedDict”对象不可调用
- Django:“Country”对象没有属性“all”
- Django:“Data”对象没有属性“save”
- Django:“datetime”类型的对象不是JSON serializab
热门文章
- Python覆盖写入文件
- 怎样创建一个 Python 列表？
- Python3 List append()方法使用
- 派森语言
- Python List pop()方法
- Python Django Web典型模块开发实战
- Python input() 函数
- Python3 列表(list) clear()方法
- Python游戏编程入门
- 如何创建一个空的set?
- python如何定义(创建)一个字符串
- Python标准库 [The Python Standard Library by Ex
- Python网络数据爬取及分析从入门到精通（分析篇）
- Python3 for 循环语句
- Python List insert() 方法
- Python 字典(Dictionary) update()方法
- Python编程无师自通 专业程序员的养成
- Python3 List count()方法
- Python 网络爬虫实战 [Web Crawler With Python]
- Python Cookbook（第2版）中文版
简而言之，你正在正确解码目标mac地址。。。然而，IP必须ARP来解析mac地址，这就是为什么您看到
ff:ff:ff:ff:ff:ff。。。这些只是ryu controller中的ARP帧。我建立了一个完整的控制器，解码到下面的IPv4层。。。
更新的ryu交换包解码器
您已经对原始数据包进行了解码，但是使用ryu Packet library比解包原始数据包要容易得多。这是我对
_packet_in_handler()的快速替换，它只输出源和目标mac地址，以及上层协议。。。现在，无论何时发送以太网数据包，您都会在mininet会话中看到这一点。。。
ARP包看起来像这样。。。
演示
假设我将上面修改过的代码（包括源代码的其他部分）保存为
ne_question.py。ff:ff:ff:ff:ff:ff。顺便说一句，如果您将wget更改为h2 wget h1，则一切正常。。。相关问题 更多 >
编程相关推荐