DPDK 是一个高性能的用户空间网络 I/O 库，可以在 Linux 和 BSD 系统上使用。下面是一个简单的 C++ 示例程序，演示如何使用 DPDK 22.11 版本的库来实现网络数据包的收发。
#include <iostream>
#include <rte_eal.h>
#include <rte_ethdev.h>
#define RX_RING_SIZE 1024
#define TX_RING_SIZE 1024
int main(int argc, char** argv)
{
int ret;
// 初始化 DPDK 运行环境
ret = rte_eal_init(argc, argv);
if (ret < 0) {
std::cerr << "Failed to initialize EAL: " << rte_strerror(-ret) << std::endl;
return -1;
}
// 获取可用的网卡端口数量
uint16_t nb_ports = rte_eth_dev_count_avail();
if (nb_ports == 0) {
std::cerr << "No Ethernet ports available" << std::endl;
return -1;
}
// 配置第一个网卡端口
const uint16_t port_id = 0;
struct rte_eth_conf port_conf = {};
struct rte_eth_txconf tx_conf = {};
struct rte_eth_rxconf rx_conf = {};
port_conf.rxmode.max_rx_pkt_len = RTE_ETHER_MAX_LEN;
port_conf.rxmode.mq_mode = ETH_MQ_RX_NONE;
tx_conf.txq_flags |= ETH_TXQ_FLAGS_NOOFFLOADS;
rx_conf.rx_drop_en = 1;
ret = rte_eth_dev_configure(port_id, 1, 1, &port_conf);
if (ret != 0) {
std::cerr << "Failed to configure Ethernet port: " << rte_strerror(-ret) << std::endl;
return -1;
}
// 分配和配置接收队列
ret = rte_eth_rx_queue_setup(port_id, 0, RX_RING_SIZE, rte_eth_dev_socket_id(port_id), &rx_conf, nullptr);
if (ret < 0) {
std::cerr << "Failed to setup RX queue: " << rte_strerror(-ret) << std::endl;
return -1;
}
// 分配和配置发送队列
ret = rte_eth_tx_queue_setup(port_id, 0, TX_RING_SIZE, rte_eth_dev_socket_id(port_id), &tx_conf);
if (ret < 0) {
std::cerr << "Failed to setup TX queue: " << rte_strerror(-ret) << std::endl;
return -1;
}
// 启动网卡端口
ret = rte_eth_dev_start(port_id);
if (ret < 0) {
std::cerr << "Failed to start Ethernet port: " << rte_strerror(-ret) << std::endl;
return -1;
}
// 接收数据包并打印信息
const uint16_t nb_rx_pkts = 32;
struct rte_mbuf* rx_pkts[nb_rx_pkts];
while (true) {
const uint16_t nb_rx = rte_eth_rx_burst(port_id, 0, rx_pkts, nb_rx_pkts);
for (uint16_t i = 0; i < nb_rx; ++i) {
struct rte_ether_hdr* eth_hdr = rte_pktmbuf_mtod(rx_pkts[i], struct rte_ether_hdr*);
printf("Received packet with MAC address: %02X:%02X:%02X:%02X:%02X:%02X\n",
eth_hdr->s_addr.addr_bytes[0], eth_hdr->s_addr.addr_bytes[1], eth_hdr->s_addr.addr_bytes[2],
eth_hdr->s_addr.addr_bytes[3], eth_hdr->s_addr.addr_bytes[4], eth_hdr->s_addr.addr_bytes[5]);
rte_pktmbuf_free(rx_pkts[i]);
}
}
return 0;
}
上面的代码实现了一个最简单的网络数据包接收程序，它会不断地从网卡端口接收数据包并打印源 MAC 地址。编译这个程序需要链接 DPDK 的库文件，可以使用如下的命令进行编译：
g++ -std=c++11 -I/path/to/dpdk/include -L/path/to/dpdk/lib -lrte_eal -lrte_ethdev main.cpp -o app
其中 /path/to/dpdk 是 DPDK 库的安装路径。注意，在编译时需要加入 -lrte_eal 和 -lrte_ethdev 参数来链接 DPDK 的库文件。
编译成功后就可以在 Linux 系统上运行这个程序了。但是在运行之前，还需要为网卡端口设置一些参数，例如绑定 CPU 核心、配置 Hugepage 等等。具体操作可以参考 DPDK 官方文档中提供的说明。
