六、vpp 流表+负载均衡

草稿！！！

vpp node其实就是三个部分
1、plugin init
2、set command
3、function 实现功能，比如这里的流表

今天我们再用VPP实现一个流表的功能

一、流表

1.1流表----plugin init

VLIB_REGISTER_NODE 注册流表节点

// 注册流表节点
VLIB_REGISTER_NODE(flowtable_node) = {.function = flowtable_getinfo, // 节点处理函数.name = "flow-table", // 节点名称.vector_size = sizeof(u32), // 向量大小.format_trace = format_flowtable_getinfo, // 跟踪格式函数.type = VLIB_NODE_TYPE_INTERNAL, // 节点类型为内部节点.n_errors = FLOWTABLE_N_ERROR, // 错误数目.error_strings = flowtable_error_strings, // 错误字符串数组.n_next_nodes = FT_NEXT_N_NEXT, // 下一个节点数目.next_nodes = {[FT_NEXT_IP4] = "ip4-lookup",[FT_NEXT_DROP] = "error-drop",[FT_NEXT_ETHERNET_INPUT] = "ethernet-input",[FT_NEXT_LOAD_BALANCER] = "load-balance",[FT_NEXT_INTERFACE_OUTPUT] = "interface-output",} // 下一个节点的映射
};// 注册插件
VLIB_PLUGIN_REGISTER() = {.version = "1.0", // 插件版本.description = "sample of flowtable", // 插件描述
};

1.2 流表-----command 解析

接收到命令后，调用注册好的回调函数flowtable_command_enable_fn，最后会通过VPP自带的vnet_hw_interface_rx_redirect_to_node函数将硬件接口的接收流量重定向到指定节点，这里就是我们的流表节点

// 启用或禁用流表功能,将硬件接口的接收流量重定向到指定节点
int flowtable_enable(flowtable_main_t *fm,u32 sw_if_index,int enable){// 如果启用，获取流表节点的索引；如果禁用，则设置索引为无效值u32 node_index = enable ? flowtable_node.index : ~0;printf("debug:[%s:%s:%d] node_index:%d\n", __FILE__, __func__, __LINE__, flowtable_node.index);// 调用 VPP 的函数，将硬件接口的接收流量重定向到指定节点return vnet_hw_interface_rx_redirect_to_node(fm->vnet_main,sw_if_index,node_index);
}static clib_error_t * flowtable_command_enable_fn(struct vlib_main_t *vm,unformat_input_t *input,struct vlib_cli_command_t *cmd){// 获取与流表相关的主数据结构flowtable_main_t * fm = &flowtable_main;u32 sw_if_index = ~0;// 初始化接口索引为无效值int enable_disable = 1;// 初始化启用/禁用标志为启用// 解析命令行输入，直到输入结束while(unformat_check_input(input) != UNFORMAT_END_OF_INPUT){// 如果输入中包含 "disable" 参数，则禁用流表功能if(unformat(input,"disable")){enable_disable = 0;}// 如果输入中包含接口索引，则解析并存储在 sw_if_index 中else if (unformat(input,"%U",unformat_vnet_sw_interface,fm->vnet_main,&sw_if_index)){}elsebreak;}// 如果没有指定接口索引，则返回错误if(sw_if_index == ~0){return clib_error_return(0,"No Interface specified");}// 调用流表启用/禁用函数int rv = flowtable_enable(fm,sw_if_index,enable_disable);if(rv){if(rv == VNET_API_ERROR_INVALID_SW_IF_INDEX){return clib_error_return(0,"Invalid interface");}else if(rv == VNET_API_ERROR_UNIMPLEMENTED){return clib_error_return(0,"Device driver doesn't support redirection");}else{return clib_error_return(0,"flowtable_enable_disable returned %d\n",rv);}}return 0;
}//命令行启动、关闭流表功能
VLIB_CLI_COMMAND(flowtable_interface_enable_disable_command) = {.path = "flowtable",.short_help = "flowtable <interface> [disable]",.function = flowtable_command_enable_fn, //对应的flowtable命令行回调函数
};

1.3 流表------function

经过上面，这是当网卡接收到数据，就会传到我们指定的流表功能函数进行处理

static uword flowtable_getinfo(struct vlib_main_t *vm,struct vlib_node_runtime_t *node,struct vlib_frame_t *frame){u32 n_left_from, *from,*to_next;u32 next_index = node->cached_next_index;printf("flowtable_getinfo cached_next_index: %u\n", next_index);from = vlib_frame_vector_args(frame);//获取指向帧向量数据的指针，即第一个数据包的地址n_left_from = frame->n_vectors;	// 获取向量数量，即有多少个数据包while(n_left_from > 0){u32 n_left_to_next;/*获取下一个节点的帧和向量，然后vlib_put_next_frame将当前节点处理的数据包添加到这个帧中，以便后续的节点可以处理这些数据包，最开始这里是获取的第一帧，一帧里面有多个vlib_buffer可以看做为二维数组*/vlib_get_next_frame(vm,node,next_index,to_next,n_left_to_next);/*n_left_to_next 是当前帧中剩余的空闲槽位数量,当值为0后，需要vlib_put_next_frame获取一个新的帧来继续传递数据包*/while(n_left_from > 0 && n_left_to_next > 0){vlib_buffer_t *b0;u32 bi0,next0 = 0;bi0 = to_next[0] = from[0];from += 1;to_next += 1;n_left_to_next -= 1;n_left_from -= 1;//它将 DPDK 的 rte_mbuf 转换为 VPP 的 vlib_buffer_t,vlib_buffer_t里面有多个rte_mbuf(数据包)b0 = vlib_get_buffer(vm,bi0);//取出当前需要处理的数据包ip4_header_t *ip0 = vlib_buffer_get_current(b0);ip4_address_t ip_src = ip0->src_address;ip4_address_t ip_dst = ip0->dst_address;//获取处理的数据包所到达的接口的软件索引，并将其存储在变量 sw_if_index0 中u32 sw_if_index0 = vnet_buffer(b0)->sw_if_index[VLIB_RX];//对每个数据包打印其源ip及目的ipstruct in_addr addr;addr.s_addr = ip_src.as_u32;printf("sw_if_index0: %d, ip_src: %s ", sw_if_index0, inet_ntoa(addr));addr.s_addr = ip_dst.as_u32;printf(" ip_dst: %s \n", inet_ntoa(addr));/*将当前处理的缓冲区 bi0 传递到下一个节点，同时更新 to_next 数组、n_left_to_next 计数和下一个节点的下一个节点索引 next0。这样，数据包将会在当前节点处理后传递到下一个节点进行进一步处理*/vlib_validate_buffer_enqueue_x1(vm,node,next_index,to_next,n_left_to_next,bi0,next0);}/*vlib_get_next_frame获取下一个节点的帧和向量，然后vlib_put_next_frame将当前节点处理的数据包添加到这个帧中，		以便后续的节点可以处理这些数据包*/vlib_put_next_frame(vm,node,next_index,n_left_to_next);}return frame->n_vectors; //这里决定接下来继续走哪一个node
}

这里的function函数有个返回值，根据返回值决定下一个节点走哪里
flowtable_getinfo这里处理函数返回2 ，则下一步走这个节点[FT_NEXT_ETHERNET_INPUT] = “ethernet-input”,
在这里插入图片描述

浅谈node

在一些系统中，节点的执行顺序可能是在程序初始化的时候静态确定的，特别是在构建数据处理流水线时。这种情况下，节点的顺序是在配置或初始化阶段定义的，然后在整个程序运行期间保持不变。

然而，在某些系统中，特别是对于一些灵活的数据流框架，节点的执行顺序可能是在程序运行时动态决定的。这可以通过某种策略或运行时的条件来调整节点的执行顺序，以适应实时需求或系统的动态变化。

总的来说，节点的执行顺序是取决于应用程序设计和需求的。一些系统更倾向于静态的、在初始化时确定的执行顺序，而其他系统则更注重在运行时根据动态需求来调整节点的执行顺序

在许多系统中，插件和节点的初始化顺序通常是通过配置文件、命令行参数或其他配置机制来确定的。这些配置通常在应用程序启动时被解析，并在初始化过程中用于指导插件和节点的加载和初始化。

以下是一些可能的方式来决定插件和节点的顺序：

配置文件： 应用程序可能会有一个配置文件，其中包含有关插件和节点的信息，包括它们的加载顺序。在应用程序启动时，解析配置文件并按照其中定义的顺序加载插件和节点。

命令行参数： 应用程序可能允许通过命令行参数来指定插件和节点的加载顺序。例如，通过在启动命令中指定参数来控制加载的插件和它们的顺序。

硬编码： 在某些情况下，加载顺序可能是硬编码在应用程序的源代码中的，即在代码中明确指定加载和初始化的顺序。

依赖关系： 插件和节点之间可能存在依赖关系，系统可以根据这些依赖关系来确定加载和初始化的顺序。例如，某个插件可能依赖于另一个插件的某些功能，因此必须在其之前加载。

具体的实现方式取决于系统的设计和开发者的选择。在某些情况下，可能会结合使用上述多种机制来达到更大的灵活性。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.hqwc.cn/news/125512.html

如若内容造成侵权/违法违规/事实不符，请联系编程知识网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

Ipython和Jupyter Notebook介绍

Ipython和Jupyter Notebook介绍

Ipython和Jupyter Notebook介绍 Python、IPython和Jupyter Notebook是三个不同但密切相关的工具。简而言之&#xff0c;Python是编程语言本身&#xff0c;IPython是对Python的增强版本&#xff0c;而Jupyter Notebook是一种在Web上进行交互式计算的环境&#xff0c;使用IPytho…
阅读更多...
1.1 数据库系统概述

1.1 数据库系统概述

思维导图&#xff1a; 前言&#xff1a; **数据库前言笔记&#xff1a;** 1. **数据库的价值** - 数据管理的高效工具 - 计算机科学的关键分支 2. **信息资源的重要性** - 现代企业或组织的生存和发展关键 - 建立有效的信息系统至关重要 3. **数据库的应用范围**…
阅读更多...
使用python-opencv检测图片中的人像

使用python-opencv检测图片中的人像

最简单的方法进行图片中的人像检测 使用python-opencv配合yolov3模型进行图片中的人像检测 1、安装python-opencv、numpy pip install opencv-python pip install numpy 2、下载yolo模型文件和配置文件&#xff1a; 下载地址&#xff1a; https://download.csdn.net/down…
阅读更多...
GEE16: 区域日均降水量计算

GEE16: 区域日均降水量计算

Precipitation 1. 区域日均降水量计算2. 降水时间序列3. 降水数据年度时间序列对比分析 1. 区域日均降水量计算 今天分析一个计算区域日均降水量的方法&#xff1a; 数据信息&#xff1a;   Climate Hazards Group InfraRed Precipitation with Station data (CHIRPS) is a…
阅读更多...
微信公众号模板消息First，Remark字段不显示，备注字段不见了

微信公众号模板消息First，Remark字段不显示，备注字段不见了

今天在开发公众号过程中有个需求发模板消息我设置的如下 成绩单打印通知&#xff01;姓名&#xff1a;{{name.DATA}} 学号&#xff1a;{{stuid.DATA}}状态&#xff1a;{{status.DATA}}时间&#xff1a;{{date.DATA}} 备注&#xff1a;{{remark.DATA}} 然后发完通知发现《…
阅读更多...
JAVA面经整理(8)

JAVA面经整理(8)

一)为什么要有区&#xff0c;段&#xff0c;页&#xff1f; 1)页是内存和磁盘之间交互的基本单位内存中的值修改之后刷到磁盘的时候还是以页为单位的索引结构给程序员提供了高效的索引实现方式&#xff0c;不过索引信息以及数据记录都是记录在文件上面的&#xff0c;确切来说是…
阅读更多...
MySql运维篇---008：日志：错误日志、二进制日志、查询日志、慢查询日志，主从复制：概述 虚拟机更改ip注意事项、原理、搭建步骤

MySql运维篇---008：日志：错误日志、二进制日志、查询日志、慢查询日志，主从复制：概述 虚拟机更改ip注意事项、原理、搭建步骤

1. 日志 1.1 错误日志 错误日志是 MySQL 中最重要的日志之一&#xff0c;它记录了当 mysqld 启动和停止时&#xff0c;以及服务器在运行过程中发生任何严重错误时的相关信息。当数据库出现任何故障导致无法正常使用时&#xff0c;建议首先查看此日志。 该日志是默认开启的&a…
阅读更多...
【算法学习】-【双指针】-【盛水最多的容器】

【算法学习】-【双指针】-【盛水最多的容器】

LeetCode原题链接&#xff1a;盛水最多的容器 下面是题目描述&#xff1a; 给定一个长度为 n 的整数数组 height 。有 n 条垂线&#xff0c;第 i 条线的两个端点是 (i, 0) 和 (i, height[i]) 。 找出其中的两条线&#xff0c;使得它们与 x 轴共同构成的容器可以容纳最多的水。…
阅读更多...
MySQL——使用mysqldump备份与恢复数据

MySQL——使用mysqldump备份与恢复数据

目录 1.mysqldump简介 2.mysqldump备份数据 2.1 备份所有数据库 2.2 备份一个/多个数据库 2.3 备份指定库中的指定表 3.mysqldump恢复数据 3.1 恢复数据库 3.2 恢复数据表 1.mysqldump简介 mysqldump命令可以将数据库中指定或所有的库、表导出为SQL脚本。表的结构和表中…
阅读更多...
基于transformer的心脑血管心脏病疾病预测

基于transformer的心脑血管心脏病疾病预测

视频讲解：基于transformer的心脑血管疾病预测 完整数据代码分享_哔哩哔哩_bilibili 数据展示： 完整代码： # pip install openpyxl -i https://pypi.tuna.tsinghua.edu.cn/simple/ # pip install optuna -i https://pypi.tuna.tsinghua.edu.cn/simple/ import numpy as np …
阅读更多...
常见的锁策略

常见的锁策略

目录 一.乐观锁 vs 悲观锁 二.轻量级锁 vs 重量级锁 三.自旋锁 vs 挂起等待锁 四.互斥锁 vs 读写锁 五.可重入锁 vs不可重入锁 一.乐观锁 vs 悲观锁 悲观锁 : 总是假设最坏的情况&#xff0c;每次去拿数据的时候都认为别人会修改&#xff0c;所以每次在拿数据的时候都会上锁…
阅读更多...
专题一：双指针【优选算法】

专题一：双指针【优选算法】

双指针应用场景&#xff1a; 数组划分、数组分块 目录 一、移动0 二、复写0 从后向前 三、快乐数 链表带环 四、盛水最多的容器 单调性双指针 五、有效三角形个数 单调性双指针 六、和为s的两个数字 七、三数之和 细节多 需再练 一、移动0 class Solution { public:void move…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023