4. 事务（Transaction）基础：事务ID的生成与管理、单块与多块消息事务、超时与重试机制

在 SECS/GEM 协议中，事务（Transaction）是消息交换的基本单元。每一个事务都由一个唯一的事务 ID（System Bytes）标识，确保请求与响应能够正确配对。本章将深入剖析事务 ID 的生成与管理策略、单块与多块消息的事务处理差异，以及超时与重试机制的设计原则。

4.1 事务ID（System Bytes）的生成与管理

事务 ID 在 SECS 消息头中占用 4 个字节（System Bytes），是消息的唯一标识。HSMS 和 RS-232 协议均使用该字段来关联 Primary Message 与 Secondary Message。

4.1.1 事务ID的生成规则

• 递增分配：通常从 0x00000001 开始，每发起一个新事务，ID 加 1。
• 循环使用：达到最大值 0xFFFFFFFF 后，回绕到 0x00000001（0 保留给测试或特殊用途）。
• 线程安全：在多线程或并发环境下，必须使用原子操作或互斥锁保护 ID 生成器。
• 唯一性保证：在同一通信会话中，不能同时存在两个相同的事务 ID。

4.1.2 事务ID的生命周期管理

4.1.3 事务ID管理架构图

4.2 单块消息与多块消息事务

SECS 消息根据数据长度分为单块消息（Single-block）和多块消息（Multi-block）。两者的差异直接影响事务的处理方式和超时策略。

4.2.1 单块消息事务

• 定义：整个消息内容在一个数据块中传输完毕。
• 特点：一次发送，一次确认；事务生命周期短。
• 典型场景：S1F1（Are You There）、S2F17（Date Time Request）等短消息。
• 事务ID使用：Primary Message 和 Secondary Message 使用相同的 System Bytes。

4.2.2 多块消息事务

• 定义：消息内容被拆分为多个数据块（Block），依次发送。
• 特点：需要块编号（Block Number）标识顺序，接收方需重组。
• 典型场景：大容量数据上传（如配方文件、日志记录）。
• 事务ID使用：同一事务的所有块共享相同的 System Bytes，块编号区分顺序。

4.2.3 单块与多块消息对比

4.2.4 多块消息事务流程

4.3 事务超时与重试机制

超时是 SECS/GEM 通信中最常见的异常场景。合理的超时与重试策略是系统稳定性的基石。

4.3.1 关键超时参数

4.3.2 重试策略

• 固定间隔重试：每次重试等待相同时间（如 5 秒），简单但可能加重网络负载。
• 指数退避：重试间隔逐渐增加（如 1s → 2s → 4s → 8s），减少拥塞风险。
• 最大重试次数：通常设置为 3~5 次，超过后上报异常。
• 事务ID复用：重试时使用相同的事务 ID，确保接收方能识别为同一事务。

4.3.3 超时重试状态机

4.3.4 重试逻辑代码示例

// 事务重试管理器伪代码
class TransactionRetryManager {
public:
    bool send_with_retry(Message& msg, int max_retries = 3) {
        uint32_t sys_id = id_generator_.next();
        msg.set_system_bytes(sys_id);
        
        for (int attempt = 0; attempt < max_retries; ++attempt) {
            if (attempt > 0) {
                // 指数退避：1s, 2s, 4s
                int delay_ms = 1000 * (1 << (attempt - 1));
                std::this_thread::sleep_for(std::chrono::milliseconds(delay_ms));
            }
            
            if (send_message(msg)) {
                // 等待 T3 超时
                auto response = wait_for_response(sys_id, T3_TIMEOUT_MS);
                if (response.has_value()) {
                    return true;  // 成功
                }
                // 超时，继续重试
                log_warning("Transaction %u timeout, attempt %d/%d", sys_id, attempt+1, max_retries);
            }
        }
        
        log_error("Transaction %u failed after %d retries", sys_id, max_retries);
        return false;
    }
    
private:
    AtomicCounter id_generator_;
    // ... 其他成员
};