1. DPDK 流分类基础：概念、框架与 rte_flow API 简介

1.1 流分类概念

流分类（Flow Classification）是网络数据平面处理的核心环节，其目标是从高速到达的数据包中识别出属于同一“流”的报文序列，并为后续的转发、过滤、统计或 QoS 操作提供决策依据。在 DPDK 语境下，流分类通常发生在网卡硬件或 PMD 驱动层，利用 NIC 内置的流分类引擎（如 Intel XL710 的 FDIR、Mellanox 的 RTE Flow、Cisco enic 的 Flow Manager）完成线速匹配。

流分类在 DPDK 应用中承担以下职责：

• 流量定向： 将特定流分配到指定 RX 队列或 CPU 核心，实现 RSS 增强或精确分发。
• 过滤与丢弃： 匹配恶意或无效流，在硬件层面直接丢弃，避免主机 CPU 处理。
• 标记与计量： 对匹配流设置 VLAN PCP、DSCP 或 Meter 颜色，用于 QoS 策略。
• 统计与镜像： 对特定流进行计数或流量镜像到监控端口。

1.2 DPDK 中的流分类框架

DPDK 的流分类框架并非单一实现，而是通过 rte_flow 抽象层统一不同网卡厂商的硬件流分类能力。框架分为三层：

1. 应用层： 用户调用 rte_flow_create() / rte_flow_destroy() / rte_flow_query() 等 API。
2. 抽象层： librte_flow 库将通用规则描述转换为网卡私有格式。
3. 驱动层： PMD（Poll Mode Driver）实现硬件操作，如 i40e、ice、mlx5、bnxt 等。

1.3 rte_flow API 简介

rte_flow API 是 DPDK 流分类的核心编程接口，采用“匹配+动作”模型。一条规则由三部分组成：

• 属性（Attributes）： 指定规则方向（ingress/egress）、优先级、组 ID。
• 匹配项（Items）： 一个链表，描述要匹配的协议字段，支持 ETH、VLAN、IPV4、IPV6、UDP、TCP、VXLAN、GTP 等。
• 动作（Actions）： 一个链表，描述匹配后的处理行为，如 QUEUE（转发到队列）、DROP（丢弃）、COUNT（计数）、MARK（设置元数据）、RSS（负载均衡）等。

下面是一个典型的 rte_flow 规则创建代码示例，匹配目的 IP 为 10.0.0.1 的 UDP 报文，并转发到队列 3：

struct rte_flow_attr attr = {
    .ingress = 1,          // 入方向规则
    .priority = 0,         // 优先级 0（最高）
};

struct rte_flow_item pattern[4];
struct rte_flow_action actions[2];
struct rte_flow *flow;
struct rte_flow_error error;

// 匹配项 1：以太网（通配）
pattern[0].type = RTE_FLOW_ITEM_TYPE_ETH;
pattern[0].spec = NULL;
pattern[0].mask = NULL;

// 匹配项 2：IPv4，目的 IP = 10.0.0.1
struct rte_flow_item_ipv4 ipv4_spec;
struct rte_flow_item_ipv4 ipv4_mask;
memset(&ipv4_spec, 0, sizeof(ipv4_spec));
memset(&ipv4_mask, 0, sizeof(ipv4_mask));
ipv4_spec.hdr.dst_addr = htonl(0x0a000001); // 10.0.0.1
ipv4_mask.hdr.dst_addr = 0xffffffff;        // 精确匹配
pattern[1].type = RTE_FLOW_ITEM_TYPE_IPV4;
pattern[1].spec = &ipv4_spec;
pattern[1].mask = &ipv4_mask;

// 匹配项 3：UDP（通配）
pattern[2].type = RTE_FLOW_ITEM_TYPE_UDP;
pattern[2].spec = NULL;
pattern[2].mask = NULL;

// 匹配项结束
pattern[3].type = RTE_FLOW_ITEM_TYPE_END;

// 动作：转发到队列 3
struct rte_flow_action_queue queue_action = { .index = 3 };
actions[0].type = RTE_FLOW_ACTION_TYPE_QUEUE;
actions[0].conf = &queue_action;
actions[1].type = RTE_FLOW_ACTION_TYPE_END;

// 创建规则
flow = rte_flow_create(port_id, &attr, pattern, actions, &error);
if (!flow) {
    printf("Flow create failed: %s\n", error.message);
}