dpdk解析报文协议-基于l2fwd

2024-08-26 07:44
文章标签 协议 解析 报文 dpdk l2fwd

本文主要是介绍dpdk解析报文协议-基于l2fwd，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

dpdk解析报文协议-基于l2fwd

0 前置条件

1、这里需要两台虚拟机，配置了相同的虚拟网络，可以通过tcpreplay在一台虚拟机回放报文，在另一台虚拟机通过tcpdump -i 网卡名 捕获到。

具体配置可参考https://www.jb51.net/server/2946942fw.htm

2、需要dpdk环境配置完成

3、大致了解计算机网络的以太网层、ip层、tcp/udp层、应用层http等之间的关系，如下图所示

​image​

1 l2fwd运行

进入example中的l2fwd代码目录下，执行下列命令

export RTE_TARGET=x86_64-native-linuxapp-gcc
export RTE_SDK=/home/chen/code/dpdk/dpdk-stable-19.11.14
make# 运行
sudo ./build/l2fwd -l 0-1 -- -p 0x3 -T 1

如果一切正常，则应该输出下图，可以通过在另一台虚拟机回放相关报文，观察统计信息变化情况​​

​image​

‍

# 另一台虚拟机
sudo tcpreplay -i ens38 xxxx.pcap

​image​

在运行l2fwd的虚拟机上可以看到

​image​

‍

此时说明前面的没问题。

2 l2fwd 整体代码解析

目前浅显的理解可以认为其他部分在初始化，主循环为l2fwd_main_loop​

3 l2fwd 修改

1、原先的l2fwd_simple_forward​函数是负责修改mac地址并转发报文，那么我们也可以在l2fwd所在的那层循环中，去做解析报文。

		// 遍历所有配置的接收端口for (i = 0; i < qconf->n_rx_port; i++) {// 从接收端口列表 qconf->rx_port_list 中获取当前迭代的端口 ID。portid = qconf->rx_port_list[i];// 调用 rte_eth_rx_burst 函数从指定的端口（portid）接收数据包nb_rx = rte_eth_rx_burst(portid, 0,pkts_burst, MAX_PKT_BURST);port_statistics[portid].rx += nb_rx;// printf("nb_rx: %d\n", nb_rx);for (j = 0; j < nb_rx; j++) {m = pkts_burst[j];rte_prefetch0(rte_pktmbuf_mtod(m, void *));parse_packet(m);// l2fwd_simple_forward(m, portid);}}

2、我们可以增加一个parse_packet​函数，参照l2fwd_mac_updating​中的处理流程，使用官方api rte_pktmbuf_mtod​获得以太网头部信息，并存入rte_ether_hdr​结构体。

void parse_packet(struct rte_mbuf *m) {struct rte_ether_hdr *eth_hdr;eth_hdr = rte_pktmbuf_mtod(m, struct rte_ether_hdr *);unsigned int total_length = rte_pktmbuf_pkt_len(mbuf); // 获取整个包的长度unsigned int ether_hdr_len = sizeof(struct rte_ether_hdr); // 以太网头部长度unsigned int data_len = total_length - ether_hdr_len; // 剩余数据长度（去除以太网头部）
}/*** Ethernet header: Contains the destination address, source address* and frame type.*/
struct rte_ether_hdr {struct rte_ether_addr d_addr; /**< Destination address. */struct rte_ether_addr s_addr; /**< Source address. */uint16_t ether_type;      /**< Frame type. */
} __attribute__((aligned(2)));

此时可以得到原mac和目的mac，以及ip版本，和下图的MAC帧是对应的。

​image​

‍

3、通过ip类型，判断是ipv4还是ipv6，进行不同的处理，这里面需要注意的是有大小端的转换（RTE_ETHER_TYPE_IPV4是大端），用rte_be_to_cpu_16。ip层相关的信息都保存在ipv4_hdr​中

    // 检查 IP 版本并获取 IP 头部if (eth_hdr->ether_type <span style="font-weight: bold;" class="mark"> rte_be_to_cpu_16(RTE_ETHER_TYPE_IPV4)) {parse_packet_ipv4((struct rte_ipv4_hdr *)(eth_hdr + 1), data_len); // 由于以太网头部长度固定，这里直接调过以太网头部字段，// 处理 IPv4 头部...} else if (eth_hdr->ether_type </span> rte_be_to_cpu_16(RTE_ETHER_TYPE_IPV6)) {printf("ipv6\n");// struct rte_ipv6_hdr *ipv6_hdr;}/*** IPv4 Header*/
struct rte_ipv4_hdr {uint8_t  version_ihl;		/**< version and header length */uint8_t  type_of_service;	/**< type of service */rte_be16_t total_length;	/**< length of packet */rte_be16_t packet_id;		/**< packet ID */rte_be16_t fragment_offset;	/**< fragmentation offset */uint8_t  time_to_live;		/**< time to live */uint8_t  next_proto_id;		/**< protocol ID */rte_be16_t hdr_checksum;	/**< header checksum */rte_be32_t src_addr;		/**< source address */rte_be32_t dst_addr;		/**< destination address */
} __attribute__((__packed__));

​image​

4、通过ip层协议标识next_proto_id​判断是tcp还是udp

void parse_packet_ipv4(struct rte_ipv4_hdr *ipv4_hdr, unsigned int data_len) {print_ipv4_addr("ipv4_src_addr:", ipv4_hdr->src_addr);print_ipv4_addr("ipv4_dst_addr:", ipv4_hdr->dst_addr);unsigned int ipv4_hdr_len = (ipv4_hdr->version_ihl & 0x0F) * 4; // 头部长度以4字节为单位// 检查协议类型并获取 TCP/UDP 头部if (ipv4_hdr->next_proto_id <span style="font-weight: bold;" class="mark"> IPPROTO_TCP) {parse_packet_tcp((struct rte_tcp_hdr *)((unsigned char *)ipv4_hdr + ipv4_hdr_len), data_len - ipv4_hdr_len);// 处理 TCP 头部...} else if (ipv4_hdr->next_proto_id </span> IPPROTO_UDP) {parse_packet_udp((struct rte_udp_hdr *)((unsigned char *)ipv4_hdr + ipv4_hdr_len), data_len - ipv4_hdr_len);// 处理 UDP 头部...}
}struct rte_tcp_hdr {rte_be16_t src_port; /**< TCP source port. */rte_be16_t dst_port; /**< TCP destination port. */rte_be32_t sent_seq; /**< TX data sequence number. */rte_be32_t recv_ack; /**< RX data acknowledgment sequence number. */uint8_t  data_off;   /**< Data offset. */uint8_t  tcp_flags;  /**< TCP flags */rte_be16_t rx_win;   /**< RX flow control window. */rte_be16_t cksum;    /**< TCP checksum. */rte_be16_t tcp_urp;  /**< TCP urgent pointer, if any. */
} __attribute__((__packed__));struct rte_udp_hdr {rte_be16_t src_port;    /**< UDP source port. */rte_be16_t dst_port;    /**< UDP destination port. */rte_be16_t dgram_len;   /**< UDP datagram length */rte_be16_t dgram_cksum; /**< UDP datagram checksum */
} __attribute__((__packed__));

​image​

​image​

5、以tcp为例，判断是否是http(这里简单判断端口是否为80)

	void parse_packet_tcp(struct rte_tcp_hdr *tcp_hdr, unsigned int data_len) {unsigned int tcp_hdr_len = ((tcp_hdr->data_off & 0xF0) >> 4) * 4; // 高 4 位表示 TCP 头部的长度unsigned char *tcp_payload = ((unsigned char *)tcp_hdr) + tcp_hdr_len;unsigned int tcp_payload_len = data_len - tcp_hdr_len; // TCP 负载长度// 将端口从网络字节序转换为主机字节序uint16_t port_host_order = rte_be_to_cpu_16(tcp_hdr->dst_port);if (port_host_order == 80) {parse_packet_http(tcp_payload, tcp_payload_len);}
}

6、打印http负载，由于http负载的结束有很多种情况（ip是否分片,http流是否结束等），所以需要基于报文长度依次减去各部分的头部来确定http负载的长度

void parse_packet_http(unsigned char *http_payload, unsigned int data_len) {// http 以 \r\n换行printf("HTTP Payload:\n");for (unsigned int i = 0; i < data_len; ++i) {char c = http_payload[i];if (isprint(c) || c <span style="font-weight: bold;" class="mark"> '\n' || c </span> '\r') {printf("%c", c);} else {printf("."); // 非可打印字符用点号表示}}printf("\n");
}

‍

​image​

这篇关于dpdk解析报文协议-基于l2fwd的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1107961。

相关文章

网页解析 lxml 库--实战

网页解析 lxml 库--实战

lxml库使用流程 lxml 是 Python 的第三方解析库，完全使用 Python 语言编写，它对 XPath表达式提供了良好的支 持，因此能够了高效地解析 HTML/XML 文档。本节讲解如何通过 lxml 库解析 HTML 文档。 pip install lxml lxm| 库提供了一个 etree 模块，该模块专门用来解析 HTML/XML 文档，下面来介绍一下 lxml 库
阅读更多...
【C++】_list常用方法解析及模拟实现

【C++】_list常用方法解析及模拟实现

相信自己的力量，只要对自己始终保持信心，尽自己最大努力去完成任何事，就算事情最终结果是失败了，努力了也不留遗憾。💓💓💓 目录   ✨说在前面 🍋知识点一：什么是list？ •🌰1.list的定义 •🌰2.list的基本特性 •🌰3.常用接口介绍 🍋知识点二：list常用接口 •🌰1.默认成员函数 🔥构造函数（⭐） 🔥析构函数 •🌰2.list对象
阅读更多...
【Linux】应用层http协议

【Linux】应用层http协议

一、HTTP协议 1.1 简要介绍一下HTTP        我们在网络的应用层中可以自己定义协议，但是，已经有大佬定义了一些现成的，非常好用的应用层协议，供我们直接使用，HTTP（超文本传输协议）就是其中之一。        在互联网世界中，HTTP（超文本传输协议）是一个至关重要的协议，他定义了客户端（如浏览器）与服务器之间如何进行通信，以交换或者传输超文本（比如HTML文档）。
阅读更多...
OWASP十大安全漏洞解析

OWASP十大安全漏洞解析

OWASP（开放式Web应用程序安全项目）发布的“十大安全漏洞”列表是Web应用程序安全领域的权威指南，它总结了Web应用程序中最常见、最危险的安全隐患。以下是对OWASP十大安全漏洞的详细解析： 1. 注入漏洞（Injection） 描述：攻击者通过在应用程序的输入数据中插入恶意代码，从而控制应用程序的行为。常见的注入类型包括SQL注入、OS命令注入、LDAP注入等。 影响：可能导致数据泄
阅读更多...
从状态管理到性能优化：全面解析 Android Compose

从状态管理到性能优化：全面解析 Android Compose

文章目录 引言一、Android Compose基本概念1.1 什么是Android Compose?1.2 Compose的优势1.3 如何在项目中使用Compose 二、Compose中的状态管理2.1 状态管理的重要性2.2 Compose中的状态和数据流2.3 使用State和MutableState处理状态2.4 通过ViewModel进行状态管理 三、Compose中的列表和滚动
阅读更多...
Spring 源码解读：自定义实现Bean定义的注册与解析

Spring 源码解读：自定义实现Bean定义的注册与解析

引言 在Spring框架中，Bean的注册与解析是整个依赖注入流程的核心步骤。通过Bean定义，Spring容器知道如何创建、配置和管理每个Bean实例。本篇文章将通过实现一个简化版的Bean定义注册与解析机制，帮助你理解Spring框架背后的设计逻辑。我们还将对比Spring中的BeanDefinition和BeanDefinitionRegistry，以全面掌握Bean注册和解析的核心原理。
阅读更多...
CSP 2023 提高级第一轮 CSP-S 2023初试题 完善程序第二题解析 未完

CSP 2023 提高级第一轮 CSP-S 2023初试题 完善程序第二题解析 未完

一、题目阅读 （最大值之和）给定整数序列 a0,⋯,an−1，求该序列所有非空连续子序列的最大值之和。上述参数满足 1≤n≤105 和 1≤ai≤108。 一个序列的非空连续子序列可以用两个下标 ll 和 rr（其中0≤l≤r<n0≤l≤r<n）表示，对应的序列为 al,al+1,⋯,ar​。两个非空连续子序列不同，当且仅当下标不同。 例如，当原序列为 [1,2,1,2] 时，要计算子序列 [
阅读更多...
多线程解析报表

多线程解析报表

假如有这样一个需求，当我们需要解析一个Excel里多个sheet的数据时，可以考虑使用多线程，每个线程解析一个sheet里的数据，等到所有的sheet都解析完之后，程序需要提示解析完成。 Way1 join import java.time.LocalTime;public class Main {public static void main(String[] args) thro
阅读更多...
ZooKeeper 中的 Curator 框架解析

ZooKeeper 中的 Curator 框架解析

Apache ZooKeeper 是一个为分布式应用提供一致性服务的软件。它提供了诸如配置管理、分布式同步、组服务等功能。在使用 ZooKeeper 时，Curator 是一个非常流行的客户端库，它简化了 ZooKeeper 的使用，提供了高级的抽象和丰富的工具。本文将详细介绍 Curator 框架，包括它的设计哲学、核心组件以及如何使用 Curator 来简化 ZooKeeper 的操作。 1
阅读更多...
【Go】go连接clickhouse使用TCP协议

【Go】go连接clickhouse使用TCP协议

离开你是傻是对是错 是看破是软弱 这结果是爱是恨或者是什么 如果是种解脱 怎么会还有眷恋在我心窝 那么爱你为什么                      🎵 黄品源/莫文蔚《那么爱你为什么》 package mainimport ("context""fmt""log""time""github.com/ClickHouse/clickhouse-go/v2")func main(
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2