基于POX与OpenFlow统计到达SDN交换机的UDP数据包数量

嘿，我来帮你搞定用POX控制器结合OpenFlow统计交换机UDP数据包的需求，结合你给出的Mininet拓扑，一步步来实现：

你提供的拓扑代码不完整，我帮你补全，确保它能正确连接到远程的POX控制器：

#!/usr/bin/python
""" Script created by VND - Visual Network Description (SDN version) """
from mininet.net import Mininet
from mininet.node import Controller, RemoteController, OVSKernelSwitch
from mininet.link import TCLink
from mininet.cli import CLI
from mininet.log import setLogLevel

def topology():
    "Create a network."
    # 指定使用远程控制器（POX），IP是本地回环，端口默认6633
    net = Mininet(controller=RemoteController, switch=OVSKernelSwitch, link=TCLink)
    
    print("*** Adding controller")
    # 添加POX控制器，名称c0，IP 127.0.0.1，端口6633
    net.addController('c0', controller=RemoteController, ip='127.0.0.1', port=6633)

    print("*** Adding hosts")
    # 添加两个测试主机h1和h2
    h1 = net.addHost('h1', ip='10.0.0.1/24')
    h2 = net.addHost('h2', ip='10.0.0.2/24')

    print("*** Adding switch")
    # 添加核心交换机s1
    s1 = net.addSwitch('s1')

    print("*** Creating links")
    # 连接主机与交换机
    net.addLink(h1, s1)
    net.addLink(h2, s1)

    print("*** Starting network")
    net.start()

    print("*** Running CLI")
    CLI(net)

    print("*** Stopping network")
    net.stop()

if __name__ == '__main__':
    setLogLevel('info')
    topology()

在POX的ext目录下新建一个udp_counter.py文件，这是实现统计功能的核心代码：

from pox.core import core
import pox.openflow.libopenflow_01 as of
from pox.lib.packet import packet, ipv4, udp

# 全局计数器，记录UDP数据包总数量
udp_packet_count = 0

log = core.getLogger()

def _handle_PacketIn(event):
    global udp_packet_count
    pkt = event.parsed
    
    # 先解析出IP层数据包
    if pkt.find('ipv4'):
        ip_pkt = pkt.find('ipv4')
        # 判断IP负载是否为UDP协议
        if ip_pkt.protocol == ipv4.UDP_PROTOCOL:
            udp_packet_count += 1
            log.info(f"收到UDP数据包，累计统计数量: {udp_packet_count}")
    
    # 添加流表项，让后续数据包直接转发（避免所有包都触发PacketIn事件）
    msg = of.ofp_flow_mod()
    msg.match = of.ofp_match.from_packet(pkt)
    msg.idle_timeout = 10
    msg.hard_timeout = 30
    msg.actions.append(of.ofp_action_output(port=of.OFPP_FLOOD))
    event.connection.send(msg)

def launch():
    # 监听OpenFlow的PacketIn事件，触发统计逻辑
    core.openflow.addListenerByName("PacketIn", _handle_PacketIn)
    log.info("UDP数据包统计模块已成功加载")

按以下顺序执行操作即可看到统计效果：

1. 启动POX控制器：在终端中运行命令，加载我们的统计模块和二层转发模块（确保主机能通信）

   ./pox.py log.level --DEBUG forwarding.l2_learning udp_counter
   

2. 启动Mininet拓扑：在另一个终端中运行你的拓扑脚本

   sudo python your_topology_script.py
   

3. 生成UDP流量测试：在Mininet的CLI中，用iperf生成UDP流量：

   # 在h1上启动UDP服务器
   h1 iperf -s -u &
   # 在h2上向h1发送10秒的UDP流量
   h2 iperf -c 10.0.0.1 -u -t 10
   

4. 查看统计结果：回到POX控制器的终端，你会看到每收到一个UDP数据包就打印累计数量，测试结束后就能看到总统计数。

• 如果你只想统计特定端口的UDP包，可以在判断逻辑中添加端口检查：比如先解析UDP层udp_pkt = ip_pkt.find('udp')，再判断udp_pkt.dstport == 5001这样的条件。
• 如果不需要默认的二层转发，可以只加载udp_counter模块，但此时需要手动添加流表项保证主机通信。

内容的提问来源于stack exchange，提问作者anon