DPDK Flow Director：RTE_FLOW_ACTION_TYPE_QUEUE能否支持多RX队列？无RSS替代方案

能否在RTE_FLOW_ACTION_TYPE_QUEUE中使用多个RX队列？ #

这种方式不可行，原因如下：

• 从DPDK API定义来看，struct rte_flow_action_queue的index字段是单个uint16_t类型，仅用于指定单个RX队列索引，并非数组指针。你提供的示例代码存在类型不匹配问题，编译阶段就会报错，无法正常运行。
• Flow Director的RTE_FLOW_ACTION_TYPE_QUEUE动作设计初衷就是将匹配报文导向单一RX队列，硬件层面不支持通过该动作直接指定多个队列。

无需RSS的多队列导向方案 #

方案1：创建多个匹配相同规则的Flow条目 #

针对同一报文匹配模式，创建多个独立的Flow规则，每个规则对应一个目标RX队列。示例代码如下：

// 定义匹配模式（示例为匹配特定目标IP）
struct rte_flow_item_ipv4 ip_spec = {
    .hdr.dst_addr = rte_cpu_to_be_32(RTE_IPV4(192,168,1,100)),
};
struct rte_flow_item_ipv4 ip_mask = {
    .hdr.dst_addr = RTE_IPV4(255,255,255,255),
};

struct rte_flow_item pattern[] = {
    [0] = {.type = RTE_FLOW_ITEM_TYPE_IPV4, .spec = &ip_spec, .mask = &ip_mask},
    [1] = {.type = RTE_FLOW_ITEM_TYPE_END},
};

// 目标队列列表
uint16_t queue_indices[] = {10, 11, 12, 13, 14, 15};
struct rte_flow *flows[ARRAY_SIZE(queue_indices)];

for (int i = 0; i < ARRAY_SIZE(queue_indices); i++) {
    struct rte_flow_action_queue queue_action = {.index = queue_indices[i]};
    struct rte_flow_action actions[] = {
        [0] = {.type = RTE_FLOW_ACTION_TYPE_QUEUE, .conf = &queue_action},
        [1] = {.type = RTE_FLOW_ACTION_TYPE_END},
    };
    // 创建Flow规则，port_id为目标端口，attr为Flow属性（需提前初始化）
    int ret = rte_flow_create(port_id, &attr, pattern, actions, NULL);
    if (ret >= 0) {
        flows[i] = (struct rte_flow *)ret;
    } else {
        // 处理规则创建失败逻辑
    }
}

该方案依赖网卡硬件对多规则的支持，同一模式报文会被多个Flow规则匹配，从而分发到不同队列。注意部分网卡存在Flow规则数量上限，需提前确认硬件规格。

方案2：Flow标记+应用层分发 #

1. 先用RTE_FLOW_ACTION_TYPE_MARK给匹配报文打上自定义标记：

struct rte_flow_action_mark mark_action = {.id = 0x1234}; // 自定义标记值
struct rte_flow_action actions[] = {
    [0] = {.type = RTE_FLOW_ACTION_TYPE_MARK, .conf = &mark_action},
    [1] = {.type = RTE_FLOW_ACTION_TYPE_END},
};
// 创建Flow规则，为匹配报文打上标记
int ret = rte_flow_create(port_id, &attr, pattern, actions, NULL);

2. 应用层收包时读取标记，按自定义逻辑分发到不同队列：

struct rte_mbuf *bufs[BURST_SIZE];
uint16_t nb_rx = rte_eth_rx_burst(port_id, default_queue, bufs, BURST_SIZE);

for (int i = 0; i < nb_rx; i++) {
    struct rte_mbuf *buf = bufs[i];
    if (buf->ol_flags & RTE_MBUF_F_RX_FDIR) {
        uint32_t mark = buf->hash.fdir.hi; // 获取标记值
        if (mark == 0x1234) {
            // 示例：轮询分配到目标队列
            uint16_t target_queue = queue_indices[i % ARRAY_SIZE(queue_indices)];
            // 可将buf转发到目标队列，或直接由对应队列的线程处理
        }
    }
}

该方案无需创建大量Flow规则，灵活性高，适合动态调整分发策略的场景；缺点是分发逻辑在应用层，会占用一定CPU资源。

内容的提问来源于stack exchange，提问作者Raghav