Ryu控制器:L2交换功能实现案例

基于 Ryu控制器 在 VM1--OVS--VM2 的简单拓扑中实现流量自动下发(流表动态安装)的完整案例。通过该案例,当VM1与VM2首次通信时,Ryu控制器会动态学习路径并下发流表,后续流量将直接由交换机转发,无需控制器介入。
1. 环境准备
(1) 拓扑结构
VM1 (10.0.0.1) <--> Open vSwitch (OVS) <--> VM2 (10.0.0.2)
- OVS:模拟软件交换机,运行OpenFlow协议(如OpenFlow 1.3)。
- Ryu控制器:负责动态下发流表。
- VM1/VM2:可以是虚拟机、容器或Mininet模拟的主机。
(2) 工具依赖
- Mininet:用于快速创建虚拟网络拓扑(可选,但推荐用于实验)。
- Open vSwitch:安装并启动OVS服务。
- Ryu控制器:已安装
ryuPython库。
2. 实现步骤
(1) 创建网络拓扑
使用Mininet创建拓扑(若使用真实虚拟机,可跳过此步):
# 启动Mininet,创建一个OVS交换机连接两个主机
sudo mn --topo single,2 --mac --switch ovsk,protocols=OpenFlow13 --controller remote
--switch ovsk:指定使用Open vSwitch。--controller remote:指定Ryu控制器IP(默认连接到本地127.0.0.1:6653)。
(2) 编写Ryu自动下发流表应用
创建一个Python文件(如auto_flow.py),实现以下逻辑:
from ryu.base import app_manager
from ryu.controller import ofp_event
from ryu.controller.handler import MAIN_DISPATCHER, CONFIG_DISPATCHER
from ryu.controller.handler import set_ev_cls
from ryu.ofproto import ofproto_v1_3class AutoFlow(app_manager.RyuApp):OFP_VERSIONS = [ofproto_v1_3.OFP_VERSION] # 使用OpenFlow 1.3def __init__(self, *args, **kwargs):super(AutoFlow, self).__init__(*args, **kwargs)self.mac_to_port = {} # 记录MAC地址到交换机端口的映射@set_ev_cls(ofp_event.EventOFPSwitchFeatures, CONFIG_DISPATCHER)def switch_features_handler(self, ev):# 交换机连接时,下发默认流表(丢弃未知流量)datapath = ev.msg.datapathofproto = datapath.ofprotoparser = datapath.ofproto_parser# 添加默认的table-miss流表项,将未知流量发送到控制器match = parser.OFPMatch()actions = [parser.OFPActionOutput(ofproto.OFPP_CONTROLLER, ofproto.OFPCML_NO_BUFFER)]self.add_flow(datapath, 0, match, actions)@set_ev_cls(ofp_event.EventOFPPacketIn, MAIN_DISPATCHER)def packet_in_handler(self, ev):# 处理Packet-In事件,动态学习MAC地址并下发流表msg = ev.msgdatapath = msg.datapathofproto = datapath.ofprotoparser = datapath.ofproto_parserin_port = msg.match['in_port']# 解析以太网帧头部pkt = packet.Packet(msg.data)eth = pkt.get_protocols(ethernet.ethernet)[0]dst_mac = eth.dstsrc_mac = eth.src# 记录MAC地址与端口的映射关系self.mac_to_port.setdefault(datapath.id, {})self.mac_to_port[datapath.id][src_mac] = in_port# 如果目标MAC已学习,下发流表;否则泛洪if dst_mac in self.mac_to_port[datapath.id]:out_port = self.mac_to_port[datapath.id][dst_mac]else:out_port = ofproto.OFPP_FLOOD # 泛洪# 构造动作列表actions = [parser.OFPActionOutput(out_port)]# 如果非泛洪,则下发流表以加速后续流量if out_port != ofproto.OFPP_FLOOD:match = parser.OFPMatch(in_port=in_port, eth_dst=dst_mac)self.add_flow(datapath, 1, match, actions)# 发送数据包到目标端口out = parser.OFPPacketOut(datapath=datapath,buffer_id=msg.buffer_id,in_port=in_port,actions=actions)datapath.send_msg(out)def add_flow(self, datapath, priority, match, actions):# 下发流表到交换机ofproto = datapath.ofprotoparser = datapath.ofproto_parser# 构造FlowMod消息inst = [parser.OFPInstructionActions(ofproto.OFPIT_APPLY_ACTIONS, actions)]mod = parser.OFPFlowMod(datapath=datapath,priority=priority,match=match,instructions=inst)datapath.send_msg(mod)
(3) 启动Ryu控制器
运行自定义的Ryu应用:
ryu-manager --verbose auto_flow.py
--verbose:显示详细日志,便于调试。
(4) 测试流量触发流表下发
在Mininet或真实环境中执行以下操作:
# 在VM1上ping VM2(首次触发Packet-In)
mininet> h1 ping h2
- 第一次Ping:OVS无流表匹配,数据包发送到控制器,Ryu学习MAC地址并下发流表。
- 后续Ping:流量直接由交换机转发(查看OVS流表确认):
sudo ovs-ofctl -O OpenFlow13 dump-flows ovs-switch
3. 关键机制解析
-
流表初始化:
- 交换机连接时,控制器下发默认流表(优先级0),将未知流量重定向到控制器。
-
MAC学习:
- 当
Packet-In事件发生时,控制器记录源MAC地址和入端口,构建MAC表。
- 当
-
动态流表下发:
- 若目标MAC地址已学习,控制器下发精确匹配的流表(优先级1),后续流量直接转发。
- 若未学习,则泛洪(Flood)数据包以发现目标主机。
4. 验证与调试
(1) 查看OVS流表
sudo ovs-ofctl -O OpenFlow13 dump-flows ovs-switch
输出示例:
cookie=0x0, duration=10s, table=0, priority=1,dl_dst=00:00:00:00:00:02 actions=output:2
cookie=0x0, duration=5s, table=0, priority=0 actions=CONTROLLER:65535
(2) 抓包验证
在OVS上抓包,观察首次Ping的ICMP请求经过控制器,后续请求直接转发:
sudo tcpdump -i ovs-switch-eth1 # 监控VM1连接的端口
5. 扩展场景
- 多交换机拓扑:在更复杂的拓扑中,Ryu可通过LLDP协议自动发现网络拓扑,实现跨交换机流表下发。
- QoS策略:在
add_flow方法中添加Meter表限速动作。 - 安全控制:结合MAC白名单或IP黑名单动态拦截流量。
总结
通过此案例,可以看到Ryu如何利用Packet-In事件动态学习网络状态并下发流表,实现类似传统交换机的自学习功能,同时保留了SDN的可编程优势。此方案适用于小型网络或实验环境,若需高性能生产部署,可结合硬件加速或分布式控制器架构。
相关文章:
Ryu控制器:L2交换功能实现案例
基于 Ryu控制器 在 VM1--OVS--VM2 的简单拓扑中实现流量自动下发(流表动态安装)的完整案例。通过该案例,当VM1与VM2首次通信时,Ryu控制器会动态学习路径并下发流表,后续流量将直接由交换机转发,无需控制器介…...
动手学深度学习2025.2.23-预备知识之-线性代数
3.线性代数 (1)向量维数和张量维数的区别: (2)普通矩阵乘法: 要求左矩阵的列数等于右矩阵的行数 import torch # 创建两个矩阵 A torch.tensor([[1, 2], [3, 4]], dtypetorch.float32) B torch.tensor([[5, 6], [7, 8]], d…...
登录-07.JWT令牌-登录后下发令牌
一.思路 我们首先完成令牌生成。 在响应数据这一块 该响应数据是一个标准的Result结构,其中"data"的值就是一个JWT令牌。因此我们只需要将生成的JWT令牌封装在Result当中然后返回给前端即可。 备注是给前端看的,不用管。以后我们做校验时&…...
机器学习实战(7):聚类算法——发现数据中的隐藏模式
第7集:聚类算法——发现数据中的隐藏模式 在机器学习中,聚类(Clustering) 是一种无监督学习方法,用于发现数据中的隐藏模式或分组。与分类任务不同,聚类不需要标签,而是根据数据的相似性将其划…...
【数据序列化协议】Protocol Buffers
一、为什么需要序列化? 数据跨平台/语言交互: 不同编程语言(如 Java、Python、Go)的数据结构不兼容,序列化提供统一的数据表示。例如:Java 的 HashMap 和 Python 的 dict 需转换为通用格式(如 …...
基于 Python 的电影市场预测分析系统设计与实现(源码 + 文档)
大家好,今天要和大家聊的是一款基于 Python 的“电影市场预测分析”系统的设计与实现。项目源码以及部署相关事宜请联系我,文末附上联系方式。 项目简介 基于 Python 的“电影市场预测分析”系统主要面向以下用户角色:电影制片方、电影发行…...
计算机三级网络技术知识汇总【6】
第六章 交换机及其配置 1. 交换机基础 1.1 基本概念 局域网交换机是一种基于 MAC 地址识别,完成转发数据帧功能的一种网络连接设备。 工作在数据链路层,根据进入端口数据帧中的 MAC 地址进行数据帧的过滤、转发(也是交换机的工作原理&…...
2025教育与科研领域实战全解析:DeepSeek赋能细分场景深度指南(附全流程案例与资源)
🚀 2025教育与科研领域实战全解析:DeepSeek赋能细分场景深度指南(附全流程案例与资源)🚀 📚 目录 DeepSeek在教育与科研中的核心价值教学场景应用:从备课到课堂管理的全流程革新科研场景应用:从数据分析到论文写作的智能跃迁师生协同创新:AI赋能的个性化学习与科研…...
Linux 命令大全完整版(10)
4. 压缩与解压缩命令 gzip(gnu zip) 功能说明:压缩文件。语 法:gzip [-acdfhlLnNqrtvV][-S <压缩字尾字符串>][-<压缩效率>][–best/fast][文件…] 或 gzip [-acdfhlLnNqrtvV][-S <压缩字尾字符串>][-<压缩效率>][–best/f…...
彻底卸载kubeadm安装的k8s集群
目录 一、删除资源 二、停止k8s服务 三、重置集群 四、卸载k8s安装包 五、清理残留文件和目录 六、删除k8s相关镜像 七、重启服务器 一、删除资源 # 删除集群中的所有资源,包括 Pod、Deployment、Service,任意节点执行 kubectl delete --all pod…...
vue+element-plus简洁完美实现淘宝网站模板
目录 一、项目介绍 二、项目截图 1.项目结构图 2.首页 3.详情 4.购物车 5.登陆页 三、源码实现 1.路由配置 2.依赖包 四、总结 一、项目介绍 项目在线预览:点击访问 本项目为vue项目,参考淘宝官方样式为主题来设计元素,简洁美观&…...
学习aigc
DALLE2 论文 Hierarchical Text-Conditional Image Generation with CLIP Latents [2204.06125] Hierarchical Text-Conditional Image Generation with CLIP LatentsAbstract page for arXiv paper 2204.06125: Hierarchical Text-Conditional Image Generation with CLIP L…...
深度学习-127-LangGraph之基础知识(四)自定义状态添加额外字段的聊天机器人
文章目录 1 自定义状态2 自定义工具2.1 完善工具human_assistance2.2 浏览器工具baidu_search3 聊天机器人3.1 绑定工具的聊天模型3.2 聊天机器人(带记忆)4 调用图4.1 调用工具时中断4.2 人工提供信息恢复4.3 查询存储的状态4.4 手动更新状态5 参考附录使用LangGraph,在状态中…...
广东英语十二种应用文模版范文
1. 邀请信(Invitation Letter) 模版 Dear [Recipients Name],I hope this letter finds you well. I am writing to invite you to [Event Name] which will be held on [Date] at [Location]. The event will start at [Time] and we would be deligh…...
python使用httpx_sse调用sse流式接口对响应格式为application/json的错误信息的处理
目录 问题描述方案 问题描述 调用sse流式接口使用httpx_sse的方式 import httpxfrom httpx_sse import connect_sse# 省略无关代码try:with httpx.Client() as client:with connect_sse(client, "GET", url, paramsparam) as event_source:clear_textbox(response_t…...
Leetcode-407. Trapping Rain Water II [C++][Java]
目录 一、题目描述 二、解题思路 【C】 【Java】 Leetcode-407. Trapping Rain Water IIhttps://leetcode.com/problems/trapping-rain-water-ii/description/ 一、题目描述 Given an m x n integer matrix heightMap representing the height of each unit cell in a 2D…...
详解 torch.triu:上三角矩阵的高效构造(中英双语)
详解 torch.triu:上三角矩阵的高效构造 在深度学习和矩阵运算中,我们经常需要构造上三角矩阵(Upper Triangular Matrix),其中主对角线以下的元素全部设为 0。PyTorch 提供了一个高效的函数 torch.triu(),用…...
[ TypeScript ] “undefined extends xxx“ 总是为 true 的 bug
版本号 "typescript": "^5.7.3", "unplugin": "^2.2.0",说明 在使用 unplugin 时 , 我定义插件的参数是 必填的, 使用时却是一个可空参数, 不传参也不会报错, (options?: UserOptions) > Return 😲😲&…...
高清下载油管视频到本地
下载工具并安装: yt-dlp官网地址: GitHub - yt-dlp/yt-dlp: A feature-rich command-line audio/video downloader ffmpeg官网地址: Download FFmpeg 注:记住为其添加环境变量 操作命令: 该指令表示以720p码率下载VIDEO_UR…...
Hadoop常用操作命令
在NameNode节点格式化集群 初始化集群 hdfs namenode -format启动HDFS sbin/start-dfs.sh启动yarn sbin/start-yarn.sh启动NodeManager yarn-daemon.sh start nodemanager启动DataNode hadoop-daemon.sh start datanode启动SecondaryNameNode hadoop-daemon.sh start se…...
FPGA与ASIC设计优化:可移植性策略与实践
## 1. FPGA与ASIC设计优化概述现代数字系统设计中,FPGA和ASIC是两种关键实现方式。FPGA凭借其可重构特性,在原型验证和小批量产品中占据主导地位;而ASIC在大规模量产时展现出显著的性能和成本优势。本指南将深入探讨如何构建兼顾FPGA高效性和…...
终极免费打字学习工具:用Qwerty Learner打造你的键盘肌肉记忆系统
终极免费打字学习工具:用Qwerty Learner打造你的键盘肌肉记忆系统 【免费下载链接】qwerty-learner 为键盘工作者设计的单词记忆与英语肌肉记忆锻炼软件 / Words learning and English muscle memory training software designed for keyboard workers 项目地址: …...
汽车嵌入式系统中安全状态机的设计与实现
1. 汽车嵌入式系统中的状态机安全实现概述在汽车电子控制单元(ECU)开发中,状态机是实现复杂控制逻辑的核心架构。以电子节气门控制系统为例,当驾驶员踩下油门踏板时,系统需要处理来自多个传感器的信号,经过状态判断后输出相应的控…...
TQ2440开发板USB烧录驱动安装避坑指南(Win10/11禁用驱动签名)
TQ2440开发板USB驱动安装全攻略:突破Windows数字签名封锁 第一次拿到TQ2440开发板时的兴奋,很快被Windows那个红色的"第三方INF不包含数字签名信息"警告浇灭——这恐怕是每个嵌入式新手都会经历的"成人礼"。当你在设备管理器里看到那…...
别再到处搜了!OpenSSL/GmSSL SM2国密密钥生成与签名验签,这一篇命令大全就够了
SM2国密算法实战手册:OpenSSL与GmSSL全场景命令对照 当项目文档要求"采用SM2算法实现数字签名"时,有多少开发者会陷入搜索引擎、技术论坛和碎片化笔记的循环?这份手册将终结这种低效状态。不同于网络上零散的代码片段,我…...
SecGPT-14B作品集:15个真实安全问答+5个日志溯源对话实录
SecGPT-14B作品集:15个真实安全问答5个日志溯源对话实录 1. SecGPT-14B网络安全大模型介绍 SecGPT-14B是由云起无垠团队开发的开源网络安全大模型,专注于提升安全防护的智能化水平。该模型基于vLLM框架部署,并通过Chainlit前端提供交互式体…...
告别在线API:在嵌入式Linux上用Ekho TTS实现离线语音播报(避坑实录)
嵌入式Linux离线语音方案:Ekho TTS深度集成指南 在智能硬件开发领域,语音交互已成为提升用户体验的关键要素。然而,当项目部署在无网络环境的嵌入式设备时,传统在线TTS服务立刻暴露出致命缺陷——网络依赖性。我曾在一个工业级智能…...
【2026 Blazor生产环境黄金标准】:微软MVP亲测的11项安全加固清单(含OWASP Top 10 Blazor专项对策)
第一章:Blazor 2026生产环境安全治理全景图Blazor 2026 在企业级生产环境中已全面支持零信任架构(ZTA)与运行时策略即代码(Policy-as-Code),其安全治理不再依赖单一防护层,而是贯穿于组件生命周…...
【AI Agent工程实战系列⑤】多Agent系统:比单Agent难的不是技术而是协调
多Agent系统:比单Agent难的不是技术而是协调 AI Agent工程实战系列 第05篇 / 共10篇 Orchestrator模式、任务分解、冲突解决、结果聚合 以及为什么大多数多Agent系统最终退化成了单Agent 一个让我们返工三周的架构决策 去年我们给一个法律科技公司搭了一套合同审查系统。需求…...
空洞骑士模组管理革命:Lumafly一键安装300+模组的终极解决方案
空洞骑士模组管理革命:Lumafly一键安装300模组的终极解决方案 【免费下载链接】Lumafly A cross platform mod manager for Hollow Knight written in Avalonia. 项目地址: https://gitcode.com/gh_mirrors/lu/Lumafly Lumafly是一款专为《空洞骑士》玩家设…...
