乐于分享
好东西不私藏
夜雨聆风 > > 办公文件 > 源码加更06_接收分发、QoS 事务和诊断闭环

源码加更06_接收分发、QoS 事务和诊断闭环

当前时间： 1970-01-01 08:00:00 分类：办公文件 评论(0)
源码加更06_接收分发、QoS 事务和诊断闭环

源码加更06_接收分发、QoS 事务和诊断闭环

[!abstract] 这一篇完整公开接收分发、QoS ACK、Inflight 事务、QoS2 入站表、Topic Alias 和消息记录方法。这是 MQTT Client 现场稳定性的收口层。

适合谁收藏

  • 正在排查 QoS1/QoS2 超时、重发、ACK 对不上的工程师。
  • 需要理解为什么 M_ProcessReceive 不能只等单一响应的读者。
  • 想把事务表、诊断和现场观测量连起来的 PLC 开发者。

本篇核心图

读图重点：先看源码对象之间的职责边界，再看数据、状态和错误如何沿着调用链流动。源码加更不是把文件名列出来，而是把完整代码、工程意图和验证口径一起讲清楚。

先给结论

高频 MQTT 通信的难点不是能不能收到报文，而是接收后能不能正确分发、ACK、记录和超时收口。这层一乱，状态机就会被在途事务拖死。

从理论到代码实现链路

MQTT 标准给的是报文类型、固定头、可变头、载荷、QoS 交互和会话语义；PLC 工程真正要解决的是周期扫描、缓冲区长度、错误锁存、在线变量、连接重入和现场可诊断性。

所以这套开源实现不能只按协议章节拆，也不能只按文件名拆。正确读法是把标准约束翻译成程序对象：入口程序负责给命令和观测点，GVL 和 DUT 定义容量与数据模型，主功能块负责调度状态机，构建方法负责出站报文，处理方法负责入站报文，辅助方法负责长度、队列、事务、主题和诊断边界。

本篇完整公开接收分发、QoS ACK、Inflight、RxQoS2、Topic Alias 和消息记录相关方法。

再往下一层看，这里其实有两条线同时存在。第一条是协议线：固定头、Remaining Length、PacketId、QoS、Topic、Payload 和 Reason Code 必须能按 MQTT 规则组合起来。第二条是 PLC 工程线：每个周期只能推进有限步骤，所有中间状态都要能被在线变量观察，所有错误都要能被锁存并归类，所有缓冲区长度都要在写入前被检查。

这就是源码加更必须完整公开的原因。只给几段核心片段，读者最多能看懂某个判断；把完整对象放出来，读者才能看到对象之间如何传递状态、长度、错误和诊断信息。完整源码讲解不是为了堆代码，而是为了让读者能从标准约束一路追到可运行的 ST 对象，再从现场现象反向定位到具体边界。

本篇公开的完整源码范围

序号
源码对象
讲解重点
1
M_ProcessReceive.st
源码对象职责和验证边界
2
M_ProcessPendingFrames.st
源码对象职责和验证边界
3
M_BuildPubAckPacket.st
出站报文构建，把引脚命令翻译成 MQTT 字节流
4
M_BuildPubRecPacket.st
出站报文构建，把引脚命令翻译成 MQTT 字节流
5
M_BuildPubRelPacket.st
出站报文构建，把引脚命令翻译成 MQTT 字节流
6
M_BuildPubCompPacket.st
出站报文构建，把引脚命令翻译成 MQTT 字节流
7
M_HandlePubAck.st
入站报文处理，把 MQTT 响应落到状态和诊断
8
M_HandlePubRec.st
入站报文处理，把 MQTT 响应落到状态和诊断
9
M_HandlePubRel.st
入站报文处理，把 MQTT 响应落到状态和诊断
10
M_HandlePubComp.st
入站报文处理，把 MQTT 响应落到状态和诊断
11
M_InflightAdd.st
QoS 事务表，决定 ACK、重发和超时能否收口
12
M_InflightCheckTimeout.st
QoS 事务表，决定 ACK、重发和超时能否收口
13
M_InflightClear.st
QoS 事务表，决定 ACK、重发和超时能否收口
14
M_InflightFind.st
QoS 事务表，决定 ACK、重发和超时能否收口
15
M_InflightRemove.st
QoS 事务表，决定 ACK、重发和超时能否收口
16
M_InflightUpdateState.st
QoS 事务表，决定 ACK、重发和超时能否收口
17
M_RxQoS2Add.st
QoS 事务表，决定 ACK、重发和超时能否收口
18
M_RxQoS2Find.st
QoS 事务表，决定 ACK、重发和超时能否收口
19
M_RxQoS2Remove.st
QoS 事务表，决定 ACK、重发和超时能否收口
20
M_TopicAliasClear.st
源码对象职责和验证边界
21
M_TopicAliasLookup.st
源码对象职责和验证边界
22
M_TopicAliasRegister.st
源码对象职责和验证边界
23
M_RecordReceivedMessage.st
源码对象职责和验证边界
24
FB_MqttPropertyCodec.st
源码对象职责和验证边界
25
FB_Random.st
源码对象职责和验证边界

怎么读这些源码

第一遍只看对象职责：这个文件解决哪一层问题，是入口、模型、状态、构建、接收、事务，还是诊断。

第二遍看边界变量：长度、索引、PacketId、QoS、状态枚举、错误码、缓冲区水位和在线观测量。PLC 通信代码最怕的是“能跑但不可诊断”，所以每个关键对象都要问一句：现场出问题时，我能不能从它留下的变量看出原因。

第三遍再看具体语句。源码全部公开，不等于读者要从第一行顺序读到最后一行。更稳的方式是用图和表先建立地图，再回到完整代码里确认每个边界确实落地。

工程验证路径

验证时看 Inflight 数量、PacketId 状态、QoS2 入站记录、Topic Alias 映射和最近接收消息。这些量能对上，才说明 QoS 闭环真的站住了。

本篇完整开源代码

完整代码 1：M_ProcessReceive.st

这一段完整公开 M_ProcessReceive.st。读代码时先看对象职责，再看状态、长度、错误和返回值，不要只抄几行赋值。

/// =======================================================================/// 名称      : M_ProcessReceive/// 功能      : 统一处理接收到的 MQTT 报文/// 说明      : 校验完整帧后，按报文类型执行解析、确认和状态更新。/// 编程人员  : ControlRookie/// 时间      : 2026-05-07/// 版本      : V2.0/// ======================================================================={attribute 'hide_all_locals'}METHOD M_ProcessReceive : BOOLVAR    byHeader          : BYTE;                           // 固定报头首字节    byMsgType         : BYTE;                           // 报文类型    byFlags           : BYTE;                           // 固定报头标志    byReasonCode      : BYTE;                           // 原因码    bySubAckCode      : BYTE;                           // SUBACK 原因码    uiFixedHeaderLen  : UINT;                           // 固定报头总长度    uiRemainingLen    : UINT;                           // 当前报文固定报头中携带的 Remaining Length 值[byte]    uiFrameEndPos     : UINT;                           // 当前帧结束位置    uiTopicPos        : UINT;                           // 主题起始偏移    uiTopicLen        : UINT;                           // 主题长度    uiPayloadPos      : UINT;                           // 载荷起始偏移    uiPayloadLen      : UINT;                           // 当前报文载荷区实际长度[byte]    uiPacketId        : UINT;                           // 当前接收报文中解析出的 Packet Identifier    uiAliasId         : UINT;                           // 主题别名    udiSubIdentifier  : UDINT;                          // 订阅标识符    uiPropsLen        : UINT;                           // 属性总长度    uiPropsHeaderLen  : UINT;                           // 属性长度这个 VBI 字段本身占用的字节数[byte]    uiPropsEnd        : UINT;                           // 属性区结束偏移    uiPropsPos        : UINT;                           // 属性读取偏移    uiIndex           : UINT;                           // 通用扫描或历史列表搬移时使用的索引    uiRxQoS2Index     : UINT;                           // 入站 QoS2 去重表中命中的槽位索引    i                 : UINT;                           // 循环索引    sAliasTopic       : STRING(GVL_Mqtt.cnMaxTopicLen); // 别名映射主题END_VAR// === IMPLEMENTATION ===/// 至少要先拿到 1 字节固定报头 + 1 字节 Remaining Length，/// 否则连“这是不是一帧完整 MQTT 报文”都还无法判断。IF uiRxLength < 2 THEN    M_ProcessReceive := FALSE;    RETURN;END_IF/// 先解析固定报头和 Remaining Length，得到“当前完整帧”在接收缓冲区中的边界。byHeader := aRxBuf[0];byMsgType := byHeader AND GVL_Mqtt.cnHdrTypeMask;byFlags := byHeader AND GVL_Mqtt.cnHdrFlagsMask;uiFixedHeaderLen := 1 + M_DecodeRemainingLength(    pBuffer := ADR(aRxBuf[1]),    uiLength => uiRemainingLen);IF uiFixedHeaderLen = 0 THEN    M_ProcessReceive := FALSE;    RETURN;END_IFuiFrameEndPos := uiFixedHeaderLen + uiRemainingLen;IF uiRxLength < uiFrameEndPos THEN    M_ProcessReceive := FALSE;    RETURN;END_IF/// 当前方法一次只消费一帧。/// 如果缓冲区里还有后续报文，最后会把余下字节整体前移，留给下一次继续处理。CASE byMsgType OF    E_MqttPacketType.byConnAck:        /// 正常 CONNACK 只允许在连接建立阶段进入专用等待态处理。        /// 一旦在通用接收路径中再次看到 CONNACK，说明会话时序已经错乱。        M_SetError(            uiErrorCode := TO_UINT(E_ReasonCode.uiErrProtocolError),            sMessage := 'Unexpected CONNACK packet');        eState := E_MqttState.iTcpDisconnect;        M_ProcessReceive := FALSE;        RETURN;    E_MqttPacketType.byPublish:        /// 先从固定报头里提取 QoS / DUP / Retain，        /// 后续再结合主题、属性和载荷拼出一条完整的入站业务消息。        byReceivedQoS := SHR(byFlags AND GVL_Mqtt.cnHdrQoSMask, 1);        uiAliasId := 0;        udiSubIdentifier := 0;        bReceivedRetain := (byFlags AND GVL_Mqtt.cnHdrRetainFlag) <> 0;        IF (byReceivedQoS > TO_BYTE(E_MqttQoS.byQoS2)) OR           ((byReceivedQoS = TO_BYTE(E_MqttQoS.byQoS0)) AND ((byFlags AND GVL_Mqtt.cnHdrDupFlag) <> 0)) THEN            M_SetError(                uiErrorCode := TO_UINT(E_ReasonCode.uiErrProtocolError),                sMessage := 'Invalid PUBLISH header flags');            eState := E_MqttState.iTcpDisconnect;            M_ProcessReceive := FALSE;            RETURN;        END_IF        uiTopicPos := uiFixedHeaderLen;        IF uiTopicPos + 1 >= uiFrameEndPos THEN            M_ProcessReceive := FALSE;            RETURN;        END_IF        uiTopicLen := SHL(BYTE_TO_UINT(aRxBuf[uiTopicPos]), 8) OR BYTE_TO_UINT(aRxBuf[uiTopicPos + 1]);        uiTopicPos := uiTopicPos + 2;        uiPayloadPos := uiTopicPos + uiTopicLen;        /// MQTT 允许 PUBLISH 主题字符串为空，但那只在 Topic Alias 续用场景才合法。        /// 因此这里先尝试读主题，后面再结合 Alias 规则决定最终主题是否有效。        sRecTopic := '';        IF uiTopicLen > 0 THEN            IF uiPayloadPos > uiFrameEndPos THEN                M_ProcessReceive := FALSE;                RETURN;            END_IF            IF NOT M_CopyBytesToString(                pSource := ADR(aRxBuf[uiTopicPos]),                uiByteCount := uiTopicLen,                sTarget := sRecTopic) THEN                M_ProcessReceive := FALSE;                RETURN;            END_IF        END_IF        uiPacketId := 0;        IF byReceivedQoS > TO_BYTE(E_MqttQoS.byQoS0) THEN            /// QoS1 / QoS2 的入站 PUBLISH 必须带 Packet Identifier，            /// 后续 ACK / 去重 / 四步握手都依赖这个编号闭环。            IF uiPayloadPos + 1 >= uiFrameEndPos THEN                M_ProcessReceive := FALSE;                RETURN;            END_IF            uiPacketId := SHL(BYTE_TO_UINT(aRxBuf[uiPayloadPos]), 8) OR BYTE_TO_UINT(aRxBuf[uiPayloadPos + 1]);            IF uiPacketId = 0 THEN                M_SetError(                    uiErrorCode := TO_UINT(E_ReasonCode.uiErrProtocolError),                    sMessage := 'Packet ID must not be zero');                eState := E_MqttState.iTcpDisconnect;                M_ProcessReceive := FALSE;                RETURN;            END_IF            uiPayloadPos := uiPayloadPos + 2;        END_IF        IF eVersion = E_MqttVersion.byMqttVersion50 THEN            /// MQTT 5.0 的 PUBLISH 还要先跳过属性区，            /// 才能准确落到真正业务 payload 的起点。            IF uiPayloadPos >= uiFrameEndPos THEN                M_ProcessReceive := FALSE;                RETURN;            END_IF            uiPropsHeaderLen := M_DecodeRemainingLength(                pBuffer := ADR(aRxBuf[uiPayloadPos]),                uiLength => uiPropsLen);            IF uiPropsHeaderLen = 0 THEN                M_ProcessReceive := FALSE;                RETURN;            END_IF            uiPropsPos := uiPayloadPos + uiPropsHeaderLen;            uiPropsEnd := uiPropsPos + uiPropsLen;            IF uiPropsEnd > uiFrameEndPos THEN                M_ProcessReceive := FALSE;                RETURN;            END_IF            WHILE uiPropsPos < uiPropsEnd DO                /// 这里只处理当前客户端已经实现并确实会影响运行行为的属性。                /// 其余未支持属性直接按协议错误处理，避免“悄悄忽略后跑偏”。                CASE aRxBuf[uiPropsPos] OF                    GVL_Mqtt.cnPropTopicAlias:                        uiPropsPos := uiPropsPos + 1;                        IF uiPropsPos + 1 >= uiPropsEnd THEN                            M_ProcessReceive := FALSE;                            RETURN;                        END_IF                        uiAliasId := SHL(BYTE_TO_UINT(aRxBuf[uiPropsPos]), 8) OR BYTE_TO_UINT(aRxBuf[uiPropsPos + 1]);                        uiPropsPos := uiPropsPos + 2;                    GVL_Mqtt.cnPropSubscriptionId:                        uiPropsPos := uiPropsPos + 1;                        uiIndex := 0;                        uiPropsHeaderLen := M_DecodeRemainingLength(                            pBuffer := ADR(aRxBuf[uiPropsPos]),                            uiLength => uiIndex);                        IF uiPropsHeaderLen = 0 THEN                            M_ProcessReceive := FALSE;                            RETURN;                        END_IF                        udiSubIdentifier := TO_UDINT(uiIndex);                        uiPropsPos := uiPropsPos + uiPropsHeaderLen;                    GVL_Mqtt.cnPropPayloadFormat,                    GVL_Mqtt.cnPropRetainAvailable,                    GVL_Mqtt.cnPropRequestProblemInfo,                    GVL_Mqtt.cnPropRequestResponseInfo,                    GVL_Mqtt.cnPropWildcardSubAvail,                    GVL_Mqtt.cnPropSubIdAvail,                    GVL_Mqtt.cnPropSharedSubAvail:                        uiPropsPos := uiPropsPos + 2;                    GVL_Mqtt.cnPropReceiveMaximum,                    GVL_Mqtt.cnPropTopicAliasMax,                    GVL_Mqtt.cnPropServerKeepAlive:                        uiPropsPos := uiPropsPos + 3;                    GVL_Mqtt.cnPropMessageExpiry,                    GVL_Mqtt.cnPropSessionExpiry,                    GVL_Mqtt.cnPropMaxPacketSize:                        uiPropsPos := uiPropsPos + 5;                    GVL_Mqtt.cnPropContentType,                    GVL_Mqtt.cnPropResponseTopic,                    GVL_Mqtt.cnPropCorrelationData,                    GVL_Mqtt.cnPropAssignedClientId,                    GVL_Mqtt.cnPropAuthMethod,                    GVL_Mqtt.cnPropAuthData,                    GVL_Mqtt.cnPropResponseInfo,                    GVL_Mqtt.cnPropServerReference,                    GVL_Mqtt.cnPropReasonString:                        uiPropsPos := uiPropsPos + 1;                        IF uiPropsPos + 1 >= uiPropsEnd THEN                            M_ProcessReceive := FALSE;                            RETURN;                        END_IF                        uiPropsPos := uiPropsPos + 2 + (                            SHL(BYTE_TO_UINT(aRxBuf[uiPropsPos]), 8) OR                            BYTE_TO_UINT(aRxBuf[uiPropsPos + 1]));                    GVL_Mqtt.cnPropUserProperty:                        uiPropsPos := uiPropsPos + 1;                        FOR i := 1 TO 2 DO                            IF uiPropsPos + 1 >= uiPropsEnd THEN                                M_ProcessReceive := FALSE;                                RETURN;                            END_IF                            uiPropsPos := uiPropsPos + 2 + (                                SHL(BYTE_TO_UINT(aRxBuf[uiPropsPos]), 8) OR                                BYTE_TO_UINT(aRxBuf[uiPropsPos + 1]));                        END_FOR                ELSE                    M_SetError(                        uiErrorCode := TO_UINT(E_ReasonCode.uiErrProtocolError),                        sMessage := 'Unsupported PUBLISH property');                    eState := E_MqttState.iTcpDisconnect;                    M_ProcessReceive := FALSE;                    RETURN;                END_CASE                IF uiPropsPos > uiPropsEnd THEN                    M_ProcessReceive := FALSE;                    RETURN;                END_IF            END_WHILE            uiPayloadPos := uiPropsEnd;            IF uiAliasId > 0 THEN                /// Topic Alias 有两种合法用法：                /// 1. 主题字符串非空：表示“登记或覆盖别名映射”；                /// 2. 主题字符串为空：表示“直接复用之前登记过的别名主题”。                IF uiAliasId > GVL_Mqtt.cnMaxTopicAlias THEN                    M_SetError(                        uiErrorCode := TO_UINT(E_ReasonCode.uiErrTopicAliasInvalid),                        sMessage := 'Topic Alias exceeds client maximum');                    eState := E_MqttState.iTcpDisconnect;                    M_ProcessReceive := FALSE;                    RETURN;                END_IF                IF sRecTopic = '' THEN                    sAliasTopic := M_TopicAliasLookup(uiAliasId := uiAliasId);                    IF sAliasTopic = '' THEN                        M_SetError(                            uiErrorCode := TO_UINT(E_ReasonCode.uiErrTopicAliasInvalid),                            sMessage := 'Unknown Topic Alias');                        eState := E_MqttState.iTcpDisconnect;                        M_ProcessReceive := FALSE;                        RETURN;                    END_IF                    sRecTopic := sAliasTopic;                ELSE                    IF NOT M_TopicAliasRegister(uiAliasId := uiAliasId, sTopic := sRecTopic) THEN                        M_SetError(                            uiErrorCode := TO_UINT(E_ReasonCode.uiErrTopicAliasInvalid),                            sMessage := 'Topic Alias registration failed');                        eState := E_MqttState.iTcpDisconnect;                        M_ProcessReceive := FALSE;                        RETURN;                    END_IF                END_IF            END_IF        END_IF        uiPayloadLen := uiFrameEndPos - uiPayloadPos;        sRecPayload := '';        IF uiPayloadLen > 0 THEN            IF NOT M_CopyBytesToString(                pSource := ADR(aRxBuf[uiPayloadPos]),                uiByteCount := uiPayloadLen,                sTarget := sRecPayload) THEN                M_ProcessReceive := FALSE;                RETURN;            END_IF        END_IF        IF byReceivedQoS = TO_BYTE(E_MqttQoS.byQoS1) THEN            /// QoS1 入站消息要先登记“占用了一个接收侧未完成配额”，            /// 再构建 PUBACK，确保高压场景下不会无限接收入站 QoS>0 消息。            IF uiRxInFlightQosCount >= uiReceiveMax THEN                M_SetError(                    uiErrorCode := TO_UINT(E_ReasonCode.uiErrReceiveMaxExceeded),                    sMessage := 'Receive Maximum exceeded');                eState := E_MqttState.iTcpDisconnect;                M_ProcessReceive := FALSE;                RETURN;            END_IF            uiRxInFlightQosCount := uiRxInFlightQosCount + 1;            IF NOT M_BuildPubAckPacket(uiPacketId := uiPacketId) THEN                IF uiRxInFlightQosCount > 0 THEN                    uiRxInFlightQosCount := uiRxInFlightQosCount - 1;                END_IF                M_SetError(                    uiErrorCode := TO_UINT(E_ReasonCode.uiErrProtocolError),                    sMessage := 'Build PUBACK failed');                eState := E_MqttState.iTcpDisconnect;                M_ProcessReceive := FALSE;                RETURN;            END_IF            xPendingImmediateTx := TRUE;            M_RecordReceivedMessage();        ELSIF byReceivedQoS = TO_BYTE(E_MqttQoS.byQoS2) THEN            /// QoS2 先查去重表：            /// - 第一次看到该 Packet ID：登记、记录业务消息、回 PUBREC            /// - 重复看到该 Packet ID：不重复投递业务消息，只重发握手响应            uiRxQoS2Index := M_RxQoS2Find(uiPacketId := uiPacketId);            IF uiRxQoS2Index = 0 THEN                IF uiRxInFlightQosCount >= uiReceiveMax THEN                    M_SetError(                        uiErrorCode := TO_UINT(E_ReasonCode.uiErrReceiveMaxExceeded),                        sMessage := 'Receive Maximum exceeded');                    eState := E_MqttState.iTcpDisconnect;                    M_ProcessReceive := FALSE;                    RETURN;                END_IF                IF NOT M_RxQoS2Add(uiPacketId := uiPacketId) THEN                    M_SetError(                        uiErrorCode := TO_UINT(E_ReasonCode.uiErrReceiveMaxExceeded),                        sMessage := 'QoS2 dedup queue is full');                    eState := E_MqttState.iTcpDisconnect;                    M_ProcessReceive := FALSE;                    RETURN;                END_IF                M_RecordReceivedMessage();            END_IF            IF NOT M_BuildPubRecPacket(uiPacketId := uiPacketId) THEN                M_SetError(                    uiErrorCode := TO_UINT(E_ReasonCode.uiErrProtocolError),                    sMessage := 'Build PUBREC failed');                eState := E_MqttState.iTcpDisconnect;                M_ProcessReceive := FALSE;                RETURN;            END_IF            xPendingImmediateTx := TRUE;        ELSE            /// QoS0 没有后续握手，记录消息后即可视为完成。            M_RecordReceivedMessage();        END_IF    E_MqttPacketType.byPubAck:        /// 出站 QoS1 发布的终点：匹配到期望 Packet ID 后关闭等待态并释放 inflight。        IF (byFlags <> 0) OR (uiFrameEndPos < 4) THEN            M_ProcessReceive := FALSE;            RETURN;        END_IF        uiPacketId := SHL(BYTE_TO_UINT(aRxBuf[uiFixedHeaderLen]), 8) OR BYTE_TO_UINT(aRxBuf[uiFixedHeaderLen + 1]);        IF uiPacketId = uiExpectedPacketId THEN            byReasonCode := 0;            IF (eVersion = E_MqttVersion.byMqttVersion50) AND (uiFrameEndPos > uiFixedHeaderLen + 2) THEN                byReasonCode := aRxBuf[uiFixedHeaderLen + 2];            END_IF            xWaitingForAck := FALSE;            bDup := FALSE;            IF byReasonCode >= 16#80 THEN                M_SetError(                    uiErrorCode := TO_UINT(E_ReasonCode.uiErrPubAckRefused),                    sMessage := 'PUBACK rejected');            ELSE                xPublishedEvent := TRUE;            END_IF            M_InflightRemove(uiPacketId := uiPacketId);        ELSE            M_ProcessReceive := FALSE;            RETURN;        END_IF    E_MqttPacketType.byPubRec:        /// 出站 QoS2 发布第 2 步：收到 PUBREC 后，把 inflight 状态推进到“可发 PUBREL”。        IF (byFlags <> 0) OR (uiFrameEndPos < 4) THEN            M_ProcessReceive := FALSE;            RETURN;        END_IF        uiPacketId := SHL(BYTE_TO_UINT(aRxBuf[uiFixedHeaderLen]), 8) OR BYTE_TO_UINT(aRxBuf[uiFixedHeaderLen + 1]);        IF uiPacketId = uiExpectedPacketId THEN            byReasonCode := 0;            IF (eVersion = E_MqttVersion.byMqttVersion50) AND (uiFrameEndPos >= 5) THEN                byReasonCode := aRxBuf[uiFixedHeaderLen + 2];                IF byReasonCode >= 16#80 THEN                    M_SetError(                        uiErrorCode := TO_UINT(E_ReasonCode.uiErrPubRecRefused),                        sMessage := 'PUBREC rejected');                    M_InflightRemove(uiPacketId := uiPacketId);                    xWaitingForAck := FALSE;                END_IF            END_IF            IF NOT bError THEN                M_InflightUpdateState(                    uiPacketId := uiPacketId,                    eNewState := E_MqttInflightState.iPubRecReceived);                xWaitingForAck := FALSE;                uiQoS2PacketId := uiPacketId;            END_IF        ELSE            M_ProcessReceive := FALSE;            RETURN;        END_IF    16#60:        /// PUBREL 固定报头类型是 16#60，且标志必须固定为 16#02。        /// 这里代表“入站 QoS2 对端开始请求我们完成第 3 / 4 步握手”。        IF (byFlags <> 2) OR (uiFrameEndPos < 4) THEN            M_SetError(                uiErrorCode := TO_UINT(E_ReasonCode.uiErrProtocolError),                sMessage := 'Invalid PUBREL flags');            eState := E_MqttState.iTcpDisconnect;            M_ProcessReceive := FALSE;            RETURN;        END_IF        uiPacketId := SHL(BYTE_TO_UINT(aRxBuf[uiFixedHeaderLen]), 8) OR BYTE_TO_UINT(aRxBuf[uiFixedHeaderLen + 1]);        M_RxQoS2Remove(uiPacketId := uiPacketId);        IF NOT M_BuildPubCompPacket(uiPacketId := uiPacketId) THEN            M_SetError(                uiErrorCode := TO_UINT(E_ReasonCode.uiErrProtocolError),                sMessage := 'Build PUBCOMP failed');            eState := E_MqttState.iTcpDisconnect;            M_ProcessReceive := FALSE;            RETURN;        END_IF        xPendingImmediateTx := TRUE;    E_MqttPacketType.byPubComp:        /// 出站 QoS2 发布终点：收到 PUBCOMP 后，整条 inflight 事务才真正完成。        IF (byFlags <> 0) OR (uiFrameEndPos < 4) THEN            M_ProcessReceive := FALSE;            RETURN;        END_IF        uiPacketId := SHL(BYTE_TO_UINT(aRxBuf[uiFixedHeaderLen]), 8) OR BYTE_TO_UINT(aRxBuf[uiFixedHeaderLen + 1]);        IF uiPacketId = uiQoS2PacketId THEN            byReasonCode := 0;            IF (eVersion = E_MqttVersion.byMqttVersion50) AND (uiFrameEndPos > uiFixedHeaderLen + 2) THEN                byReasonCode := aRxBuf[uiFixedHeaderLen + 2];            END_IF            xWaitingForAck := FALSE;            bDup := FALSE;            IF byReasonCode >= 16#80 THEN                M_SetError(                    uiErrorCode := TO_UINT(E_ReasonCode.uiErrPubCompRefused),                    sMessage := 'PUBCOMP rejected');            ELSE                xPublishedEvent := TRUE;            END_IF            M_InflightRemove(uiPacketId := uiPacketId);        ELSE            M_ProcessReceive := FALSE;            RETURN;        END_IF    E_MqttPacketType.bySubAck:        /// SUBACK 收到后既要结束等待态，也要把“当前激活订阅请求”写回本地订阅表。        IF (byFlags <> 0) OR (uiFrameEndPos < 5) THEN            M_ProcessReceive := FALSE;            RETURN;        END_IF        uiPacketId := SHL(BYTE_TO_UINT(aRxBuf[uiFixedHeaderLen]), 8) OR BYTE_TO_UINT(aRxBuf[uiFixedHeaderLen + 1]);        IF uiPacketId = uiPendingSubPacketId THEN            uiPayloadPos := uiFixedHeaderLen + 2;            IF eVersion = E_MqttVersion.byMqttVersion50 THEN                uiPropsHeaderLen := M_DecodeRemainingLength(                    pBuffer := ADR(aRxBuf[uiPayloadPos]),                    uiLength => uiPropsLen);                IF uiPropsHeaderLen = 0 THEN                    M_ProcessReceive := FALSE;                    RETURN;                END_IF                IF uiPayloadPos + uiPropsHeaderLen + uiPropsLen > uiFrameEndPos THEN                    M_ProcessReceive := FALSE;                    RETURN;                END_IF                uiPayloadPos := uiPayloadPos + uiPropsHeaderLen + uiPropsLen;            END_IF            IF uiPayloadPos >= uiFrameEndPos THEN                M_ProcessReceive := FALSE;                RETURN;            END_IF            bySubAckCode := aRxBuf[uiPayloadPos];            xWaitingForSubAck := FALSE;            IF bySubAckCode < 16#80 THEN                IF bySubAckCode > TO_BYTE(E_MqttQoS.byQoS2) THEN                    M_SetError(                        uiErrorCode := TO_UINT(E_ReasonCode.uiErrProtocolError),                        sMessage := 'SUBACK reason code is invalid');                    eState := E_MqttState.iTcpDisconnect;                    M_ProcessReceive := FALSE;                    RETURN;                END_IF                xSubscribedEvent := TRUE;                M_SubListAdd(                    sTopic := sActiveSubTopic,                    eQos := eActiveSubQoS,                    udiSubscriptionId := udiActiveSubscriptionId);                IF bActiveSubscribeRestore THEN                    IF uiRestoreSubscriptionIndex >= GVL_Mqtt.cnMaxSubscriptions THEN                        bRestoreSubscriptions := FALSE;                        uiRestoreSubscriptionIndex := 0;                    END_IF                END_IF                sActiveSubTopic := '';                eActiveSubQoS := E_MqttQoS.byQoS0;                udiActiveSubscriptionId := 0;                bActiveSubscribeRestore := FALSE;            ELSE                M_SetError(                    uiErrorCode := TO_UINT(E_ReasonCode.uiErrSubscriptionFailed),                    sMessage := 'Subscription rejected');                bRestoreSubscriptions := FALSE;                uiRestoreSubscriptionIndex := 0;                sActiveSubTopic := '';                eActiveSubQoS := E_MqttQoS.byQoS0;                udiActiveSubscriptionId := 0;                bActiveSubscribeRestore := FALSE;            END_IF        ELSE            M_ProcessReceive := FALSE;            RETURN;        END_IF    E_MqttPacketType.byUnsubAck:        /// UNSUBACK 成功后要同步移除本地订阅表中的主题意图；        /// 若服务端返回“不存在该订阅”，按 MQTT 5.0 允许值处理，不视为协议错。        IF byFlags <> 0 THEN            M_ProcessReceive := FALSE;            RETURN;        END_IF        IF ((eVersion = E_MqttVersion.byMqttVersion50) AND (uiFrameEndPos < 5)) OR           ((eVersion <> E_MqttVersion.byMqttVersion50) AND (uiFrameEndPos < 4)) THEN            M_ProcessReceive := FALSE;            RETURN;        END_IF        uiPacketId := SHL(BYTE_TO_UINT(aRxBuf[uiFixedHeaderLen]), 8) OR BYTE_TO_UINT(aRxBuf[uiFixedHeaderLen + 1]);        IF uiPacketId = uiPendingUnsubPacketId THEN            xWaitingForUnsubAck := FALSE;            byReasonCode := 0;            IF eVersion = E_MqttVersion.byMqttVersion50 THEN                uiPayloadPos := uiFixedHeaderLen + 2;                uiPropsHeaderLen := M_DecodeRemainingLength(                    pBuffer := ADR(aRxBuf[uiPayloadPos]),                    uiLength => uiPropsLen);                IF uiPropsHeaderLen = 0 THEN                    M_ProcessReceive := FALSE;                    RETURN;                END_IF                IF uiPayloadPos + uiPropsHeaderLen + uiPropsLen > uiFrameEndPos THEN                    M_ProcessReceive := FALSE;                    RETURN;                END_IF                uiPayloadPos := uiPayloadPos + uiPropsHeaderLen + uiPropsLen;                IF uiPayloadPos < uiFrameEndPos THEN                    byReasonCode := aRxBuf[uiPayloadPos];                END_IF            END_IF            IF (byReasonCode <> 0) AND (byReasonCode <> GVL_Mqtt.cnRcNoSubscriptionExisted) AND (byReasonCode < 16#80) THEN                M_SetError(                    uiErrorCode := TO_UINT(E_ReasonCode.uiErrProtocolError),                    sMessage := 'UNSUBACK reason code is invalid');                eState := E_MqttState.iTcpDisconnect;                M_ProcessReceive := FALSE;                RETURN;            END_IF            IF byReasonCode >= 16#80 THEN                M_SetError(                    uiErrorCode := TO_UINT(E_ReasonCode.uiErrSubscriptionFailed),                    sMessage := 'Unsubscribe rejected');            ELSE                xUnsubscribedEvent := TRUE;                M_SubListRemove(sTopic := sUnsubTopic);            END_IF        ELSE            M_ProcessReceive := FALSE;            RETURN;        END_IF    E_MqttPacketType.byPingResp:        /// PINGRESP 只是把“当前还有一笔心跳等待”清掉，不携带业务数据。        IF (byFlags <> 0) OR (uiRemainingLen <> 0) THEN            M_ProcessReceive := FALSE;            RETURN;        END_IF        bPingPending := FALSE;    E_MqttPacketType.byDisconnect:        /// 服务端主动发 DISCONNECT 时，客户端必须退出当前会话，        /// 同时把原因码转成可见诊断，便于现场判断是协议拒绝、管理断开还是迁移提示。        byReasonCode := 0;        IF eVersion = E_MqttVersion.byMqttVersion50 THEN            IF byFlags <> 0 THEN                M_SetError(                    uiErrorCode := TO_UINT(E_ReasonCode.uiErrProtocolError),                    sMessage := 'Invalid DISCONNECT flags');                eState := E_MqttState.iTcpDisconnect;                M_ProcessReceive := FALSE;                RETURN;            END_IF            IF uiRemainingLen >= 1 THEN                byReasonCode := aRxBuf[uiFixedHeaderLen];            END_IF        ELSIF (byFlags <> 0) OR (uiRemainingLen <> 0) THEN            M_SetError(                uiErrorCode := TO_UINT(E_ReasonCode.uiErrProtocolError),                sMessage := 'Invalid MQTT 3.1.1 DISCONNECT');            eState := E_MqttState.iTcpDisconnect;            M_ProcessReceive := FALSE;            RETURN;        END_IF        M_SetError(            uiErrorCode := TO_UINT(E_ReasonCode.uiErrNotConnected),            sMessage := CONCAT('Server sent DISCONNECT rc=', BYTE_TO_STRING(byReasonCode)));        eState := E_MqttState.iTcpDisconnect;    E_MqttPacketType.byAuth:        /// V2.0 当前不实现增强认证交换。        /// 一旦服务端进入 AUTH 流程，直接以明确诊断退出，避免假装兼容。        IF eVersion <> E_MqttVersion.byMqttVersion50 THEN            M_SetError(                uiErrorCode := TO_UINT(E_ReasonCode.uiErrProtocolError),                sMessage := 'Unexpected AUTH packet');            eState := E_MqttState.iTcpDisconnect;        ELSE            M_SetError(                uiErrorCode := TO_UINT(E_ReasonCode.uiErrAuthFailed),                sMessage := 'AUTH exchange is not supported in MqttClient_V2_0');            eState := E_MqttState.iTcpDisconnect;        END_IFELSE        M_SetError(            uiErrorCode := TO_UINT(E_ReasonCode.uiErrProtocolError),            sMessage := 'Unsupported packet type');        eState := E_MqttState.iTcpDisconnect;        M_ProcessReceive := FALSE;        RETURN;END_CASE/// 如果接收缓冲区里还粘着后续报文，把未消费字节整体前移，/// 这样下一次扫描就能从新帧起点继续解析。IF uiRxLength > uiFrameEndPos THEN    uiPayloadLen := uiRxLength - uiFrameEndPos;    IF uiPayloadLen > 0 THEN        FOR i := 1 TO uiPayloadLen DO            aRxBuf[i - 1] := aRxBuf[uiFrameEndPos + i - 1];        END_FOR    END_IF    uiRxLength := uiPayloadLen;ELSE    uiRxLength := 0;END_IFM_ProcessReceive := TRUE;

完整代码 2：M_ProcessPendingFrames.st

这一段完整公开 M_ProcessPendingFrames.st。读代码时先看对象职责，再看状态、长度、错误和返回值，不要只抄几行赋值。

/// =======================================================================/// 名称      : M_ProcessPendingFrames/// 功能      : 连续处理缓冲区中的完整报文/// 说明      : 只要存在完整报文就循环调用 M_ProcessReceive/// 编程人员  : ControlRookie/// 时间      : 2026-05-08/// 版本      : V2.0/// ======================================================================={attribute 'hide_all_locals'}METHOD M_ProcessPendingFrames : BOOLVAR    bProcessed      : BOOL;           // 是否处理过至少一帧END_VAR// === IMPLEMENTATION ===bProcessed := FALSE;WHILE uiRxLength > 0 DO    IF NOT M_ProcessReceive() THEN        EXIT;    END_IF    bProcessed := TRUE;    // 生成即时协议响应后，先交还主状态机发送 ACK，再继续处理后续入站帧。    IF xPendingImmediateTx THEN        EXIT;    END_IFEND_WHILEM_ProcessPendingFrames := bProcessed;

完整代码 3：M_BuildPubAckPacket.st

这一段完整公开 M_BuildPubAckPacket.st。读代码时先看对象职责，再看状态、长度、错误和返回值，不要只抄几行赋值。

/// =======================================================================/// 名称      : M_BuildPubAckPacket/// 功能      : 构建 PUBACK 发送报文/// 说明      : 根据 MQTT 版本组装 QoS1 发布确认报文并写入发送缓冲区。/// 编程人员  : ControlRookie/// 时间      : 2026-05-05/// 版本      : V1.0/// ======================================================================={attribute 'hide_all_locals'}METHOD M_BuildPubAckPacket : BOOLVAR_INPUT    uiPacketId : UINT; // 需要回给 Broker 的 QoS1 发布报文标识符END_VARVAR    uiPos               : UINT := 0; // 当前写入发送缓冲区的位置偏移[byte]    uiRemainingLen      : UINT;      // 写入固定报头中的 Remaining Length 值[byte]    i                   : DINT;      // 清空发送缓冲区时使用的循环索引END_VAR// === IMPLEMENTATION ===// BUG-10: 缓冲区溢出保护（PUBACK最大6字节）IF SIZEOF(aTxBuf) < 6 THEN    M_BuildPubAckPacket := FALSE;    RETURN;END_IF// 清空发送缓冲区FOR i := LOWER_BOUND(aTxBuf, 1) TO UPPER_BOUND(aTxBuf, 1) DO    aTxBuf[i] := 0;END_FOR/// =======================================================================/// 创建报文/// =======================================================================uiPos := 0;IF eVersion = E_MqttVersion.byMqttVersion50 THEN    // MQTT 5.0: Packet ID(2) + Reason Code(1) + Properties Length(1)    uiRemainingLen := 4;    aTxBuf[0] := E_MqttPacketType.byPubAck;    uiPos := 1;    uiPos := uiPos + M_EncodeRemainingLength(uiRemainingLen, ADR(aTxBuf[uiPos]));    // Packet ID    aTxBuf[uiPos] := UINT_TO_BYTE(SHR(uiPacketId, 8)); uiPos := uiPos + 1;    aTxBuf[uiPos] := UINT_TO_BYTE(uiPacketId AND 16#FF); uiPos := uiPos + 1;    // Reason Code: 0x00 = Success    aTxBuf[uiPos] := 16#00; uiPos := uiPos + 1;    // Properties Length: 0    aTxBuf[uiPos] := 0; uiPos := uiPos + 1;ELSE    // MQTT 3.1.1: Packet ID(2) only, BUG-03修复: remaining length = 2    uiRemainingLen := 2;    aTxBuf[0] := E_MqttPacketType.byPubAck;    uiPos := 1;    uiPos := uiPos + M_EncodeRemainingLength(uiRemainingLen, ADR(aTxBuf[uiPos]));    aTxBuf[uiPos] := UINT_TO_BYTE(SHR(uiPacketId, 8)); uiPos := uiPos + 1;    aTxBuf[uiPos] := UINT_TO_BYTE(uiPacketId AND 16#FF); uiPos := uiPos + 1;END_IFuiTxLength := uiPos;M_BuildPubAckPacket := TRUE;;

完整代码 4：M_BuildPubRecPacket.st

这一段完整公开 M_BuildPubRecPacket.st。读代码时先看对象职责，再看状态、长度、错误和返回值，不要只抄几行赋值。

/// =======================================================================/// 名称      : M_BuildPubRecPacket/// 功能      : 构建 PUBREC 发送报文/// 说明      : 根据 MQTT 版本组装 QoS2 第一步确认报文并更新发送长度。/// 编程人员  : ControlRookie/// 时间      : 2026-05-05/// 版本      : V1.0/// ======================================================================={attribute 'hide_all_locals'}METHOD M_BuildPubRecPacket : BOOLVAR_INPUT    uiPacketId : UINT; // 需要回给对端的 QoS2 第一步确认报文标识符END_VARVAR    uiPos               : UINT := 0; // 当前写入发送缓冲区的位置偏移[byte]    uiRemainingLen      : UINT;      // 写入固定报头中的 Remaining Length 值[byte]    i                   : DINT;      // 清空发送缓冲区时使用的循环索引END_VAR// === IMPLEMENTATION ===// BUG-10: 缓冲区溢出保护（PUBREC最大6字节）IF SIZEOF(aTxBuf) < 6 THEN    M_BuildPubRecPacket := FALSE;    RETURN;END_IF// 清空发送缓冲区FOR i := LOWER_BOUND(aTxBuf, 1) TO UPPER_BOUND(aTxBuf, 1) DO    aTxBuf[i] := 0;END_FORuiPos := 0;IF eVersion = E_MqttVersion.byMqttVersion50 THEN    // MQTT 5.0: Packet ID(2) + Reason Code(1) + Properties Length(1)    uiRemainingLen := 4;    aTxBuf[0] := E_MqttPacketType.byPubRec;    uiPos := 1;    uiPos := uiPos + M_EncodeRemainingLength(uiRemainingLen, ADR(aTxBuf[uiPos]));    aTxBuf[uiPos] := UINT_TO_BYTE(SHR(uiPacketId, 8)); uiPos := uiPos + 1;    aTxBuf[uiPos] := UINT_TO_BYTE(uiPacketId AND 16#FF); uiPos := uiPos + 1;    // Reason Code: 0x00 = Success    aTxBuf[uiPos] := 16#00; uiPos := uiPos + 1;    // Properties Length: 0    aTxBuf[uiPos] := 0; uiPos := uiPos + 1;ELSE    // MQTT 3.1.1: Packet ID(2) only, remaining length = 2    uiRemainingLen := 2;    aTxBuf[0] := E_MqttPacketType.byPubRec;    uiPos := 1;    uiPos := uiPos + M_EncodeRemainingLength(uiRemainingLen, ADR(aTxBuf[uiPos]));    aTxBuf[uiPos] := UINT_TO_BYTE(SHR(uiPacketId, 8)); uiPos := uiPos + 1;    aTxBuf[uiPos] := UINT_TO_BYTE(uiPacketId AND 16#FF); uiPos := uiPos + 1;END_IFuiTxLength := uiPos;M_BuildPubRecPacket := TRUE;;

完整代码 5：M_BuildPubRelPacket.st

这一段完整公开 M_BuildPubRelPacket.st。读代码时先看对象职责，再看状态、长度、错误和返回值，不要只抄几行赋值。

/// =======================================================================/// 名称      : M_BuildPubRelPacket/// 功能      : 构建 PUBREL 发送报文/// 说明      : 根据 MQTT 版本组装 QoS2 第二步释放报文并更新发送长度。/// 编程人员  : ControlRookie/// 时间      : 2026-05-05/// 版本      : V1.0/// ======================================================================={attribute 'hide_all_locals'}METHOD M_BuildPubRelPacket : BOOLVAR    uiPos               : UINT := 0; // 当前写入发送缓冲区的位置偏移[byte]    uiRemainingLen      : UINT;      // 写入固定报头中的 Remaining Length 值[byte]    i                   : DINT;      // 清空发送缓冲区时使用的循环索引END_VAR// === IMPLEMENTATION ===// BUG-10: 缓冲区溢出保护（PUBREL最大6字节）IF SIZEOF(aTxBuf) < 6 THEN    M_BuildPubRelPacket := FALSE;    RETURN;END_IF// 清空发送缓冲区FOR i := LOWER_BOUND(aTxBuf, 1) TO UPPER_BOUND(aTxBuf, 1) DO    aTxBuf[i] := 0;END_FORuiPos := 0;IF eVersion = E_MqttVersion.byMqttVersion50 THEN    // MQTT 5.0: Packet ID(2) + Reason Code(1) + Properties Length(1)    uiRemainingLen := 4;    aTxBuf[0] := E_MqttPacketType.byPubRel;    uiPos := 1;    uiPos := uiPos + M_EncodeRemainingLength(uiRemainingLen, ADR(aTxBuf[uiPos]));    aTxBuf[uiPos] := UINT_TO_BYTE(SHR(uiQoS2PacketId, 8)); uiPos := uiPos + 1;    aTxBuf[uiPos] := UINT_TO_BYTE(uiQoS2PacketId AND 16#FF); uiPos := uiPos + 1;    // Reason Code: 0x00 = Success    aTxBuf[uiPos] := 16#00; uiPos := uiPos + 1;    // Properties Length: 0    aTxBuf[uiPos] := 0; uiPos := uiPos + 1;ELSE    // MQTT 3.1.1: Packet ID(2) only, remaining length = 2    uiRemainingLen := 2;    aTxBuf[0] := E_MqttPacketType.byPubRel;    uiPos := 1;    uiPos := uiPos + M_EncodeRemainingLength(uiRemainingLen, ADR(aTxBuf[uiPos]));    aTxBuf[uiPos] := UINT_TO_BYTE(SHR(uiQoS2PacketId, 8)); uiPos := uiPos + 1;    aTxBuf[uiPos] := UINT_TO_BYTE(uiQoS2PacketId AND 16#FF); uiPos := uiPos + 1;END_IFuiTxLength := uiPos;M_BuildPubRelPacket := TRUE;;

完整代码 6：M_BuildPubCompPacket.st

这一段完整公开 M_BuildPubCompPacket.st。读代码时先看对象职责，再看状态、长度、错误和返回值，不要只抄几行赋值。

/// =======================================================================/// 名称      : M_BuildPubCompPacket/// 功能      : 构建 PUBCOMP 发送报文/// 说明      : 根据 MQTT 版本组装 QoS2 完成确认报文并更新发送长度。/// 编程人员  : ControlRookie/// 时间      : 2026-05-05/// 版本      : V1.0/// ======================================================================={attribute 'hide_all_locals'}METHOD M_BuildPubCompPacket : BOOLVAR_INPUT    uiPacketId : UINT; // 需要回给对端的 QoS2 完成阶段报文标识符END_VARVAR    uiPos               : UINT := 0; // 当前写入发送缓冲区的位置偏移[byte]    uiRemainingLen      : UINT;      // 写入固定报头中的 Remaining Length 值[byte]    i                   : DINT;      // 清空发送缓冲区时使用的循环索引END_VAR// === IMPLEMENTATION ===// BUG-10: 缓冲区溢出保护（PUBCOMP最大6字节）IF SIZEOF(aTxBuf) < 6 THEN    M_BuildPubCompPacket := FALSE;    RETURN;END_IF// 清空发送缓冲区FOR i := LOWER_BOUND(aTxBuf, 1) TO UPPER_BOUND(aTxBuf, 1) DO    aTxBuf[i] := 0;END_FORuiPos := 0;IF eVersion = E_MqttVersion.byMqttVersion50 THEN    // MQTT 5.0: Packet ID(2) + Reason Code(1) + Properties Length(1)    uiRemainingLen := 4;    aTxBuf[0] := E_MqttPacketType.byPubComp;    uiPos := 1;    uiPos := uiPos + M_EncodeRemainingLength(uiRemainingLen, ADR(aTxBuf[uiPos]));    aTxBuf[uiPos] := UINT_TO_BYTE(SHR(uiPacketId, 8)); uiPos := uiPos + 1;    aTxBuf[uiPos] := UINT_TO_BYTE(uiPacketId AND 16#FF); uiPos := uiPos + 1;    // Reason Code: 0x00 = Success    aTxBuf[uiPos] := 16#00; uiPos := uiPos + 1;    // Properties Length: 0    aTxBuf[uiPos] := 0; uiPos := uiPos + 1;ELSE    // MQTT 3.1.1: BUG-04修复, remaining length = 2    uiRemainingLen := 2;    aTxBuf[0] := E_MqttPacketType.byPubComp;    uiPos := 1;    uiPos := uiPos + M_EncodeRemainingLength(uiRemainingLen, ADR(aTxBuf[uiPos]));    aTxBuf[uiPos] := UINT_TO_BYTE(SHR(uiPacketId, 8)); uiPos := uiPos + 1;    aTxBuf[uiPos] := UINT_TO_BYTE(uiPacketId AND 16#FF); uiPos := uiPos + 1;END_IFuiTxLength := uiPos;M_BuildPubCompPacket := TRUE;;

完整代码 7：M_HandlePubAck.st

这一段完整公开 M_HandlePubAck.st。读代码时先看对象职责，再看状态、长度、错误和返回值，不要只抄几行赋值。

/// =======================================================================/// 名称      : M_HandlePubAck/// 功能      : 兼容桩方法，保留 PUBACK 旧接口/// 说明      : 该方法已废弃，实际处理逻辑已迁移至 M_ProcessReceive，仅为兼容旧调用保留。/// 编程人员  : ControlRookie/// 时间      : 2026-05-05/// 版本      : V1.0/// ======================================================================={attribute 'hide_all_locals'}METHOD M_HandlePubAck : BOOLVAR_INPUTEND_VAR// === IMPLEMENTATION ===// 逻辑已移至M_ProcessReceiveM_HandlePubAck := FALSE;

完整代码 8：M_HandlePubRec.st

这一段完整公开 M_HandlePubRec.st。读代码时先看对象职责，再看状态、长度、错误和返回值，不要只抄几行赋值。

/// =======================================================================/// 名称      : M_HandlePubRec/// 功能      : 兼容桩方法，保留 PUBREC 旧接口/// 说明      : 该方法已废弃，实际处理逻辑已迁移至 M_ProcessReceive，仅为兼容旧调用保留。/// 编程人员  : ControlRookie/// 时间      : 2026-05-05/// 版本      : V1.0/// ======================================================================={attribute 'hide_all_locals'}METHOD M_HandlePubRec : BOOLVAR_INPUTEND_VAR// === IMPLEMENTATION ===// 逻辑已移至M_ProcessReceiveM_HandlePubRec := FALSE;

完整代码 9：M_HandlePubRel.st

这一段完整公开 M_HandlePubRel.st。读代码时先看对象职责，再看状态、长度、错误和返回值，不要只抄几行赋值。

/// =======================================================================/// 名称      : M_HandlePubRel/// 功能      : 兼容桩方法，保留 PUBREL 旧接口/// 说明      : 该方法已废弃，实际处理逻辑已迁移至 M_ProcessReceive，仅为兼容旧调用保留。/// 编程人员  : ControlRookie/// 时间      : 2026-05-05/// 版本      : V1.0/// ======================================================================={attribute 'hide_all_locals'}METHOD M_HandlePubRel : BOOLVAR_INPUTEND_VAR// === IMPLEMENTATION ===// 逻辑已移至M_ProcessReceiveM_HandlePubRel := FALSE;

完整代码 10：M_HandlePubComp.st

这一段完整公开 M_HandlePubComp.st。读代码时先看对象职责，再看状态、长度、错误和返回值，不要只抄几行赋值。

/// =======================================================================/// 名称      : M_HandlePubComp/// 功能      : 兼容桩方法，保留 PUBCOMP 旧接口/// 说明      : 该方法已废弃，实际处理逻辑已迁移至 M_ProcessReceive，仅为兼容旧调用保留。/// 编程人员  : ControlRookie/// 时间      : 2026-05-05/// 版本      : V1.0/// ======================================================================={attribute 'hide_all_locals'}METHOD M_HandlePubComp : BOOLVAR_INPUTEND_VAR// === IMPLEMENTATION ===// 逻辑已移至M_ProcessReceiveM_HandlePubComp := FALSE;

完整代码 11：M_InflightAdd.st

这一段完整公开 M_InflightAdd.st。读代码时先看对象职责，再看状态、长度、错误和返回值，不要只抄几行赋值。

/// =======================================================================/// 名称      : M_InflightAdd/// 功能      : 将出站消息加入在途队列/// 说明      : 为 QoS1 / QoS2 发布消息创建在途记录并返回索引/// 编程人员  : ControlRookie/// 时间      : 2026-05-08/// 版本      : V2.0/// ======================================================================={attribute 'hide_all_locals'}METHOD M_InflightAdd : UINTVAR_INPUT    uiPacketId      : UINT;           // 需要登记到出站在途队列的 Packet Identifier    eQoS            : E_MqttQoS;      // 消息 QoS 等级    sTopic          : STRING(GVL_Mqtt.cnMaxTopicLen);   // 发布主题    sPayload        : STRING(GVL_Mqtt.cnMaxPayloadSize); // 发布载荷    uiPayloadLen    : UINT;           // 发布载荷长度[byte]    bRetain         : BOOL;           // Retain 标志END_VARVAR    i               : UINT;           // 循环索引END_VAR// === IMPLEMENTATION ===// 先做容量保护，避免超出本地在途窗口上限后继续塞入新消息。IF uiInflightCount >= GVL_Mqtt.cnMaxInflight THEN    M_InflightAdd := 0;    RETURN;END_IF// 在线性数组里找第一条空槽位，用最简单直接的方式维护 QoS>0 出站上下文。FOR i := 1 TO GVL_Mqtt.cnMaxInflight DO    IF NOT aInflight[i].bUsed THEN        aInflight[i].bUsed := TRUE;        aInflight[i].uiPacketId := uiPacketId;        aInflight[i].eQoS := eQoS;        aInflight[i].sTopic := sTopic;        aInflight[i].sPayload := sPayload;        aInflight[i].uiPayloadLen := uiPayloadLen;        aInflight[i].bRetain := bRetain;        aInflight[i].bDup := FALSE;        aInflight[i].uiRetryCount := 0;        aInflight[i].tLastSend := TIME();        aInflight[i].eState := E_MqttInflightState.iPublishSent;        uiInflightCount := uiInflightCount + 1;        // MQTT 5.0 下，发送一条新的 QoS>0 出站消息就要消耗一份服务器授予的发送配额。        IF (eVersion = E_MqttVersion.byMqttVersion50) AND (uiSendQuota > 0) THEN            uiSendQuota := uiSendQuota - 1;        END_IF        M_InflightAdd := i;        RETURN;    END_IFEND_FORM_InflightAdd := 0;

完整代码 12：M_InflightCheckTimeout.st

这一段完整公开 M_InflightCheckTimeout.st。读代码时先看对象职责，再看状态、长度、错误和返回值，不要只抄几行赋值。

/// =======================================================================/// 名称      : M_InflightCheckTimeout/// 功能      : 扫描在途消息超时/// 说明      : 找到需要重发的首个在途消息并返回其索引/// 编程人员  : ControlRookie/// 时间      : 2026-05-08/// 版本      : V2.0/// ======================================================================={attribute 'hide_all_locals'}METHOD M_InflightCheckTimeout : UINTVAR    i               : UINT;           // 循环索引    tCurrent        : TIME;           // 当前时间END_VAR// === IMPLEMENTATION ===// 逐条扫描在途表，找到第一条已经超时且仍允许重发的消息。tCurrent := TIME();FOR i := 1 TO GVL_Mqtt.cnMaxInflight DO    IF aInflight[i].bUsed THEN        IF (tCurrent - aInflight[i].tLastSend) >= GVL_Mqtt.cnInflightTimeout THEN            IF aInflight[i].uiRetryCount < GVL_Mqtt.cnMaxRetries THEN                // 进入重发前先置 DUP，并刷新“上次发送时间”和重试计数。                aInflight[i].bDup := TRUE;                aInflight[i].uiRetryCount := aInflight[i].uiRetryCount + 1;                aInflight[i].tLastSend := tCurrent;                M_InflightCheckTimeout := i;                RETURN;            ELSE                // 超过最大重试次数后，说明这条消息的交付闭环已经不可恢复，记录错误并释放槽位。                M_SetError(                    uiErrorCode := TO_UINT(E_ReasonCode.uiErrTimeout),                    sMessage := 'Inflight publish retry exceeded');                M_InflightRemove(uiPacketId := aInflight[i].uiPacketId);            END_IF        END_IF    END_IFEND_FORM_InflightCheckTimeout := 0;

完整代码 13：M_InflightClear.st

这一段完整公开 M_InflightClear.st。读代码时先看对象职责，再看状态、长度、错误和返回值，不要只抄几行赋值。

/// =======================================================================/// 名称      : M_InflightClear/// 功能      : 清空出站在途队列/// 说明      : 在禁用、断开或新会话开始时重置在途消息/// 编程人员  : ControlRookie/// 时间      : 2026-05-08/// 版本      : V2.0/// ======================================================================={attribute 'hide_all_locals'}METHOD M_InflightClear : BOOLVAR    i               : UINT;           // 循环索引END_VAR// === IMPLEMENTATION ===// 清空所有出站在途槽位，同时一并清掉接收侧 QoS2 去重表。FOR i := 1 TO GVL_Mqtt.cnMaxInflight DO    aInflight[i].bUsed := FALSE;    aInflight[i].uiPacketId := 0;    aInflight[i].sTopic := '';    aInflight[i].sPayload := '';    aInflight[i].uiPayloadLen := 0;    aInflight[i].bRetain := FALSE;    aInflight[i].bDup := FALSE;    aInflight[i].uiRetryCount := 0;    aInflight[i].tLastSend := T#0S;    aInflight[i].eState := E_MqttInflightState.iIdle;    aRxQoS2PacketIds[i] := 0;END_FORuiInflightCount := 0;uiRxInFlightQosCount := 0;uiRetryInflightIndex := 0;// 新会话开始时，发送窗口恢复到服务端允许的 Receive Maximum；// 如果服务端还没明确给过值，就退回本地默认窗口。IF uiServerReceiveMax = 0 THEN    uiSendQuota := GVL_Mqtt.cnDefaultReceiveMax;ELSE    uiSendQuota := uiServerReceiveMax;END_IFM_InflightClear := TRUE;

完整代码 14：M_InflightFind.st

这一段完整公开 M_InflightFind.st。读代码时先看对象职责，再看状态、长度、错误和返回值，不要只抄几行赋值。

/// =======================================================================/// 名称      : M_InflightFind/// 功能      : 按 Packet ID 查找在途消息/// 说明      : 返回队列索引，0 表示未找到/// 编程人员  : ControlRookie/// 时间      : 2026-05-08/// 版本      : V2.0/// ======================================================================={attribute 'hide_all_locals'}METHOD M_InflightFind : UINTVAR_INPUT    uiPacketId      : UINT;           // 需要在出站在途队列中查找的 Packet IdentifierEND_VARVAR    i               : UINT;           // 循环索引END_VAR// === IMPLEMENTATION ===FOR i := 1 TO GVL_Mqtt.cnMaxInflight DO    IF aInflight[i].bUsed AND aInflight[i].uiPacketId = uiPacketId THEN        M_InflightFind := i;        RETURN;    END_IFEND_FORM_InflightFind := 0;

完整代码 15：M_InflightRemove.st

这一段完整公开 M_InflightRemove.st。读代码时先看对象职责，再看状态、长度、错误和返回值，不要只抄几行赋值。

/// =======================================================================/// 名称      : M_InflightRemove/// 功能      : 从在途队列删除消息/// 说明      : 在 QoS1 / QoS2 流程完成后释放在途槽位/// 编程人员  : ControlRookie/// 时间      : 2026-05-08/// 版本      : V2.0/// ======================================================================={attribute 'hide_all_locals'}METHOD M_InflightRemove : BOOLVAR_INPUT    uiPacketId      : UINT;           // 需要从出站在途队列移除的 Packet IdentifierEND_VARVAR    uiIndex         : UINT;           // 命中的出站在途队列槽位索引END_VAR// === IMPLEMENTATION ===// 先按 Packet Identifier 找到对应在途槽位；找不到说明当前没有需要释放的上下文。uiIndex := M_InflightFind(uiPacketId := uiPacketId);IF uiIndex = 0 THEN    M_InflightRemove := FALSE;    RETURN;END_IF// 释放槽位时把所有和这条消息相关的缓存一起清掉，避免后续误复用旧数据。aInflight[uiIndex].bUsed := FALSE;aInflight[uiIndex].uiPacketId := 0;aInflight[uiIndex].sTopic := '';aInflight[uiIndex].sPayload := '';aInflight[uiIndex].uiPayloadLen := 0;aInflight[uiIndex].bRetain := FALSE;aInflight[uiIndex].bDup := FALSE;aInflight[uiIndex].uiRetryCount := 0;aInflight[uiIndex].tLastSend := T#0S;aInflight[uiIndex].eState := E_MqttInflightState.iIdle;IF uiInflightCount > 0 THEN    uiInflightCount := uiInflightCount - 1;END_IF// MQTT 5.0 下，消息完成后需要把一份发送配额还给本地发送窗口。IF eVersion = E_MqttVersion.byMqttVersion50 THEN    IF uiSendQuota < uiServerReceiveMax THEN        uiSendQuota := uiSendQuota + 1;    END_IFEND_IFM_InflightRemove := TRUE;

完整代码 16：M_InflightUpdateState.st

这一段完整公开 M_InflightUpdateState.st。读代码时先看对象职责，再看状态、长度、错误和返回值，不要只抄几行赋值。

/// =======================================================================/// 名称      : M_InflightUpdateState/// 功能      : 更新在途消息状态/// 说明      : 对 QoS1 / QoS2 流程的状态迁移执行最小合法性约束/// 编程人员  : ControlRookie/// 时间      : 2026-05-05/// 版本      : V1.1/// ======================================================================={attribute 'hide_all_locals'}METHOD M_InflightUpdateState : BOOLVAR_INPUT    uiPacketId      : UINT;                   // 需要更新状态的出站在途 Packet Identifier    eNewState       : E_MqttInflightState;    // 新状态END_VARVAR    uiIndex         : UINT;                   // 命中的出站在途队列槽位索引    bTransitionOk   : BOOL;                   // 状态迁移是否合法END_VAR// === IMPLEMENTATION ===// 只有已经存在于在途表中的 Packet Identifier 才允许更新状态。uiIndex := M_InflightFind(uiPacketId := uiPacketId);IF uiIndex = 0 THEN    M_InflightUpdateState := FALSE;    RETURN;END_IF// 这里只允许最小必要的合法迁移，避免状态机被异常报文拉进不合理状态。bTransitionOk := FALSE;CASE aInflight[uiIndex].eState OF    E_MqttInflightState.iPublishSent:        IF (eNewState = E_MqttInflightState.iPublishSent) OR           (eNewState = E_MqttInflightState.iPubRecReceived) OR           (eNewState = E_MqttInflightState.iCompleted) THEN            bTransitionOk := TRUE;        END_IF    E_MqttInflightState.iPubRecReceived:        IF (eNewState = E_MqttInflightState.iPubRecReceived) OR           (eNewState = E_MqttInflightState.iPubRelSent) THEN            bTransitionOk := TRUE;        END_IF    E_MqttInflightState.iPubRelSent:        IF (eNewState = E_MqttInflightState.iPubRelSent) OR           (eNewState = E_MqttInflightState.iCompleted) THEN            bTransitionOk := TRUE;        END_IF    E_MqttInflightState.iCompleted:        IF eNewState = E_MqttInflightState.iCompleted THEN            bTransitionOk := TRUE;        END_IFEND_CASEIF NOT bTransitionOk THEN    M_InflightUpdateState := FALSE;    RETURN;END_IF// 合法迁移才真正落盘，供后续超时重发和 ACK 匹配继续使用。aInflight[uiIndex].eState := eNewState;M_InflightUpdateState := TRUE;

完整代码 17：M_RxQoS2Add.st

这一段完整公开 M_RxQoS2Add.st。读代码时先看对象职责，再看状态、长度、错误和返回值，不要只抄几行赋值。

/// =======================================================================/// 名称      : M_RxQoS2Add/// 功能      : 记录入站 QoS2 报文标识符/// 说明      : 用于 QoS2 消息去重，成功返回 TRUE/// 编程人员  : ControlRookie/// 时间      : 2026-05-08/// 版本      : V2.0/// ======================================================================={attribute 'hide_all_locals'}METHOD M_RxQoS2Add : BOOLVAR_INPUT    uiPacketId      : UINT;           // 需要登记到入站 QoS2 去重表的 Packet IdentifierEND_VARVAR    i               : UINT;           // 循环索引END_VAR// === IMPLEMENTATION ===// QoS2 的 Packet Identifier 不能为 0。IF uiPacketId = 0 THEN    M_RxQoS2Add := FALSE;    RETURN;END_IF// 已经存在则直接视为登记成功，避免重复占用去重槽位。IF M_RxQoS2Find(uiPacketId := uiPacketId) > 0 THEN    M_RxQoS2Add := TRUE;    RETURN;END_IF// 找第一条空槽位登记，用于后续识别重复到达的 QoS2 PUBLISH。FOR i := 1 TO GVL_Mqtt.cnMaxInflight DO    IF aRxQoS2PacketIds[i] = 0 THEN        aRxQoS2PacketIds[i] := uiPacketId;        uiRxInFlightQosCount := uiRxInFlightQosCount + 1;        M_RxQoS2Add := TRUE;        RETURN;    END_IFEND_FORM_RxQoS2Add := FALSE;

完整代码 18：M_RxQoS2Find.st

这一段完整公开 M_RxQoS2Find.st。读代码时先看对象职责，再看状态、长度、错误和返回值，不要只抄几行赋值。

/// =======================================================================/// 名称      : M_RxQoS2Find/// 功能      : 查找入站 QoS2 去重记录/// 说明      : 返回索引，0 表示未找到/// 编程人员  : ControlRookie/// 时间      : 2026-05-08/// 版本      : V2.0/// ======================================================================={attribute 'hide_all_locals'}METHOD M_RxQoS2Find : UINTVAR_INPUT    uiPacketId      : UINT;           // 需要在入站 QoS2 去重表中查找的 Packet IdentifierEND_VARVAR    i               : UINT;           // 循环索引END_VAR// === IMPLEMENTATION ===FOR i := 1 TO GVL_Mqtt.cnMaxInflight DO    IF aRxQoS2PacketIds[i] = uiPacketId THEN        M_RxQoS2Find := i;        RETURN;    END_IFEND_FORM_RxQoS2Find := 0;

完整代码 19：M_RxQoS2Remove.st

这一段完整公开 M_RxQoS2Remove.st。读代码时先看对象职责，再看状态、长度、错误和返回值，不要只抄几行赋值。

/// =======================================================================/// 名称      : M_RxQoS2Remove/// 功能      : 删除入站 QoS2 去重记录/// 说明      : 在收到对应 PUBREL 后释放记录/// 编程人员  : ControlRookie/// 时间      : 2026-05-08/// 版本      : V2.0/// ======================================================================={attribute 'hide_all_locals'}METHOD M_RxQoS2Remove : BOOLVAR_INPUT    uiPacketId      : UINT;           // 需要从入站 QoS2 去重表中移除的 Packet IdentifierEND_VARVAR    uiIndex         : UINT;           // 命中的入站 QoS2 去重表槽位索引END_VAR// === IMPLEMENTATION ===// 先找到对应 Packet Identifier 的去重记录；没有就说明当前无需释放。uiIndex := M_RxQoS2Find(uiPacketId := uiPacketId);IF uiIndex = 0 THEN    M_RxQoS2Remove := FALSE;    RETURN;END_IF// PUBREL 完成后，这条入站 QoS2 消息的去重上下文就可以释放。aRxQoS2PacketIds[uiIndex] := 0;IF uiRxInFlightQosCount > 0 THEN    uiRxInFlightQosCount := uiRxInFlightQosCount - 1;END_IFM_RxQoS2Remove := TRUE;

完整代码 20：M_TopicAliasClear.st

这一段完整公开 M_TopicAliasClear.st。读代码时先看对象职责，再看状态、长度、错误和返回值，不要只抄几行赋值。

/// =======================================================================/// 名称      : M_TopicAliasClear/// 功能      : 清空主题别名表/// 说明      : 在新连接建立时清理旧连接的 Topic Alias 映射/// 编程人员  : ControlRookie/// 时间      : 2026-05-08/// 版本      : V2.0/// ======================================================================={attribute 'hide_all_locals'}METHOD M_TopicAliasClear : BOOLVAR    i               : UINT;           // 循环索引END_VAR// === IMPLEMENTATION ===// Topic Alias 属于单连接上下文；新连接建立前必须把旧映射全部清掉。FOR i := 1 TO GVL_Mqtt.cnMaxTopicAlias DO    aTopicAlias[i].bUsed := FALSE;    aTopicAlias[i].uiAliasId := 0;    aTopicAlias[i].sTopic := '';END_FORuiTopicAliasCount := 0;uiNextTopicAlias := 1;M_TopicAliasClear := TRUE;

完整代码 21：M_TopicAliasLookup.st

这一段完整公开 M_TopicAliasLookup.st。读代码时先看对象职责，再看状态、长度、错误和返回值，不要只抄几行赋值。

/// =======================================================================/// 名称      : M_TopicAliasLookup/// 功能      : 查找主题别名对应的主题/// 说明      : 返回主题字符串，未找到时返回空字符串/// 编程人员  : ControlRookie/// 时间      : 2026-05-08/// 版本      : V2.0/// ======================================================================={attribute 'hide_all_locals'}METHOD M_TopicAliasLookup : STRING(GVL_Mqtt.cnMaxTopicLen)VAR_INPUT    uiAliasId       : UINT;           // 主题别名END_VARVAR    i               : UINT;           // 循环索引END_VAR// === IMPLEMENTATION ===// Topic Alias 0 无效，直接返回空字符串。IF uiAliasId = 0 THEN    M_TopicAliasLookup := '';    RETURN;END_IF// 在本地别名表里按编号查找，命中后返回缓存的原始主题。FOR i := 1 TO GVL_Mqtt.cnMaxTopicAlias DO    IF aTopicAlias[i].bUsed AND aTopicAlias[i].uiAliasId = uiAliasId THEN        M_TopicAliasLookup := aTopicAlias[i].sTopic;        RETURN;    END_IFEND_FORM_TopicAliasLookup := '';

完整代码 22：M_TopicAliasRegister.st

这一段完整公开 M_TopicAliasRegister.st。读代码时先看对象职责，再看状态、长度、错误和返回值，不要只抄几行赋值。

/// =======================================================================/// 名称      : M_TopicAliasRegister/// 功能      : 注册主题别名映射/// 说明      : 保存接收方向 Topic Alias 与主题的映射关系/// 编程人员  : ControlRookie/// 时间      : 2026-05-08/// 版本      : V2.0/// ======================================================================={attribute 'hide_all_locals'}METHOD M_TopicAliasRegister : BOOLVAR_INPUT    uiAliasId       : UINT;           // 主题别名    sTopic          : STRING(GVL_Mqtt.cnMaxTopicLen); // 主题名称END_VARVAR    i               : UINT;           // 循环索引END_VAR// === IMPLEMENTATION ===// Topic Alias 0 在 MQTT 5.0 中非法，直接拒绝。IF uiAliasId = 0 THEN    M_TopicAliasRegister := FALSE;    RETURN;END_IF// 本地别名表也受固定容量限制，超过后不再继续登记。IF uiAliasId > GVL_Mqtt.cnMaxTopicAlias THEN    M_TopicAliasRegister := FALSE;    RETURN;END_IF// 如果别名已存在，则按协议语义覆盖为最新主题映射。FOR i := 1 TO GVL_Mqtt.cnMaxTopicAlias DO    IF aTopicAlias[i].bUsed AND aTopicAlias[i].uiAliasId = uiAliasId THEN        aTopicAlias[i].sTopic := sTopic;        M_TopicAliasRegister := TRUE;        RETURN;    END_IFEND_FOR// 否则找空槽位插入一条新映射，供后续“仅带 Topic Alias 不带 Topic Name”的报文复原主题。FOR i := 1 TO GVL_Mqtt.cnMaxTopicAlias DO    IF NOT aTopicAlias[i].bUsed THEN        aTopicAlias[i].bUsed := TRUE;        aTopicAlias[i].uiAliasId := uiAliasId;        aTopicAlias[i].sTopic := sTopic;        uiTopicAliasCount := uiTopicAliasCount + 1;        M_TopicAliasRegister := TRUE;        RETURN;    END_IFEND_FORM_TopicAliasRegister := FALSE;

完整代码 23：M_RecordReceivedMessage.st

这一段完整公开 M_RecordReceivedMessage.st。读代码时先看对象职责，再看状态、长度、错误和返回值，不要只抄几行赋值。

/// =======================================================================/// 名称      : M_RecordReceivedMessage/// 功能      : 记录最新接收消息/// 说明      : 统一维护接收历史、单次事件标志和统计量，避免多处分支重复写入。/// 编程人员  : ControlRookie/// 时间      : 2026-05-07/// 版本      : V2.0/// ======================================================================={attribute 'hide_all_locals'}METHOD M_RecordReceivedMessage : BOOLVAR    j             : DINT;   // 历史数组循环索引END_VAR// === IMPLEMENTATION ===FOR j := UPPER_BOUND(aRecTopicList, 1) TO LOWER_BOUND(aRecTopicList, 1) + 1 BY -1 DO    aRecTopicList[j] := aRecTopicList[j - 1];    aRecPayloadList[j] := aRecPayloadList[j - 1];END_FORaRecTopicList[0] := sRecTopic;aRecPayloadList[0] := sRecPayload;bMessageReceived := TRUE;uiMessagesReceived := uiMessagesReceived + 1;dtLastMessageTime := ULINT_TO_DT(uliSysTime / 1000);M_RecordReceivedMessage := TRUE;

完整代码 24：FB_MqttPropertyCodec.st

这一段完整公开 FB_MqttPropertyCodec.st。读代码时先看对象职责，再看状态、长度、错误和返回值，不要只抄几行赋值。

/// =======================================================================/// 名称      : FB_MqttPropertyCodec/// 功能      : MQTT 5.0 属性编解码器/// 说明      : 提供属性的编码（写入缓冲区）和解码（从缓冲区读取）功能，///             供 CONNECT、CONNACK、PUBLISH、SUBSCRIBE 等报文复用/// 编程人员  : ControlRookie/// 时间      : 2026-05-08/// 版本      : V2.0/// ======================================================================={attribute 'hide_all_locals'}FUNCTION_BLOCK FB_MqttPropertyCodecVAR    // 编码缓冲区（由 Encode 方法写入 MQTT 5.0 属性时复用）    aPropBuf        : ARRAY[0..511] OF BYTE; // MQTT 5.0 属性编码临时缓冲区[byte]    uiPropPos       : UINT;                  // 当前属性缓冲区写入位置索引[byte]END_VAR// === IMPLEMENTATION ===// 本 FB 自身不直接执行业务逻辑，// 真实的属性读写行为全部由其下属方法承担。

完整代码 25：FB_Random.st

这一段完整公开 FB_Random.st。读代码时先看对象职责，再看状态、长度、错误和返回值，不要只抄几行赋值。

/// =======================================================================/// 名称      : FB_Random/// 功能      : 简单伪随机数发生器/// 说明      : 根据 3 个输入种子生成 ASCII 可打印区间内的伪随机值，///             主要用于示例或轻量场景，不作为密码学随机源/// 编程人员  : ControlRookie/// 时间      : 2026-05-08/// 版本      : V2.0/// ======================================================================={attribute 'hide_all_locals'}FUNCTION_BLOCK FB_RandomVAR_INPUT    dwSeedA             : DWORD;     // 输入种子 A    dwSeedB             : DWORD;     // 输入种子 B    dwSeedV             : DWORD;     // 输入种子 VEND_VARVAR_OUTPUT    dwRandom            : DWORD;     // 输出的伪随机 ASCII 码值END_VARVAR    dwModulus           : DWORD;     // 取模基数    dwSequence          : DWORD;     // 内部序列值END_VAR// === IMPLEMENTATION ===// 用一个很轻量的递增序列扰动输入种子，产出 A..Y 区间的可打印 ASCII 值。dwSequence := dwSequence + 2;dwModulus := 25;dwRandom := (dwSeedA + dwSeedV + dwSeedB + dwSequence) MOD dwModulus + 65;

这一篇你最该记住的几句话

  1. 源码加更不是片段展示，而是完整源码对象公开讲解。
  2. 先建立对象地图，再读状态、报文和事务，现场调试才不会迷路。
  3. 判断源码成熟度，不只看功能是否实现，还要看边界、错误和在线观测量是否闭环。

系列导航

  • 系列定位：MqttClient 系列教程，源码加更阶段，第 16 篇 / 共 16 篇
  • 上一篇：源码加更05
  • 下一篇：系列收官，无下一篇
基本 文件 流程 错误 SQL 调试
  1. 请求信息 : 2026-06-26 22:50:28 HTTP/1.1 GET : https://www.yeyulingfeng.com/a/805426.html
  2. 运行时间 : 0.129193s [ 吞吐率：7.74req/s ] 内存消耗：5,289.32kb 文件加载：145
  3. 缓存信息 : 0 reads,0 writes
  4. 会话信息 : SESSION_ID=48338f1c9ff00ba5e57e52b898348470
  1. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/public/index.php ( 0.79 KB )
  2. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/autoload.php ( 0.17 KB )
  3. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/composer/autoload_real.php ( 2.49 KB )
  4. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/composer/platform_check.php ( 0.90 KB )
  5. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/composer/ClassLoader.php ( 14.03 KB )
  6. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/composer/autoload_static.php ( 6.05 KB )
  7. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/think-helper/src/helper.php ( 8.34 KB )
  8. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/think-validate/src/helper.php ( 2.19 KB )
  9. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/ralouphie/getallheaders/src/getallheaders.php ( 1.60 KB )
  10. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/think-orm/src/helper.php ( 1.47 KB )
  11. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/think-orm/stubs/load_stubs.php ( 0.16 KB )
  12. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/think/Exception.php ( 1.69 KB )
  13. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/think-container/src/Facade.php ( 2.71 KB )
  14. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/symfony/deprecation-contracts/function.php ( 0.99 KB )
  15. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/symfony/polyfill-mbstring/bootstrap.php ( 8.26 KB )
  16. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/symfony/polyfill-mbstring/bootstrap80.php ( 9.78 KB )
  17. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/symfony/var-dumper/Resources/functions/dump.php ( 1.49 KB )
  18. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/think-dumper/src/helper.php ( 0.18 KB )
  19. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/symfony/var-dumper/VarDumper.php ( 4.30 KB )
  20. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/guzzlehttp/guzzle/src/functions_include.php ( 0.16 KB )
  21. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/guzzlehttp/guzzle/src/functions.php ( 5.54 KB )
  22. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/think/App.php ( 15.30 KB )
  23. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/think-container/src/Container.php ( 15.76 KB )
  24. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/psr/container/src/ContainerInterface.php ( 1.02 KB )
  25. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/app/provider.php ( 0.19 KB )
  26. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/think/Http.php ( 6.04 KB )
  27. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/think-helper/src/helper/Str.php ( 7.29 KB )
  28. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/think/Env.php ( 4.68 KB )
  29. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/app/common.php ( 0.03 KB )
  30. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/helper.php ( 18.78 KB )
  31. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/think/Config.php ( 5.54 KB )
  32. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/config/alipay.php ( 3.59 KB )
  33. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/think/facade/Env.php ( 1.67 KB )
  34. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/config/app.php ( 0.95 KB )
  35. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/config/cache.php ( 0.78 KB )
  36. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/config/console.php ( 0.23 KB )
  37. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/config/cookie.php ( 0.56 KB )
  38. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/config/database.php ( 2.48 KB )
  39. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/config/filesystem.php ( 0.61 KB )
  40. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/config/lang.php ( 0.91 KB )
  41. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/config/log.php ( 1.35 KB )
  42. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/config/middleware.php ( 0.19 KB )
  43. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/config/route.php ( 1.89 KB )
  44. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/config/session.php ( 0.57 KB )
  45. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/config/trace.php ( 0.34 KB )
  46. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/config/view.php ( 0.82 KB )
  47. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/app/event.php ( 0.25 KB )
  48. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/think/Event.php ( 7.67 KB )
  49. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/app/service.php ( 0.13 KB )
  50. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/app/AppService.php ( 0.26 KB )
  51. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/think/Service.php ( 1.64 KB )
  52. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/think/Lang.php ( 7.35 KB )
  53. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/lang/zh-cn.php ( 13.70 KB )
  54. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/think/initializer/Error.php ( 3.31 KB )
  55. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/think/initializer/RegisterService.php ( 1.33 KB )
  56. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/services.php ( 0.14 KB )
  57. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/think/service/PaginatorService.php ( 1.52 KB )
  58. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/think/service/ValidateService.php ( 0.99 KB )
  59. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/think/service/ModelService.php ( 2.04 KB )
  60. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/think-trace/src/Service.php ( 0.77 KB )
  61. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/think/Middleware.php ( 6.72 KB )
  62. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/think/initializer/BootService.php ( 0.77 KB )
  63. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/think-orm/src/Paginator.php ( 11.86 KB )
  64. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/think-validate/src/Validate.php ( 63.20 KB )
  65. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/think-orm/src/Model.php ( 23.55 KB )
  66. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/think-orm/src/model/concern/Attribute.php ( 21.05 KB )
  67. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/think-orm/src/model/concern/AutoWriteData.php ( 4.21 KB )
  68. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/think-orm/src/model/concern/Conversion.php ( 6.44 KB )
  69. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/think-orm/src/model/concern/DbConnect.php ( 5.16 KB )
  70. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/think-orm/src/model/concern/ModelEvent.php ( 2.33 KB )
  71. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/think-orm/src/model/concern/RelationShip.php ( 28.29 KB )
  72. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/think-helper/src/contract/Arrayable.php ( 0.09 KB )
  73. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/think-helper/src/contract/Jsonable.php ( 0.13 KB )
  74. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/think-orm/src/model/contract/Modelable.php ( 0.09 KB )
  75. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/think/Db.php ( 2.88 KB )
  76. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/think-orm/src/DbManager.php ( 8.52 KB )
  77. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/think/Log.php ( 6.28 KB )
  78. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/think/Manager.php ( 3.92 KB )
  79. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/psr/log/src/LoggerTrait.php ( 2.69 KB )
  80. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/psr/log/src/LoggerInterface.php ( 2.71 KB )
  81. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/think/Cache.php ( 4.92 KB )
  82. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/psr/simple-cache/src/CacheInterface.php ( 4.71 KB )
  83. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/think-helper/src/helper/Arr.php ( 16.63 KB )
  84. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/think/cache/driver/File.php ( 7.84 KB )
  85. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/think/cache/Driver.php ( 9.03 KB )
  86. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/think/contract/CacheHandlerInterface.php ( 1.99 KB )
  87. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/app/Request.php ( 0.09 KB )
  88. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/think/Request.php ( 55.78 KB )
  89. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/app/middleware.php ( 0.25 KB )
  90. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/think/Pipeline.php ( 2.61 KB )
  91. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/think-trace/src/TraceDebug.php ( 3.40 KB )
  92. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/think/middleware/SessionInit.php ( 1.94 KB )
  93. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/think/Session.php ( 1.80 KB )
  94. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/think/session/driver/File.php ( 6.27 KB )
  95. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/think/contract/SessionHandlerInterface.php ( 0.87 KB )
  96. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/think/session/Store.php ( 7.12 KB )
  97. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/think/Route.php ( 23.73 KB )
  98. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/think/route/RuleName.php ( 5.75 KB )
  99. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/think/route/Domain.php ( 2.53 KB )
  100. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/think/route/RuleGroup.php ( 22.43 KB )
  101. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/think/route/Rule.php ( 26.95 KB )
  102. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/think/route/RuleItem.php ( 9.78 KB )
  103. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/route/app.php ( 3.94 KB )
  104. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/think/facade/Route.php ( 4.70 KB )
  105. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/think/route/dispatch/Controller.php ( 4.74 KB )
  106. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/think/route/Dispatch.php ( 10.44 KB )
  107. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/app/controller/Index.php ( 9.87 KB )
  108. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/app/BaseController.php ( 2.05 KB )
  109. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/think-orm/src/facade/Db.php ( 0.93 KB )
  110. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/think-orm/src/db/connector/Mysql.php ( 5.44 KB )
  111. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/think-orm/src/db/PDOConnection.php ( 52.47 KB )
  112. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/think-orm/src/db/Connection.php ( 8.39 KB )
  113. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/think-orm/src/db/ConnectionInterface.php ( 4.57 KB )
  114. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/think-orm/src/db/builder/Mysql.php ( 16.58 KB )
  115. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/think-orm/src/db/Builder.php ( 24.06 KB )
  116. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/think-orm/src/db/BaseBuilder.php ( 27.50 KB )
  117. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/think-orm/src/db/Query.php ( 15.71 KB )
  118. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/think-orm/src/db/BaseQuery.php ( 45.13 KB )
  119. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/think-orm/src/db/concern/TimeFieldQuery.php ( 7.43 KB )
  120. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/think-orm/src/db/concern/AggregateQuery.php ( 3.26 KB )
  121. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/think-orm/src/db/concern/ModelRelationQuery.php ( 20.07 KB )
  122. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/think-orm/src/db/concern/ParamsBind.php ( 3.66 KB )
  123. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/think-orm/src/db/concern/ResultOperation.php ( 7.01 KB )
  124. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/think-orm/src/db/concern/WhereQuery.php ( 19.37 KB )
  125. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/think-orm/src/db/concern/JoinAndViewQuery.php ( 7.11 KB )
  126. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/think-orm/src/db/concern/TableFieldInfo.php ( 2.63 KB )
  127. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/think-orm/src/db/concern/Transaction.php ( 2.77 KB )
  128. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/think/log/driver/File.php ( 5.96 KB )
  129. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/think/contract/LogHandlerInterface.php ( 0.86 KB )
  130. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/think/log/Channel.php ( 3.89 KB )
  131. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/think/event/LogRecord.php ( 1.02 KB )
  132. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/think-helper/src/Collection.php ( 16.47 KB )
  133. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/think/facade/View.php ( 1.70 KB )
  134. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/think/View.php ( 4.39 KB )
  135. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/app/controller/Es.php ( 3.30 KB )
  136. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/think/Response.php ( 8.81 KB )
  137. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/think/response/View.php ( 3.29 KB )
  138. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/think/Cookie.php ( 6.06 KB )
  139. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/think-view/src/Think.php ( 8.38 KB )
  140. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/framework/src/think/contract/TemplateHandlerInterface.php ( 1.60 KB )
  141. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/think-template/src/Template.php ( 46.61 KB )
  142. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/think-template/src/template/driver/File.php ( 2.41 KB )
  143. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/think-template/src/template/contract/DriverInterface.php ( 0.86 KB )
  144. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/runtime/temp/c935550e3e8a3a4c27dd94e439343fdf.php ( 31.50 KB )
  145. /yingpanguazai/ssd/ssd1/www/wwww.yeyulingfeng.com/vendor/topthink/think-trace/src/Html.php ( 4.42 KB )
  1. CONNECT:[ UseTime:0.000586s ] mysql:host=127.0.0.1;port=3306;dbname=wenku;charset=utf8mb4
  2. SHOW FULL COLUMNS FROM `fenlei` [ RunTime:0.001044s ]
  3. SELECT * FROM `fenlei` WHERE `fid` = 0 [ RunTime:0.000317s ]
  4. SELECT * FROM `fenlei` WHERE `fid` = 63 [ RunTime:0.000286s ]
  5. SHOW FULL COLUMNS FROM `set` [ RunTime:0.000699s ]
  6. SELECT * FROM `set` [ RunTime:0.000265s ]
  7. SHOW FULL COLUMNS FROM `article` [ RunTime:0.000739s ]
  8. SELECT * FROM `article` WHERE `id` = 805426 LIMIT 1 [ RunTime:0.001046s ]
  9. UPDATE `article` SET `lasttime` = 1782485428 WHERE `id` = 805426 [ RunTime:0.012284s ]
  10. SELECT * FROM `fenlei` WHERE `id` = 64 LIMIT 1 [ RunTime:0.000289s ]
  11. SELECT * FROM `article` WHERE `id` < 805426 ORDER BY `id` DESC LIMIT 1 [ RunTime:0.000743s ]
  12. SELECT * FROM `article` WHERE `id` > 805426 ORDER BY `id` ASC LIMIT 1 [ RunTime:0.000931s ]
  13. SELECT * FROM `article` WHERE `id` < 805426 ORDER BY `id` DESC LIMIT 10 [ RunTime:0.000821s ]
  14. SELECT * FROM `article` WHERE `id` < 805426 ORDER BY `id` DESC LIMIT 10,10 [ RunTime:0.000937s ]
  15. SELECT * FROM `article` WHERE `id` < 805426 ORDER BY `id` DESC LIMIT 20,10 [ RunTime:0.017781s ]
0.130974s