4. 发送队列模型：FIFO队列、优先级队列、延迟队列的设计原则

在SECS/GEM协议栈中，消息发送队列是连接上层应用与底层TCP/IP传输的核心缓冲区域。设计不合理的队列模型会导致消息乱序、优先级反转、关键事务超时等问题。本章节围绕三种经典队列模型——FIFO队列、优先级队列与延迟队列，阐述其设计原则、适用场景及在半导体设备通信中的工程实现要点。

4.1 FIFO队列：基础顺序保证

FIFO（First In First Out）队列是最基础的发送队列模型，所有消息按照入队顺序依次发送。在SECS/GEM协议中，FIFO队列适用于同优先级消息的保序传输场景，例如连续的S6F11（设备数据上报）消息流。

4.1.1 设计原则

• 严格保序：消息出队顺序必须与入队顺序完全一致，不允许重排。
• 无阻塞入队：入队操作应设计为O(1)时间复杂度，避免在高并发时成为瓶颈。
• 背压机制：当队列长度超过阈值时，应向上层应用反馈“发送缓冲区满”状态，防止内存溢出。
• 原子操作：入队/出队操作需保证线程安全，推荐使用无锁队列（如Ring Buffer）或轻量级锁。

4.1.2 适用场景

4.1.3 FIFO队列结构示意

4.2 优先级队列：紧急消息优先发送

SECS/GEM协议定义了多种消息类型，其中控制消息（如S2F17/S2F18在线/离线切换）和报警消息（S5F1）的实时性要求远高于普通数据上报。优先级队列允许高优先级消息跳过低优先级消息，直接进入发送队列头部。

4.2.1 设计原则

• 优先级分级：建议分为3~5级（如：紧急、高、中、低、后台），避免过多级别导致调度开销。
• 优先级映射：将SECS/GEM消息类型映射到内部优先级。例如：S5F1/S5F2报警消息映射为“紧急”，S1F13/S1F14控制消息映射为“高”。
• 防饿死机制：低优先级消息不能无限期被高优先级消息阻塞。建议引入“老化”机制——低优先级消息等待超过一定时间后自动提升优先级。
• 队列隔离：每个优先级使用独立的子队列，避免高优先级消息被低优先级消息的头阻塞（Head-of-Line Blocking）。

4.2.2 优先级映射表

4.2.3 多级优先级队列架构

4.3 延迟队列：定时与条件触发的消息发送

在半导体设备通信中，许多消息需要在特定时间点或满足特定条件后才发送。例如：定时上报（每30秒上报一次设备状态）、延迟重试（消息发送失败后等待5秒重试）、条件触发（等待某个变量达到阈值后再发送）。延迟队列正是为这类场景设计的。

4.3.1 设计原则

• 时间轮（Time Wheel）实现：使用分层时间轮或最小堆（Min-Heap）管理延迟任务，避免遍历整个队列。
• 精度与性能平衡：延迟精度控制在毫秒级即可，不必追求微秒级精度，避免过度消耗CPU。
• 取消与更新：支持取消已入队的延迟消息，以及更新延迟时间（如重试间隔递增）。
• 持久化：对于关键延迟消息（如重试任务），建议在宕机后能从持久化存储恢复。

4.3.2 延迟队列典型应用场景

4.3.3 延迟队列时间轮结构

4.4 复合队列模型：工程实践中的最佳选择

在实际的SECS/GEM协议栈中，单一队列模型往往无法满足所有需求。推荐采用“优先级队列 + 延迟队列”的复合模型：

1. 消息入队流程：应用层发送消息时，首先判断是否需要延迟。如果需要，则进入延迟队列；否则直接进入优先级队列。
2. 延迟到期处理：延迟队列中的消息到期后，根据其优先级插入到优先级队列的对应子队列中。
3. 发送调度：优先级调度器从各子队列中按权重取消息，发送到TCP通道。
4. 失败重试：发送失败的消息，根据重试策略重新进入延迟队列，等待下一次发送。

4.4.1 复合队列模型代码示例

// 复合队列模型核心接口（C++伪代码）
class CompositeSendQueue {
public:
    // 发送消息：支持优先级和延迟
    bool enqueue(const SECSMessage& msg, 
                 Priority prio = Priority::MEDIUM,
                 std::chrono::milliseconds delay = 0ms) {
        if (delay.count() > 0) {
            // 进入延迟队列
            return delayQueue_.schedule(msg, delay, prio);
        } else {
            // 直接进入优先级队列
            return priorityQueue_.enqueue(msg, prio);
        }
    }
    
    // 主循环：每次tick调用
    void tick() {
        // 1. 处理到期的延迟消息
        auto expired = delayQueue_.popExpired();
        for (auto& item : expired) {
            priorityQueue_.enqueue(item.msg, item.prio);
        }
        
        // 2. 从优先级队列取消息发送
        auto msg = priorityQueue_.dequeue();
        if (msg.has_value()) {
            sendToTransport(msg.value());
        }
    }
    
private:
    TimeWheelDelayQueue delayQueue_;      // 延迟队列（时间轮实现）
    MultiLevelPriorityQueue priorityQueue_; // 多级优先级队列
};

4.5 三种队列模型对比总结