乐于分享
好东西不私藏
夜雨聆风 > > 办公文件 > 源码加更04_MQTT 编解码器和字节工具函数

源码加更04_MQTT 编解码器和字节工具函数

当前时间： 2026-07-08 13:54:05 分类：办公文件 评论(0)
源码加更04_MQTT 编解码器和字节工具函数

源码加更04_MQTT 编解码器和字节工具函数

这一组源码加更只有一个目标：把 MqttBroker 的真实 ST 源码按工程阅读顺序讲完整。不是再补几段“看起来像源码”的片段，而是让读者能沿着源码对象理解这个 Broker 怎么组织、怎么运行、怎么排障。

适合谁收藏

  • 已经读过 MqttBroker 主线教程，想继续看真实源码实现的工程师。
  • 想学习 CodeSys ST 工程如何拆分 Broker、连接池、编解码、路由和 QoS 调度的人。
  • 想把 MQTT Broker 移植到 PLC、边缘控制器或教学工程里的开发者。

先给结论

这一篇把 MQTT 报文解析和构造集中到 Codec 与工具函数里看，重点是从字节流还原协议字段，以及从结构化字段重新构造 ACK/PUBLISH。

MQTT 报文不是字符串拼接。Remaining Length、UTF-8 String、PacketId、QoS 标志位这些字节级边界，一旦错一个，Broker 就会表现成偶发断开或订阅失败。

这篇覆盖 16 个源码文件，合计约 1616 行 ST 代码。为了保持公开教程可读性，正文先讲源码阅读路径，再给完整源码。读代码时建议不要从第一个代码块一路机械读到底，而是按本篇的“读代码顺序”来抓主线。

从工程问题到代码职责

层次
本篇重点
你读源码时要抓住的判断
工程入口
程序如何启动、对象如何被实例化
先确认谁是入口，谁只是被调度的对象
数据边界
容量、状态、错误、缓冲区和表结构
先知道边界，后面排障才不会乱猜
协作关系
各 FB、函数和结构体如何互相传递数据
不按文件夹读，按数据流和状态流读
验证路径
在线观察应该看哪些变量
代码最终要能落到现场排障，而不是只停在源码阅读

本篇源码覆盖表

序号
源码对象
行数
1
FB_MqttBrokerCodec.M_BuildPublish.st
146
2
FB_MqttBrokerCodec.M_BuildSimpleAck.st
277
3
FB_MqttBrokerCodec.M_ParseConnect.st
290
4
FB_MqttBrokerCodec.M_ParsePublish.st
143
5
FB_MqttBrokerCodec.M_ParseSubscribe.st
145
6
FB_MqttBrokerCodec.M_ParseUnsubscribe.st
122
7
FB_MqttBrokerCodec.st
14
8
F_MqttAppendString.st
49
9
F_MqttContainsWildcard.st
34
10
F_MqttDecodeRemainingLength.st
63
11
F_MqttEncodeRemainingLength.st
55
12
F_MqttIsValidTopicFilter.st
76
13
F_MqttIsValidTopicName.st
39
14
F_MqttReadString.st
67
15
F_MqttSkipVariableByteInteger.st
54
16
F_MqttStartsWith.st
42

推荐阅读顺序

  • 先看 FB_MqttBrokerCodec.st 主体职责。
  • 再看 CONNECT/PUBLISH/SUBSCRIBE/UNSUBSCRIBE 解析。
  • 最后看 Remaining Length、String、Topic、QoS 等工具函数。

验证和排障边界

  • 订阅失败、报文断开、PacketId 不匹配时，优先检查本篇对象。
  • 抓包对照固定报头和 Remaining Length，可以最快定位编码边界错误。

本篇完整开源代码

下面代码来自对应 .st 源文件的连续完整内容。为方便公开阅读，只保留源码对象名，不放本机工程路径。

完整代码 01: FB_MqttBrokerCodec.M_BuildPublish.st

/// =======================================================================/// 名称      : M_BuildPublish/// 功能      : 构建 Broker 出站 PUBLISH 报文/// 说明      : 根据路由后的发布帧生成投递给订阅者的 MQTT PUBLISH。/// 编程人员  : ControlRookie/// 时间      : 2026-05-08/// 版本      : V1.0/// ======================================================================={attribute 'hide_all_locals'}METHOD M_BuildPublish : BOOLVAR_INPUT    stPublish     : ST_MqttBrokerPublishFrame; // 待投递给订阅者的发布帧    byProtocolLevel : BYTE; // 目标客户端 MQTT 协议级别，5 表示 PUBLISH 可变头需要追加零属性长度    uiWriteOffset : UINT; // 当前 PUBLISH 帧写入发送缓冲区的起始偏移，批量组包时用于追加到上一帧之后[byte]    udiBufferSize : UDINT; // 发送缓冲区总容量[byte]END_VARVAR_IN_OUT    aBuffer       : ARRAY[*] OF BYTE; // MQTT 发送缓冲区END_VARVAR_OUTPUT    uiFrameLen    : UINT; // 构建出的 PUBLISH 报文长度[byte]END_VARVAR    aRemaining    : ARRAY[0..3] OF BYTE; // Remaining Length 编码临时缓冲区    uiRemainingLen : UINT; // Remaining Length 编码字节数[byte]    udiRemaining  : UDINT; // PUBLISH 剩余长度数值[byte]    udiFrameLen   : UDINT; // 当前 PUBLISH 完整 MQTT 帧长度，用于偏移写入前的总边界检查[byte]    uiOffset      : UINT; // 当前写入偏移[byte]    uiIndex       : UINT; // 字节复制索引[byte]END_VAR// === IMPLEMENTATION ===uiFrameLen := 0;IF NOT stPublish.xValid THEN    M_BuildPublish := FALSE;    RETURN;END_IFIF NOT F_MqttIsValidTopicName(sTopic := stPublish.sTopic) THEN    M_BuildPublish := FALSE;    RETURN;END_IFudiRemaining := 2 + TO_UDINT(stPublish.uiTopicLen) + TO_UDINT(stPublish.uiPayloadLen);IF stPublish.eQoS <> E_MqttQoS.byQoS0 THEN    udiRemaining := udiRemaining + 2;END_IFIF byProtocolLevel = GVL_MqttBroker.cnMqttProtocolLevel5 THEN    // MQTT 5.0 PUBLISH 可变头在 Topic/PacketId 后必须携带 Properties。    // 当前 Broker 不发送任何 5.0 属性，因此属性长度固定编码为 0，占 1 字节。    udiRemaining := udiRemaining + 1;END_IFIF NOT F_MqttEncodeRemainingLength(    aBuffer := aRemaining,    udiValue := udiRemaining,    udiBufferSize := SIZEOF(aRemaining),    uiEncodedLen => uiRemainingLen) THEN    M_BuildPublish := FALSE;    RETURN;END_IFudiFrameLen := 1 + TO_UDINT(uiRemainingLen) + udiRemaining;IF (TO_UDINT(uiWriteOffset) + udiFrameLen) > udiBufferSize THEN    M_BuildPublish := FALSE;    RETURN;END_IFaBuffer[uiWriteOffset] := TO_BYTE(E_MqttPacketType.byPublish);IF stPublish.xDup THEN    aBuffer[uiWriteOffset] := aBuffer[uiWriteOffset] OR 16#08;END_IFCASE stPublish.eQoS OF    E_MqttQoS.byQoS0:        // QoS0 固定头 QoS 位保持 00。    E_MqttQoS.byQoS1:        aBuffer[uiWriteOffset] := aBuffer[uiWriteOffset] OR 16#02;    E_MqttQoS.byQoS2:        aBuffer[uiWriteOffset] := aBuffer[uiWriteOffset] OR 16#04;ELSE    M_BuildPublish := FALSE;    RETURN;END_CASEIF stPublish.xRetain THEN    aBuffer[uiWriteOffset] := aBuffer[uiWriteOffset] OR 16#01;END_IFuiIndex := 0;WHILE uiIndex < uiRemainingLen DO    aBuffer[uiWriteOffset + 1 + uiIndex] := aRemaining[uiIndex];    uiIndex := uiIndex + 1;END_WHILEuiOffset := uiWriteOffset + 1 + uiRemainingLen;IF NOT F_MqttAppendString(    aBuffer := aBuffer,    uiOffset := uiOffset,    sValue := stPublish.sTopic,    udiBufferSize := udiBufferSize) THEN    M_BuildPublish := FALSE;    RETURN;END_IFIF stPublish.eQoS <> E_MqttQoS.byQoS0 THEN    IF (TO_UDINT(uiOffset) + 2) > udiBufferSize THEN        M_BuildPublish := FALSE;        RETURN;    END_IF    aBuffer[uiOffset] := TO_BYTE(stPublish.uiPacketId / 256);    aBuffer[uiOffset + 1] := TO_BYTE(stPublish.uiPacketId MOD 256);    uiOffset := uiOffset + 2;END_IFIF byProtocolLevel = GVL_MqttBroker.cnMqttProtocolLevel5 THEN    IF (TO_UDINT(uiOffset) + 1) > udiBufferSize THEN        M_BuildPublish := FALSE;        RETURN;    END_IF    aBuffer[uiOffset] := 0;    uiOffset := uiOffset + 1;END_IFIF stPublish.uiPayloadLen > 0 THEN    IF (TO_UDINT(uiOffset) + TO_UDINT(stPublish.uiPayloadLen)) > udiBufferSize THEN        M_BuildPublish := FALSE;        RETURN;    END_IF    // Payload 存在 ST STRING 中时按 0 基下标读取。    // 这和 MQTT 报文字节数组 aBuffer[0..] 的下标体系一致，可以避免转发时首字节丢失、尾部多出垃圾字符。    FOR uiIndex := 0 TO stPublish.uiPayloadLen - 1 DO        aBuffer[uiOffset + uiIndex] := stPublish.sPayload[uiIndex];    END_FOR    uiOffset := uiOffset + stPublish.uiPayloadLen;END_IFuiFrameLen := uiOffset - uiWriteOffset;uiLastFrameLen := uiFrameLen;M_BuildPublish := TRUE;

完整代码 02: FB_MqttBrokerCodec.M_BuildSimpleAck.st

/// =======================================================================/// 名称      : M_BuildSimpleAck/// 功能      : 构建固定长度 MQTT 协议响应/// 说明      : 用于 CONNACK、PUBACK、SUBACK、UNSUBACK、PINGRESP 等轻量响应包。/// 编程人员  : ControlRookie/// 时间      : 2026-05-08/// 版本      : V1.0/// ======================================================================={attribute 'hide_all_locals'}METHOD M_BuildSimpleAck : BOOLVAR_INPUT    ePacketType  : E_MqttPacketType; // 需要构建的 MQTT 响应报文类型    byProtocolLevel : BYTE; // 目标客户端 MQTT 协议级别，5 表示响应中需要携带零属性长度    uiPacketId   : UINT; // 需要带 Packet Identifier 的响应使用该值，无需 PacketId 时为 0    byReturnCode : BYTE; // CONNACK/SUBACK 返回码，其他响应通常为 0    uiReturnCount : UINT; // SUBACK 多 Topic 返回码数量，普通响应传 0    uiWriteOffset : UINT; // 当前响应帧写入发送缓冲区的起始偏移，批量组包时用于追加到上一帧之后[byte]    udiBufferSize : UDINT; // 发送缓冲区总容量[byte]END_VARVAR_IN_OUT    aBuffer      : ARRAY[*] OF BYTE; // MQTT 发送缓冲区    aReturnCodes : ARRAY[*] OF BYTE; // SUBACK 多 Topic 返回码数组，普通响应可传空闲数组END_VARVAR_OUTPUT    uiFrameLen   : UINT; // 构建出的 MQTT 响应报文长度[byte]END_VARVAR    uiIndex      : UINT; // SUBACK 多返回码复制索引[1..cnMaxTopicItemsPerPacket]    udiNeededLen : UDINT; // 当前响应帧需要的完整缓冲长度，包含固定头、可变头和返回码[byte]END_VAR// === IMPLEMENTATION ===uiFrameLen := 0;CASE ePacketType OF    E_MqttPacketType.byConnAck:        IF byProtocolLevel = GVL_MqttBroker.cnMqttProtocolLevel5 THEN            udiNeededLen := 5;        ELSE            udiNeededLen := 4;        END_IF        IF (TO_UDINT(uiWriteOffset) + udiNeededLen) > udiBufferSize THEN            M_BuildSimpleAck := FALSE;            RETURN;        END_IF        aBuffer[uiWriteOffset] := TO_BYTE(E_MqttPacketType.byConnAck);        aBuffer[uiWriteOffset + 2] := 0;        aBuffer[uiWriteOffset + 3] := byReturnCode;        IF byProtocolLevel = GVL_MqttBroker.cnMqttProtocolLevel5 THEN            // MQTT 5.0 CONNACK = Acknowledge Flags + Reason Code + Properties。            // 当前轻量兼容层不返回任何属性，因此属性长度固定写 0。            aBuffer[uiWriteOffset + 1] := 3;            aBuffer[uiWriteOffset + 4] := 0;            uiFrameLen := 5;        ELSE            aBuffer[uiWriteOffset + 1] := 2;            uiFrameLen := 4;        END_IF    E_MqttPacketType.byPubAck:        IF byProtocolLevel = GVL_MqttBroker.cnMqttProtocolLevel5 THEN            udiNeededLen := 6;        ELSE            udiNeededLen := 4;        END_IF        IF (TO_UDINT(uiWriteOffset) + udiNeededLen) > udiBufferSize THEN            M_BuildSimpleAck := FALSE;            RETURN;        END_IF        aBuffer[uiWriteOffset] := TO_BYTE(E_MqttPacketType.byPubAck);        IF byProtocolLevel = GVL_MqttBroker.cnMqttProtocolLevel5 THEN            aBuffer[uiWriteOffset + 1] := 4;        ELSE            aBuffer[uiWriteOffset + 1] := 2;        END_IF        aBuffer[uiWriteOffset + 2] := TO_BYTE(uiPacketId / 256);        aBuffer[uiWriteOffset + 3] := TO_BYTE(uiPacketId MOD 256);        IF byProtocolLevel = GVL_MqttBroker.cnMqttProtocolLevel5 THEN            // MQTT 5.0 UNSUBACK = Packet Identifier + Properties + Reason Codes。            // 当前 M_EnqueueProtocolAck 只生成单返回码，属性长度固定写 0。            aBuffer[uiWriteOffset + 4] := 0;            aBuffer[uiWriteOffset + 5] := byReturnCode;            uiFrameLen := 6;        ELSE            uiFrameLen := 4;        END_IF    E_MqttPacketType.byPubRec:        IF byProtocolLevel = GVL_MqttBroker.cnMqttProtocolLevel5 THEN            udiNeededLen := 6;        ELSE            udiNeededLen := 4;        END_IF        IF (TO_UDINT(uiWriteOffset) + udiNeededLen) > udiBufferSize THEN            M_BuildSimpleAck := FALSE;            RETURN;        END_IF        aBuffer[uiWriteOffset] := TO_BYTE(E_MqttPacketType.byPubRec);        IF byProtocolLevel = GVL_MqttBroker.cnMqttProtocolLevel5 THEN            aBuffer[uiWriteOffset + 1] := 4;        ELSE            aBuffer[uiWriteOffset + 1] := 2;        END_IF        aBuffer[uiWriteOffset + 2] := TO_BYTE(uiPacketId / 256);        aBuffer[uiWriteOffset + 3] := TO_BYTE(uiPacketId MOD 256);        IF byProtocolLevel = GVL_MqttBroker.cnMqttProtocolLevel5 THEN            aBuffer[uiWriteOffset + 4] := byReturnCode;            aBuffer[uiWriteOffset + 5] := 0;            uiFrameLen := 6;        ELSE            uiFrameLen := 4;        END_IF    E_MqttPacketType.byPubRel:        IF byProtocolLevel = GVL_MqttBroker.cnMqttProtocolLevel5 THEN            udiNeededLen := 6;        ELSE            udiNeededLen := 4;        END_IF        IF (TO_UDINT(uiWriteOffset) + udiNeededLen) > udiBufferSize THEN            M_BuildSimpleAck := FALSE;            RETURN;        END_IF        aBuffer[uiWriteOffset] := TO_BYTE(E_MqttPacketType.byPubRel);        IF byProtocolLevel = GVL_MqttBroker.cnMqttProtocolLevel5 THEN            aBuffer[uiWriteOffset + 1] := 4;        ELSE            aBuffer[uiWriteOffset + 1] := 2;        END_IF        aBuffer[uiWriteOffset + 2] := TO_BYTE(uiPacketId / 256);        aBuffer[uiWriteOffset + 3] := TO_BYTE(uiPacketId MOD 256);        IF byProtocolLevel = GVL_MqttBroker.cnMqttProtocolLevel5 THEN            aBuffer[uiWriteOffset + 4] := byReturnCode;            aBuffer[uiWriteOffset + 5] := 0;            uiFrameLen := 6;        ELSE            uiFrameLen := 4;        END_IF    E_MqttPacketType.byPubComp:        IF byProtocolLevel = GVL_MqttBroker.cnMqttProtocolLevel5 THEN            udiNeededLen := 6;        ELSE            udiNeededLen := 4;        END_IF        IF (TO_UDINT(uiWriteOffset) + udiNeededLen) > udiBufferSize THEN            M_BuildSimpleAck := FALSE;            RETURN;        END_IF        aBuffer[uiWriteOffset] := TO_BYTE(E_MqttPacketType.byPubComp);        IF byProtocolLevel = GVL_MqttBroker.cnMqttProtocolLevel5 THEN            aBuffer[uiWriteOffset + 1] := 4;        ELSE            aBuffer[uiWriteOffset + 1] := 2;        END_IF        aBuffer[uiWriteOffset + 2] := TO_BYTE(uiPacketId / 256);        aBuffer[uiWriteOffset + 3] := TO_BYTE(uiPacketId MOD 256);        IF byProtocolLevel = GVL_MqttBroker.cnMqttProtocolLevel5 THEN            aBuffer[uiWriteOffset + 4] := byReturnCode;            aBuffer[uiWriteOffset + 5] := 0;            uiFrameLen := 6;        ELSE            uiFrameLen := 4;        END_IF    E_MqttPacketType.bySubAck:        IF uiReturnCount = 0 THEN            IF byProtocolLevel = GVL_MqttBroker.cnMqttProtocolLevel5 THEN                udiNeededLen := 6;            ELSE                udiNeededLen := 5;            END_IF        ELSE            IF byProtocolLevel = GVL_MqttBroker.cnMqttProtocolLevel5 THEN                udiNeededLen := 5 + TO_UDINT(uiReturnCount);            ELSE                udiNeededLen := 4 + TO_UDINT(uiReturnCount);            END_IF        END_IF        IF (TO_UDINT(uiWriteOffset) + udiNeededLen) > udiBufferSize THEN            M_BuildSimpleAck := FALSE;            RETURN;        END_IF        aBuffer[uiWriteOffset] := TO_BYTE(E_MqttPacketType.bySubAck);        IF uiReturnCount = 0 THEN            IF byProtocolLevel = GVL_MqttBroker.cnMqttProtocolLevel5 THEN                aBuffer[uiWriteOffset + 1] := 4;            ELSE                aBuffer[uiWriteOffset + 1] := 3;            END_IF        ELSE            IF byProtocolLevel = GVL_MqttBroker.cnMqttProtocolLevel5 THEN                aBuffer[uiWriteOffset + 1] := TO_BYTE(3 + uiReturnCount);            ELSE                aBuffer[uiWriteOffset + 1] := TO_BYTE(2 + uiReturnCount);            END_IF        END_IF        aBuffer[uiWriteOffset + 2] := TO_BYTE(uiPacketId / 256);        aBuffer[uiWriteOffset + 3] := TO_BYTE(uiPacketId MOD 256);        IF byProtocolLevel = GVL_MqttBroker.cnMqttProtocolLevel5 THEN            aBuffer[uiWriteOffset + 4] := 0;            IF uiReturnCount = 0 THEN                aBuffer[uiWriteOffset + 5] := byReturnCode;                uiFrameLen := 6;            ELSE                FOR uiIndex := 1 TO uiReturnCount DO                    IF uiIndex > GVL_MqttBroker.cnMaxTopicItemsPerPacket THEN                        M_BuildSimpleAck := FALSE;                        RETURN;                    END_IF                    aBuffer[uiWriteOffset + 4 + uiIndex] := aReturnCodes[uiIndex];                END_FOR                uiFrameLen := 5 + uiReturnCount;            END_IF        ELSE            IF uiReturnCount = 0 THEN                aBuffer[uiWriteOffset + 4] := byReturnCode;                uiFrameLen := 5;            ELSE                FOR uiIndex := 1 TO uiReturnCount DO                    IF uiIndex > GVL_MqttBroker.cnMaxTopicItemsPerPacket THEN                        M_BuildSimpleAck := FALSE;                        RETURN;                    END_IF                    aBuffer[uiWriteOffset + 3 + uiIndex] := aReturnCodes[uiIndex];                END_FOR                uiFrameLen := 4 + uiReturnCount;            END_IF        END_IF    E_MqttPacketType.byUnsubAck:        IF byProtocolLevel = GVL_MqttBroker.cnMqttProtocolLevel5 THEN            udiNeededLen := 6;        ELSE            udiNeededLen := 4;        END_IF        IF (TO_UDINT(uiWriteOffset) + udiNeededLen) > udiBufferSize THEN            M_BuildSimpleAck := FALSE;            RETURN;        END_IF        aBuffer[uiWriteOffset] := TO_BYTE(E_MqttPacketType.byUnsubAck);        IF byProtocolLevel = GVL_MqttBroker.cnMqttProtocolLevel5 THEN            aBuffer[uiWriteOffset + 1] := 4;        ELSE            aBuffer[uiWriteOffset + 1] := 2;        END_IF        aBuffer[uiWriteOffset + 2] := TO_BYTE(uiPacketId / 256);        aBuffer[uiWriteOffset + 3] := TO_BYTE(uiPacketId MOD 256);        IF byProtocolLevel = GVL_MqttBroker.cnMqttProtocolLevel5 THEN            aBuffer[uiWriteOffset + 4] := byReturnCode;            aBuffer[uiWriteOffset + 5] := 0;            uiFrameLen := 6;        ELSE            uiFrameLen := 4;        END_IF    E_MqttPacketType.byPingResp:        IF (TO_UDINT(uiWriteOffset) + 2) > udiBufferSize THEN            M_BuildSimpleAck := FALSE;            RETURN;        END_IF        aBuffer[uiWriteOffset] := TO_BYTE(E_MqttPacketType.byPingResp);        aBuffer[uiWriteOffset + 1] := 0;        uiFrameLen := 2;ELSE    M_BuildSimpleAck := FALSE;    RETURN;END_CASEuiLastFrameLen := uiFrameLen;M_BuildSimpleAck := TRUE;

完整代码 03: FB_MqttBrokerCodec.M_ParseConnect.st

/// =======================================================================/// 名称      : M_ParseConnect/// 功能      : 解析 MQTT CONNECT 报文/// 说明      : 校验 MQTT 3.1 / 3.1.1 / 5.0 协议名、协议级别、ClientID，并解析 Clean Session 与 Will。/// 编程人员  : ControlRookie/// 时间      : 2026-05-08/// 版本      : V1.0/// ======================================================================={attribute 'hide_all_locals'}METHOD M_ParseConnect : BOOLVAR_INPUT    uiBodyOffset : UINT; // CONNECT 可变头在报文缓冲区中的起始偏移[byte]    uiFrameLen   : UINT; // 当前 CONNECT 完整报文长度[byte]END_VARVAR_IN_OUT    aBuffer      : ARRAY[*] OF BYTE; // MQTT 原始报文缓冲区    stConnection : ST_MqttBrokerConnection; // 当前连接槽位，会被写入 ClientID、KeepAlive 和 Will 信息END_VARVAR_OUTPUT    eError       : E_MqttBrokerError; // 解析失败时返回的 Broker 错误码END_VARVAR    uiOffset       : UINT; // 当前解析偏移[byte]    uiProtocolLen  : UINT; // 协议名字段长度[byte]    uiClientIdLen  : UINT; // ClientID 字段长度[byte]    uiWillTopicLen : UINT; // Will Topic 字段长度[byte]    uiWillMsgLen   : UINT; // Will Payload 字段长度[byte]    uiUsernameLen  : UINT; // 用户名字段长度[byte]    uiPasswordLen  : UINT; // 密码字段长度[byte]    udiPropertyLen : UDINT; // MQTT 5.0 CONNECT 属性区长度，当前轻量兼容模式只校验并跳过[byte]    byFlags        : BYTE; // CONNECT Flags 字节，包含用户名、密码、Will、Clean Session 标志    byProtocolLevel : BYTE; // CONNECT 中声明的 MQTT 协议级别，3 表示 3.1，4 表示 3.1.1，5 表示 5.0    byWillQoS      : BYTE; // 从 CONNECT Flags 中提取的 Will QoS 数值    sTempString    : STRING; // CONNECT 用户名/密码临时缓冲，再按目标字段容量赋值END_VAR// === IMPLEMENTATION ===eError := E_MqttBrokerError.uiNoError;uiOffset := uiBodyOffset;IF uiFrameLen < 14 THEN    eError := E_MqttBrokerError.uiProtocolMalformed;    M_ParseConnect := FALSE;    RETURN;END_IFIF (uiOffset + 1) >= uiFrameLen THEN    eError := E_MqttBrokerError.uiProtocolMalformed;    M_ParseConnect := FALSE;    RETURN;END_IFuiProtocolLen := TO_UINT(aBuffer[uiOffset]) * 256 + TO_UINT(aBuffer[uiOffset + 1]);CASE uiProtocolLen OF    4:        IF (uiOffset + 5) >= uiFrameLen THEN            eError := E_MqttBrokerError.uiProtocolMalformed;            M_ParseConnect := FALSE;            RETURN;        END_IF        IF (aBuffer[uiOffset + 2] <> 16#4D)            OR (aBuffer[uiOffset + 3] <> 16#51)            OR (aBuffer[uiOffset + 4] <> 16#54)            OR (aBuffer[uiOffset + 5] <> 16#54) THEN            eError := E_MqttBrokerError.uiUnsupportedProtocol;            M_ParseConnect := FALSE;            RETURN;        END_IF        uiOffset := uiOffset + 6;    6:        IF (uiOffset + 7) >= uiFrameLen THEN            eError := E_MqttBrokerError.uiProtocolMalformed;            M_ParseConnect := FALSE;            RETURN;        END_IF        // MQTT 3.1 老客户端使用协议名 MQIsdp，协议级别为 3。        // 此处单独分支处理，避免把 3.1.1/5.0 的标准 MQTT 协议名校验放宽。        IF (aBuffer[uiOffset + 2] <> 16#4D)            OR (aBuffer[uiOffset + 3] <> 16#51)            OR (aBuffer[uiOffset + 4] <> 16#49)            OR (aBuffer[uiOffset + 5] <> 16#73)            OR (aBuffer[uiOffset + 6] <> 16#64)            OR (aBuffer[uiOffset + 7] <> 16#70) THEN            eError := E_MqttBrokerError.uiUnsupportedProtocol;            M_ParseConnect := FALSE;            RETURN;        END_IF        uiOffset := uiOffset + 8;ELSE    eError := E_MqttBrokerError.uiUnsupportedProtocol;    M_ParseConnect := FALSE;    RETURN;END_CASEIF uiOffset >= uiFrameLen THEN    eError := E_MqttBrokerError.uiProtocolMalformed;    M_ParseConnect := FALSE;    RETURN;END_IFbyProtocolLevel := aBuffer[uiOffset];IF ((uiProtocolLen = 4)    AND (byProtocolLevel <> GVL_MqttBroker.cnMqttProtocolLevel311)    AND (byProtocolLevel <> GVL_MqttBroker.cnMqttProtocolLevel5))    OR ((uiProtocolLen = 6)    AND (byProtocolLevel <> GVL_MqttBroker.cnMqttProtocolLevel31)) THEN    eError := E_MqttBrokerError.uiUnsupportedProtocol;    M_ParseConnect := FALSE;    RETURN;END_IFstConnection.byProtocolLevel := byProtocolLevel;uiOffset := uiOffset + 1;IF uiOffset >= uiFrameLen THEN    eError := E_MqttBrokerError.uiProtocolMalformed;    M_ParseConnect := FALSE;    RETURN;END_IFbyFlags := aBuffer[uiOffset];uiOffset := uiOffset + 1;IF (byFlags AND 16#01) <> 0 THEN    eError := E_MqttBrokerError.uiProtocolMalformed;    M_ParseConnect := FALSE;    RETURN;END_IFIF (uiOffset + 1) >= uiFrameLen THEN    eError := E_MqttBrokerError.uiProtocolMalformed;    M_ParseConnect := FALSE;    RETURN;END_IFstConnection.uiKeepAlive := TO_UINT(aBuffer[uiOffset]) * 256 + TO_UINT(aBuffer[uiOffset + 1]);IF stConnection.uiKeepAlive = 0 THEN    stConnection.uiKeepAlive := GVL_MqttBroker.cnDefaultKeepAlive;END_IFuiOffset := uiOffset + 2;IF stConnection.byProtocolLevel = GVL_MqttBroker.cnMqttProtocolLevel5 THEN    // MQTT 5.0 在 KeepAlive 后增加 CONNECT Properties。    // 当前 Broker 定位为工业轻量兼容，不解释 User Property / Session Expiry 等高级属性，    // 但必须严格跳过属性长度字段，避免后续 ClientID 解析错位导致 5.0 客户端无法连接。    IF NOT F_MqttSkipVariableByteInteger(        aBuffer := aBuffer,        uiOffset := uiOffset,        uiBufferLen := uiFrameLen,        udiValue => udiPropertyLen) THEN        eError := E_MqttBrokerError.uiProtocolMalformed;        M_ParseConnect := FALSE;        RETURN;    END_IF    IF (TO_UDINT(uiOffset) + udiPropertyLen) > TO_UDINT(uiFrameLen) THEN        eError := E_MqttBrokerError.uiProtocolMalformed;        M_ParseConnect := FALSE;        RETURN;    END_IF    uiOffset := uiOffset + TO_UINT(udiPropertyLen);END_IFIF NOT F_MqttReadString(    aBuffer := aBuffer,    uiOffset := uiOffset,    sValue := stConnection.sClientId,    uiBufferLen := uiFrameLen,    uiMaxLen := GVL_MqttBroker.cnMaxClientIdLen,    uiStringLen => uiClientIdLen) THEN    eError := E_MqttBrokerError.uiInvalidClientId;    M_ParseConnect := FALSE;    RETURN;END_IFIF uiClientIdLen = 0 THEN    eError := E_MqttBrokerError.uiInvalidClientId;    M_ParseConnect := FALSE;    RETURN;END_IFstConnection.xCleanSession := (byFlags AND 16#02) <> 0;stConnection.xWillFlag := (byFlags AND 16#04) <> 0;stConnection.xWillRetain := (byFlags AND 16#20) <> 0;stConnection.sUsername := '';stConnection.sPassword := '';stConnection.xAuthenticated := FALSE;byWillQoS := SHR(byFlags AND 16#18, 3);CASE byWillQoS OF    0:        stConnection.eWillQoS := E_MqttQoS.byQoS0;    1:        stConnection.eWillQoS := E_MqttQoS.byQoS1;    2:        stConnection.eWillQoS := E_MqttQoS.byQoS2;ELSE    eError := E_MqttBrokerError.uiProtocolMalformed;    M_ParseConnect := FALSE;    RETURN;END_CASEIF stConnection.xWillFlag THEN    IF stConnection.byProtocolLevel = GVL_MqttBroker.cnMqttProtocolLevel5 THEN        // MQTT 5.0 Will Properties 位于 Will Topic 之前。        // 当前只支持 Will Topic/Payload/QoS/Retain 主链路，属性区做长度校验后跳过。        IF NOT F_MqttSkipVariableByteInteger(            aBuffer := aBuffer,            uiOffset := uiOffset,            uiBufferLen := uiFrameLen,            udiValue => udiPropertyLen) THEN            eError := E_MqttBrokerError.uiProtocolMalformed;            M_ParseConnect := FALSE;            RETURN;        END_IF        IF (TO_UDINT(uiOffset) + udiPropertyLen) > TO_UDINT(uiFrameLen) THEN            eError := E_MqttBrokerError.uiProtocolMalformed;            M_ParseConnect := FALSE;            RETURN;        END_IF        uiOffset := uiOffset + TO_UINT(udiPropertyLen);    END_IF    IF NOT F_MqttReadString(        aBuffer := aBuffer,        uiOffset := uiOffset,        sValue := stConnection.sWillTopic,        uiBufferLen := uiFrameLen,        uiMaxLen := GVL_MqttBroker.cnMaxTopicLen,        uiStringLen => uiWillTopicLen) THEN        eError := E_MqttBrokerError.uiInvalidTopic;        M_ParseConnect := FALSE;        RETURN;    END_IF    IF NOT F_MqttIsValidTopicName(sTopic := stConnection.sWillTopic) THEN        eError := E_MqttBrokerError.uiInvalidTopic;        M_ParseConnect := FALSE;        RETURN;    END_IF    IF NOT F_MqttReadString(        aBuffer := aBuffer,        uiOffset := uiOffset,        sValue := stConnection.sWillPayload,        uiBufferLen := uiFrameLen,        uiMaxLen := GVL_MqttBroker.cnMaxPayloadLen,        uiStringLen => uiWillMsgLen) THEN        eError := E_MqttBrokerError.uiProtocolMalformed;        M_ParseConnect := FALSE;        RETURN;    END_IFEND_IFIF (byFlags AND 16#80) <> 0 THEN    IF NOT F_MqttReadString(        aBuffer := aBuffer,        uiOffset := uiOffset,        sValue := sTempString,        uiBufferLen := uiFrameLen,        uiMaxLen := GVL_MqttBroker.cnMaxUsernameLen,        uiStringLen => uiUsernameLen) THEN        eError := E_MqttBrokerError.uiProtocolMalformed;        M_ParseConnect := FALSE;        RETURN;    END_IF    stConnection.sUsername := sTempString;END_IFIF (byFlags AND 16#40) <> 0 THEN    IF NOT F_MqttReadString(        aBuffer := aBuffer,        uiOffset := uiOffset,        sValue := sTempString,        uiBufferLen := uiFrameLen,        uiMaxLen := GVL_MqttBroker.cnMaxPasswordLen,        uiStringLen => uiPasswordLen) THEN        eError := E_MqttBrokerError.uiProtocolMalformed;        M_ParseConnect := FALSE;        RETURN;    END_IF    stConnection.sPassword := sTempString;END_IFuiLastFrameLen := uiFrameLen;M_ParseConnect := TRUE;

完整代码 04: FB_MqttBrokerCodec.M_ParsePublish.st

/// =======================================================================/// 名称      : M_ParsePublish/// 功能      : 解析 MQTT PUBLISH 报文/// 说明      : 提取 Topic、Payload、QoS、Retain、DUP 和 PacketId，供路由层使用。/// 编程人员  : ControlRookie/// 时间      : 2026-05-08/// 版本      : V1.0/// ======================================================================={attribute 'hide_all_locals'}METHOD M_ParsePublish : BOOLVAR_INPUT    uiSourceSlot : UINT; // 发布来源客户端槽位编号[1..cnMaxClientSlots]    byProtocolLevel : BYTE; // 当前连接协商的 MQTT 协议级别，5 表示需要跳过 PUBLISH Properties    uiBodyOffset : UINT; // PUBLISH 可变头起始偏移[byte]    uiFrameLen   : UINT; // 当前 PUBLISH 完整报文长度[byte]END_VARVAR_IN_OUT    aBuffer      : ARRAY[*] OF BYTE; // MQTT 原始报文缓冲区    stPublish    : ST_MqttBrokerPublishFrame; // 解析后的标准发布帧END_VARVAR_OUTPUT    eError       : E_MqttBrokerError; // 解析失败时返回的 Broker 错误码END_VARVAR    uiOffset     : UINT; // 当前解析偏移[byte]    uiTopicLen   : UINT; // Topic Name 字段长度[byte]    uiPayloadIdx : UINT; // Payload 字节复制索引[byte]    udiPropertyLen : UDINT; // MQTT 5.0 PUBLISH 属性区长度，当前轻量兼容模式只校验并跳过[byte]    byQoS        : BYTE; // 固定头中解析出的 QoS 数值END_VAR// === IMPLEMENTATION ===eError := E_MqttBrokerError.uiNoError;stPublish.xValid := FALSE;stPublish.uiSourceSlot := uiSourceSlot;stPublish.uiTargetSlot := 0;stPublish.uiPacketId := 0;stPublish.sTopic := '';stPublish.sPayload := '';uiOffset := uiBodyOffset;IF uiFrameLen <= uiBodyOffset THEN    eError := E_MqttBrokerError.uiProtocolMalformed;    M_ParsePublish := FALSE;    RETURN;END_IFstPublish.xDup := (aBuffer[0] AND 16#08) <> 0;stPublish.xRetain := (aBuffer[0] AND 16#01) <> 0;byQoS := SHR(aBuffer[0] AND 16#06, 1);CASE byQoS OF    0:        stPublish.eQoS := E_MqttQoS.byQoS0;    1:        stPublish.eQoS := E_MqttQoS.byQoS1;    2:        stPublish.eQoS := E_MqttQoS.byQoS2;ELSE    eError := E_MqttBrokerError.uiProtocolMalformed;    M_ParsePublish := FALSE;    RETURN;END_CASEIF NOT F_MqttReadString(    aBuffer := aBuffer,    uiOffset := uiOffset,    sValue := stPublish.sTopic,    uiBufferLen := uiFrameLen,    uiMaxLen := GVL_MqttBroker.cnMaxTopicLen,    uiStringLen => uiTopicLen) THEN    eError := E_MqttBrokerError.uiInvalidTopic;    M_ParsePublish := FALSE;    RETURN;END_IFIF NOT F_MqttIsValidTopicName(sTopic := stPublish.sTopic) THEN    eError := E_MqttBrokerError.uiInvalidTopic;    M_ParsePublish := FALSE;    RETURN;END_IFstPublish.uiTopicLen := uiTopicLen;IF stPublish.eQoS <> E_MqttQoS.byQoS0 THEN    IF (uiOffset + 1) >= uiFrameLen THEN        eError := E_MqttBrokerError.uiProtocolMalformed;        M_ParsePublish := FALSE;        RETURN;    END_IF    stPublish.uiPacketId := TO_UINT(aBuffer[uiOffset]) * 256 + TO_UINT(aBuffer[uiOffset + 1]);    uiOffset := uiOffset + 2;    IF stPublish.uiPacketId = 0 THEN        eError := E_MqttBrokerError.uiProtocolMalformed;        M_ParsePublish := FALSE;        RETURN;    END_IFEND_IFIF byProtocolLevel = GVL_MqttBroker.cnMqttProtocolLevel5 THEN    // MQTT 5.0 在 PUBLISH 可变头末尾增加 Properties。    // 当前 Broker 不实现 Topic Alias、Payload Format 等 5.0 高级属性，    // 但必须跳过属性区，否则 Payload 会被错误地带上属性长度字节。    IF NOT F_MqttSkipVariableByteInteger(        aBuffer := aBuffer,        uiOffset := uiOffset,        uiBufferLen := uiFrameLen,        udiValue => udiPropertyLen) THEN        eError := E_MqttBrokerError.uiProtocolMalformed;        M_ParsePublish := FALSE;        RETURN;    END_IF    IF (TO_UDINT(uiOffset) + udiPropertyLen) > TO_UDINT(uiFrameLen) THEN        eError := E_MqttBrokerError.uiProtocolMalformed;        M_ParsePublish := FALSE;        RETURN;    END_IF    uiOffset := uiOffset + TO_UINT(udiPropertyLen);END_IFstPublish.uiPayloadLen := uiFrameLen - uiOffset;IF stPublish.uiPayloadLen > GVL_MqttBroker.cnMaxPayloadLen THEN    eError := E_MqttBrokerError.uiPacketTooLarge;    M_ParsePublish := FALSE;    RETURN;END_IFIF stPublish.uiPayloadLen > 0 THEN    // CodeSys/CODESYS 的 STRING 字符访问按 0 基下标工作。    // 这里保存 Payload 时必须与 F_MqttReadString/F_MqttAppendString 保持一致；    // 否则应用层字符串会整体错位，后续转发给订阅客户端时可能构造出非法 PUBLISH。    FOR uiPayloadIdx := 0 TO stPublish.uiPayloadLen - 1 DO        stPublish.sPayload[uiPayloadIdx] := aBuffer[uiOffset + uiPayloadIdx];    END_FOR    stPublish.sPayload[stPublish.uiPayloadLen] := 0;END_IFstPublish.xValid := TRUE;uiLastFrameLen := uiFrameLen;M_ParsePublish := TRUE;

完整代码 05: FB_MqttBrokerCodec.M_ParseSubscribe.st

/// =======================================================================/// 名称      : M_ParseSubscribe/// 功能      : 解析 MQTT SUBSCRIBE 报文/// 说明      : 第二阶段支持单个 SUBSCRIBE 报文内多个 Topic Filter，并逐项输出返回码。/// 编程人员  : ControlRookie/// 时间      : 2026-05-08/// 版本      : V1.0/// ======================================================================={attribute 'hide_all_locals'}METHOD M_ParseSubscribe : BOOLVAR_INPUT    byProtocolLevel : BYTE; // 当前连接协商的 MQTT 协议级别，5 表示需要跳过 SUBSCRIBE Properties    uiBodyOffset : UINT; // SUBSCRIBE 可变头起始偏移[byte]    uiFrameLen   : UINT; // 当前 SUBSCRIBE 完整报文长度[byte]END_VARVAR_IN_OUT    aBuffer      : ARRAY[*] OF BYTE; // MQTT 原始报文缓冲区    aTopicItems  : ARRAY[*] OF ST_MqttBrokerTopicItem; // 解析出的多 Topic 订阅条目数组END_VARVAR_OUTPUT    uiPacketId   : UINT; // SUBSCRIBE Packet Identifier    uiItemCount  : UINT; // 本次 SUBSCRIBE 成功解析出的 Topic 条目数量    eError       : E_MqttBrokerError; // 解析失败时返回的 Broker 错误码END_VARVAR    uiOffset     : UINT; // 当前解析偏移[byte]    uiFilterLen  : UINT; // Topic Filter 字段长度[byte]    uiIndex      : UINT; // Topic 条目数组写入索引[1..cnMaxTopicItemsPerPacket]    udiPropertyLen : UDINT; // MQTT 5.0 SUBSCRIBE 属性区长度，当前轻量兼容模式只校验并跳过[byte]    byQoS        : BYTE; // SUBSCRIBE 载荷中请求的 QoS 数值END_VAR// === IMPLEMENTATION ===eError := E_MqttBrokerError.uiNoError;uiPacketId := 0;uiItemCount := 0;uiOffset := uiBodyOffset;FOR uiIndex := 1 TO GVL_MqttBroker.cnMaxTopicItemsPerPacket DO    aTopicItems[uiIndex].xUsed := FALSE;    aTopicItems[uiIndex].sTopicFilter := '';    aTopicItems[uiIndex].uiFilterLen := 0;    aTopicItems[uiIndex].eQoS := E_MqttQoS.byQoS0;    aTopicItems[uiIndex].byReturnCode := 16#80;END_FORIF (uiOffset + 1) >= uiFrameLen THEN    eError := E_MqttBrokerError.uiProtocolMalformed;    M_ParseSubscribe := FALSE;    RETURN;END_IFuiPacketId := TO_UINT(aBuffer[uiOffset]) * 256 + TO_UINT(aBuffer[uiOffset + 1]);uiOffset := uiOffset + 2;IF uiPacketId = 0 THEN    eError := E_MqttBrokerError.uiProtocolMalformed;    M_ParseSubscribe := FALSE;    RETURN;END_IFIF byProtocolLevel = GVL_MqttBroker.cnMqttProtocolLevel5 THEN    // MQTT 5.0 在 SUBSCRIBE Packet Identifier 后增加 Properties。    // 当前轻量 Broker 不解释 Subscription Identifier / User Property 等高级属性，    // 只跳过属性区，让后续 Topic Filter 列表按正确偏移解析。    IF NOT F_MqttSkipVariableByteInteger(        aBuffer := aBuffer,        uiOffset := uiOffset,        uiBufferLen := uiFrameLen,        udiValue => udiPropertyLen) THEN        eError := E_MqttBrokerError.uiProtocolMalformed;        M_ParseSubscribe := FALSE;        RETURN;    END_IF    IF (TO_UDINT(uiOffset) + udiPropertyLen) > TO_UDINT(uiFrameLen) THEN        eError := E_MqttBrokerError.uiProtocolMalformed;        M_ParseSubscribe := FALSE;        RETURN;    END_IF    uiOffset := uiOffset + TO_UINT(udiPropertyLen);END_IFWHILE uiOffset < uiFrameLen DO    IF uiItemCount >= GVL_MqttBroker.cnMaxTopicItemsPerPacket THEN        eError := E_MqttBrokerError.uiPacketTooLarge;        M_ParseSubscribe := FALSE;        RETURN;    END_IF    uiIndex := uiItemCount + 1;    IF NOT F_MqttReadString(        aBuffer := aBuffer,        uiOffset := uiOffset,        sValue := aTopicItems[uiIndex].sTopicFilter,        uiBufferLen := uiFrameLen,        uiMaxLen := GVL_MqttBroker.cnMaxTopicLen,        uiStringLen => uiFilterLen) THEN        eError := E_MqttBrokerError.uiInvalidTopic;        M_ParseSubscribe := FALSE;        RETURN;    END_IF    IF uiOffset >= uiFrameLen THEN        eError := E_MqttBrokerError.uiProtocolMalformed;        M_ParseSubscribe := FALSE;        RETURN;    END_IF    byQoS := aBuffer[uiOffset];    uiOffset := uiOffset + 1;    CASE byQoS OF        0:            aTopicItems[uiIndex].eQoS := E_MqttQoS.byQoS0;        1:            aTopicItems[uiIndex].eQoS := E_MqttQoS.byQoS1;        2:            aTopicItems[uiIndex].eQoS := E_MqttQoS.byQoS2;    ELSE        eError := E_MqttBrokerError.uiUnsupportedQoS;        M_ParseSubscribe := FALSE;        RETURN;    END_CASE    IF NOT F_MqttIsValidTopicFilter(sFilter := aTopicItems[uiIndex].sTopicFilter) THEN        eError := E_MqttBrokerError.uiInvalidTopic;        M_ParseSubscribe := FALSE;        RETURN;    END_IF    aTopicItems[uiIndex].xUsed := TRUE;    aTopicItems[uiIndex].uiFilterLen := uiFilterLen;    aTopicItems[uiIndex].byReturnCode := TO_BYTE(aTopicItems[uiIndex].eQoS);    uiItemCount := uiItemCount + 1;END_WHILEIF uiItemCount = 0 THEN    eError := E_MqttBrokerError.uiProtocolMalformed;    M_ParseSubscribe := FALSE;    RETURN;END_IFM_ParseSubscribe := TRUE;

完整代码 06: FB_MqttBrokerCodec.M_ParseUnsubscribe.st

/// =======================================================================/// 名称      : M_ParseUnsubscribe/// 功能      : 解析 MQTT UNSUBSCRIBE 报文/// 说明      : 第二阶段支持单个 UNSUBSCRIBE 报文内多个 Topic Filter。/// 编程人员  : ControlRookie/// 时间      : 2026-05-08/// 版本      : V1.0/// ======================================================================={attribute 'hide_all_locals'}METHOD M_ParseUnsubscribe : BOOLVAR_INPUT    byProtocolLevel : BYTE; // 当前连接协商的 MQTT 协议级别，5 表示需要跳过 UNSUBSCRIBE Properties    uiBodyOffset : UINT; // UNSUBSCRIBE 可变头起始偏移[byte]    uiFrameLen   : UINT; // 当前 UNSUBSCRIBE 完整报文长度[byte]END_VARVAR_IN_OUT    aBuffer      : ARRAY[*] OF BYTE; // MQTT 原始报文缓冲区    aTopicItems  : ARRAY[*] OF ST_MqttBrokerTopicItem; // 解析出的多 Topic 取消订阅条目数组END_VARVAR_OUTPUT    uiPacketId   : UINT; // UNSUBSCRIBE Packet Identifier    uiItemCount  : UINT; // 本次 UNSUBSCRIBE 成功解析出的 Topic 条目数量    eError       : E_MqttBrokerError; // 解析失败时返回的 Broker 错误码END_VARVAR    uiOffset     : UINT; // 当前解析偏移[byte]    uiFilterLen  : UINT; // Topic Filter 字段长度[byte]    uiIndex      : UINT; // Topic 条目数组写入索引[1..cnMaxTopicItemsPerPacket]    udiPropertyLen : UDINT; // MQTT 5.0 UNSUBSCRIBE 属性区长度，当前轻量兼容模式只校验并跳过[byte]END_VAR// === IMPLEMENTATION ===eError := E_MqttBrokerError.uiNoError;uiPacketId := 0;uiItemCount := 0;uiOffset := uiBodyOffset;FOR uiIndex := 1 TO GVL_MqttBroker.cnMaxTopicItemsPerPacket DO    aTopicItems[uiIndex].xUsed := FALSE;    aTopicItems[uiIndex].sTopicFilter := '';    aTopicItems[uiIndex].uiFilterLen := 0;    aTopicItems[uiIndex].eQoS := E_MqttQoS.byQoS0;    aTopicItems[uiIndex].byReturnCode := 0;END_FORIF (uiOffset + 1) >= uiFrameLen THEN    eError := E_MqttBrokerError.uiProtocolMalformed;    M_ParseUnsubscribe := FALSE;    RETURN;END_IFuiPacketId := TO_UINT(aBuffer[uiOffset]) * 256 + TO_UINT(aBuffer[uiOffset + 1]);uiOffset := uiOffset + 2;IF uiPacketId = 0 THEN    eError := E_MqttBrokerError.uiProtocolMalformed;    M_ParseUnsubscribe := FALSE;    RETURN;END_IFIF byProtocolLevel = GVL_MqttBroker.cnMqttProtocolLevel5 THEN    // MQTT 5.0 在 UNSUBSCRIBE Packet Identifier 后增加 Properties。    // 当前只支持 Topic Filter 主链路，属性区做长度校验后跳过。    IF NOT F_MqttSkipVariableByteInteger(        aBuffer := aBuffer,        uiOffset := uiOffset,        uiBufferLen := uiFrameLen,        udiValue => udiPropertyLen) THEN        eError := E_MqttBrokerError.uiProtocolMalformed;        M_ParseUnsubscribe := FALSE;        RETURN;    END_IF    IF (TO_UDINT(uiOffset) + udiPropertyLen) > TO_UDINT(uiFrameLen) THEN        eError := E_MqttBrokerError.uiProtocolMalformed;        M_ParseUnsubscribe := FALSE;        RETURN;    END_IF    uiOffset := uiOffset + TO_UINT(udiPropertyLen);END_IFWHILE uiOffset < uiFrameLen DO    IF uiItemCount >= GVL_MqttBroker.cnMaxTopicItemsPerPacket THEN        eError := E_MqttBrokerError.uiPacketTooLarge;        M_ParseUnsubscribe := FALSE;        RETURN;    END_IF    uiIndex := uiItemCount + 1;    IF NOT F_MqttReadString(        aBuffer := aBuffer,        uiOffset := uiOffset,        sValue := aTopicItems[uiIndex].sTopicFilter,        uiBufferLen := uiFrameLen,        uiMaxLen := GVL_MqttBroker.cnMaxTopicLen,        uiStringLen => uiFilterLen) THEN        eError := E_MqttBrokerError.uiInvalidTopic;        M_ParseUnsubscribe := FALSE;        RETURN;    END_IF    IF NOT F_MqttIsValidTopicFilter(sFilter := aTopicItems[uiIndex].sTopicFilter) THEN        eError := E_MqttBrokerError.uiInvalidTopic;        M_ParseUnsubscribe := FALSE;        RETURN;    END_IF    aTopicItems[uiIndex].xUsed := TRUE;    aTopicItems[uiIndex].uiFilterLen := uiFilterLen;    aTopicItems[uiIndex].eQoS := E_MqttQoS.byQoS0;    aTopicItems[uiIndex].byReturnCode := 0;    uiItemCount := uiItemCount + 1;END_WHILEIF uiItemCount = 0 THEN    eError := E_MqttBrokerError.uiProtocolMalformed;    M_ParseUnsubscribe := FALSE;    RETURN;END_IFM_ParseUnsubscribe := TRUE;

完整代码 07: FB_MqttBrokerCodec.st

/// =======================================================================/// 名称      : FB_MqttBrokerCodec/// 功能      : MQTT Broker 报文编解码器/// 说明      : 本功能块不保存业务状态，只通过方法解析入站报文和构建服务端回包。/// 编程人员  : ControlRookie/// 时间      : 2026-05-08/// 版本      : V1.0/// ======================================================================={attribute 'hide_all_locals'}FUNCTION_BLOCK FB_MqttBrokerCodecVAR    uiLastFrameLen : UINT; // 最近一次成功构建或解析的 MQTT 报文长度[byte]END_VAR// === IMPLEMENTATION ===

完整代码 08: F_MqttAppendString.st

/// =======================================================================/// 名称      : F_MqttAppendString/// 功能      : 向 MQTT 报文缓冲区追加 UTF-8 字符串字段/// 说明      : MQTT 字符串格式为 2 字节大端长度 + 字符串内容，本函数负责边界保护。/// 编程人员  : ControlRookie/// 时间      : 2026-05-08/// 版本      : V1.0/// ======================================================================={attribute 'hide_all_locals'}FUNCTION F_MqttAppendString : BOOLVAR_INPUT    sValue        : STRING; // 需要追加到 MQTT 报文中的字符串内容    udiBufferSize : UDINT; // 调用方报文缓冲区总容量[byte]END_VARVAR_IN_OUT    aBuffer       : ARRAY[*] OF BYTE; // 调用方报文缓冲区    uiOffset      : UINT; // 当前写入偏移，成功后推进到字符串末尾后一字节[byte]END_VARVAR    uiLen         : UINT; // 字符串长度[byte]    uiIndex       : UINT; // 字符串字符复制索引，CODESYS STRING 字符下标从 0 开始[byte]    uiWriteIndex  : UINT; // 当前写入报文缓冲区索引[byte]END_VAR// === IMPLEMENTATION ===uiLen := TO_UINT(LEN(sValue));IF (TO_UDINT(uiOffset) + 2 + TO_UDINT(uiLen)) > udiBufferSize THEN    F_MqttAppendString := FALSE;    RETURN;END_IFaBuffer[uiOffset] := TO_BYTE(uiLen / 256);aBuffer[uiOffset + 1] := TO_BYTE(uiLen MOD 256);uiOffset := uiOffset + 2;IF uiLen > 0 THEN    FOR uiIndex := 0 TO uiLen - 1 DO        uiWriteIndex := uiOffset + uiIndex;        IF TO_UDINT(uiWriteIndex) >= udiBufferSize THEN            F_MqttAppendString := FALSE;            RETURN;        END_IF        aBuffer[uiWriteIndex] := TO_BYTE(sValue[uiIndex]);    END_FOREND_IFuiOffset := uiOffset + uiLen;F_MqttAppendString := TRUE;

完整代码 09: F_MqttContainsWildcard.st

/// =======================================================================/// 名称      : F_MqttContainsWildcard/// 功能      : 判断 Topic Filter 是否包含 MQTT 通配符/// 说明      : 供 ACL 判断是否允许 + 或 # 通配符订阅。/// 编程人员  : ControlRookie/// 时间      : 2026-05-08/// 版本      : V1.0/// ======================================================================={attribute 'hide_all_locals'}FUNCTION F_MqttContainsWildcard : BOOLVAR_INPUT    sTopicFilter : STRING; // 需要检查的 Topic FilterEND_VARVAR    uiLen   : UINT; // Topic Filter 长度[byte]    uiIndex : UINT; // 字符逐字节扫描索引[byte]END_VAR// === IMPLEMENTATION ===uiLen := TO_UINT(LEN(sTopicFilter));IF uiLen = 0 THEN    F_MqttContainsWildcard := FALSE;    RETURN;END_IFFOR uiIndex := 0 TO uiLen - 1 DO    IF (sTopicFilter[uiIndex] = 16#2B) OR (sTopicFilter[uiIndex] = 16#23) THEN        F_MqttContainsWildcard := TRUE;        RETURN;    END_IFEND_FORF_MqttContainsWildcard := FALSE;

完整代码 10: F_MqttDecodeRemainingLength.st

/// =======================================================================/// 名称      : F_MqttDecodeRemainingLength/// 功能      : 解码 MQTT Remaining Length/// 说明      : 从固定报头第 2 字节开始解析 MQTT 变长整数，最多读取 4 字节。/// 编程人员  : ControlRookie/// 时间      : 2026-05-08/// 版本      : V1.0/// ======================================================================={attribute 'hide_all_locals'}FUNCTION F_MqttDecodeRemainingLength : BOOLVAR_INPUT    uiStartIndex : UINT; // Remaining Length 在缓冲区中的起始索引，通常为 1[byte]    uiBufferLen  : UINT; // 当前缓冲区内有效数据长度[byte]END_VARVAR_IN_OUT    aBuffer      : ARRAY[*] OF BYTE; // MQTT 原始接收缓冲区END_VARVAR_OUTPUT    udiValue     : UDINT; // 解码后的 Remaining Length 数值[byte]    uiBytesUsed  : UINT; // Remaining Length 字段实际占用的字节数[byte]    xNeedMore    : BOOL; // 数据不足时置 TRUE，上层应继续读取 TCP 数据END_VARVAR    udiMultiplier : UDINT; // MQTT 变长整数倍率，依次为 1、128、16384、2097152    byEncoded     : BYTE; // 当前读取的编码字节    uiIndex       : UINT; // 当前读取缓冲区索引[byte]    uiLoop        : UINT; // 变长整数最多 4 字节的循环计数END_VAR// === IMPLEMENTATION ===udiValue := 0;uiBytesUsed := 0;xNeedMore := FALSE;udiMultiplier := 1;uiIndex := uiStartIndex;IF uiStartIndex >= uiBufferLen THEN    xNeedMore := TRUE;    F_MqttDecodeRemainingLength := FALSE;    RETURN;END_IFFOR uiLoop := 1 TO 4 DO    IF uiIndex >= uiBufferLen THEN        xNeedMore := TRUE;        F_MqttDecodeRemainingLength := FALSE;        RETURN;    END_IF    byEncoded := aBuffer[uiIndex];    udiValue := udiValue + TO_UDINT(byEncoded AND 16#7F) * udiMultiplier;    uiBytesUsed := uiBytesUsed + 1;    IF (byEncoded AND 16#80) = 0 THEN        F_MqttDecodeRemainingLength := TRUE;        RETURN;    END_IF    udiMultiplier := udiMultiplier * 128;    uiIndex := uiIndex + 1;END_FORF_MqttDecodeRemainingLength := FALSE;

完整代码 11: F_MqttEncodeRemainingLength.st

/// =======================================================================/// 名称      : F_MqttEncodeRemainingLength/// 功能      : 编码 MQTT Remaining Length/// 说明      : 把 MQTT 剩余长度编码为 1~4 字节变长整数，并写入调用方提供的缓冲区。/// 编程人员  : ControlRookie/// 时间      : 2026-05-08/// 版本      : V1.0/// ======================================================================={attribute 'hide_all_locals'}FUNCTION F_MqttEncodeRemainingLength : BOOLVAR_INPUT    udiValue     : UDINT; // 需要编码的 MQTT Remaining Length 数值[byte]    udiBufferSize : UDINT; // 调用方输出缓冲区容量[byte]END_VARVAR_IN_OUT    aBuffer      : ARRAY[*] OF BYTE; // 调用方输出缓冲区，函数从索引 0 起写入编码结果END_VARVAR_OUTPUT    uiEncodedLen : UINT; // 实际编码产生的字节数[byte]END_VARVAR    udiWorkValue : UDINT; // 编码过程中逐步除以 128 的临时值    byEncoded    : BYTE; // 当前轮生成的 7 位数据和 continuation 标志    uiIndex      : UINT; // 当前写入缓冲区的索引[byte]END_VAR// === IMPLEMENTATION ===uiEncodedLen := 0;udiWorkValue := udiValue;IF udiValue > GVL_MqttBroker.cnMqttRemainingLengthMax THEN    F_MqttEncodeRemainingLength := FALSE;    RETURN;END_IFREPEAT    IF TO_UDINT(uiIndex) >= udiBufferSize THEN        F_MqttEncodeRemainingLength := FALSE;        RETURN;    END_IF    byEncoded := TO_BYTE(udiWorkValue MOD 128);    udiWorkValue := udiWorkValue / 128;    IF udiWorkValue > 0 THEN        byEncoded := byEncoded OR 16#80;    END_IF    aBuffer[uiIndex] := byEncoded;    uiIndex := uiIndex + 1;UNTIL udiWorkValue = 0END_REPEATuiEncodedLen := uiIndex;F_MqttEncodeRemainingLength := TRUE;

完整代码 12: F_MqttIsValidTopicFilter.st

/// =======================================================================/// 名称      : F_MqttIsValidTopicFilter/// 功能      : 校验 MQTT Topic Filter/// 说明      : SUBSCRIBE 使用的过滤器允许 + / #，但必须满足 MQTT 通配符位置规则。/// 编程人员  : ControlRookie/// 时间      : 2026-05-08/// 版本      : V1.0/// ======================================================================={attribute 'hide_all_locals'}FUNCTION F_MqttIsValidTopicFilter : BOOLVAR_INPUT    sFilter : STRING; // 待校验的 MQTT Topic FilterEND_VARVAR    uiLen      : UINT; // Topic Filter 长度[byte]    uiIndex    : UINT; // 当前检查的字符位置，CODESYS STRING 字符下标从 0 开始[byte]    byPrev     : BYTE; // 当前字符前一个字符，用于判断通配符是否独占层级    byNext     : BYTE; // 当前字符后一个字符，用于判断通配符是否独占层级END_VAR// === IMPLEMENTATION ===uiLen := TO_UINT(LEN(sFilter));IF uiLen = 0 THEN    F_MqttIsValidTopicFilter := FALSE;    RETURN;END_IFIF uiLen > GVL_MqttBroker.cnMaxTopicLen THEN    F_MqttIsValidTopicFilter := FALSE;    RETURN;END_IFFOR uiIndex := 0 TO uiLen - 1 DO    IF uiIndex > 0 THEN        byPrev := sFilter[uiIndex - 1];    ELSE        byPrev := 0;    END_IF    IF uiIndex < (uiLen - 1) THEN        byNext := sFilter[uiIndex + 1];    ELSE        byNext := 0;    END_IF    CASE sFilter[uiIndex] OF        16#23:            // # 必须是最后一个字符，并且要么单独出现，要么前面是层级分隔符 /。            IF uiIndex <> (uiLen - 1) THEN                F_MqttIsValidTopicFilter := FALSE;                RETURN;            END_IF            IF (uiIndex > 0) AND (byPrev <> 16#2F) THEN                F_MqttIsValidTopicFilter := FALSE;                RETURN;            END_IF        16#2B:            // + 必须独占一个层级，左右只能是边界或层级分隔符 /。            IF (uiIndex > 0) AND (byPrev <> 16#2F) THEN                F_MqttIsValidTopicFilter := FALSE;                RETURN;            END_IF            IF (uiIndex < (uiLen - 1)) AND (byNext <> 16#2F) THEN                F_MqttIsValidTopicFilter := FALSE;                RETURN;            END_IF    ELSE        // 普通字符不需要额外限制；UTF-8 合法性由上位系统或客户端侧保证。    END_CASEEND_FORF_MqttIsValidTopicFilter := TRUE;

完整代码 13: F_MqttIsValidTopicName.st

/// =======================================================================/// 名称      : F_MqttIsValidTopicName/// 功能      : 校验 MQTT Topic Name/// 说明      : PUBLISH 使用的 Topic Name 不能为空，且不能包含 + / # 通配符。/// 编程人员  : ControlRookie/// 时间      : 2026-05-08/// 版本      : V1.0/// ======================================================================={attribute 'hide_all_locals'}FUNCTION F_MqttIsValidTopicName : BOOLVAR_INPUT    sTopic : STRING; // 待校验的 MQTT Topic NameEND_VARVAR    uiLen   : UINT; // Topic Name 长度[byte]    uiIndex : UINT; // 当前检查的字符位置，CODESYS STRING 字符下标从 0 开始[byte]END_VAR// === IMPLEMENTATION ===uiLen := TO_UINT(LEN(sTopic));IF uiLen = 0 THEN    F_MqttIsValidTopicName := FALSE;    RETURN;END_IFIF uiLen > GVL_MqttBroker.cnMaxTopicLen THEN    F_MqttIsValidTopicName := FALSE;    RETURN;END_IFFOR uiIndex := 0 TO uiLen - 1 DO    IF (sTopic[uiIndex] = 16#2B) OR (sTopic[uiIndex] = 16#23) THEN        F_MqttIsValidTopicName := FALSE;        RETURN;    END_IFEND_FORF_MqttIsValidTopicName := TRUE;

完整代码 14: F_MqttReadString.st

/// =======================================================================/// 名称      : F_MqttReadString/// 功能      : 从 MQTT 报文缓冲区读取 UTF-8 字符串字段/// 说明      : 读取 2 字节大端长度和后续内容，并推进调用方偏移。/// 注意      : CodeSys/CODESYS STRING 字符下标按 0 基访问，不能按 1 基复制。/// 编程人员  : ControlRookie/// 时间      : 2026-05-08/// 版本      : V1.0/// ======================================================================={attribute 'hide_all_locals'}FUNCTION F_MqttReadString : BOOLVAR_INPUT    uiBufferLen : UINT; // 当前 MQTT 报文有效长度[byte]    uiMaxLen    : UINT; // 输出字符串允许保存的最大长度[byte]END_VARVAR_IN_OUT    aBuffer     : ARRAY[*] OF BYTE; // MQTT 原始报文缓冲区    uiOffset    : UINT; // 当前读取偏移，成功后推进到字符串末尾后一字节[byte]    sValue      : STRING; // 读取出的字符串内容，短字段由调用方使用默认长度临时缓冲转接END_VARVAR_OUTPUT    uiStringLen : UINT; // MQTT 字符串字段声明的原始长度[byte]END_VARVAR    uiIndex     : UINT; // 字符串字符复制索引，CODESYS STRING 字符下标从 0 开始[byte]    uiReadIndex : UINT; // 当前读取报文缓冲区索引[byte]END_VAR// === IMPLEMENTATION ===sValue := '';uiStringLen := 0;IF (uiOffset + 1) >= uiBufferLen THEN    F_MqttReadString := FALSE;    RETURN;END_IFuiStringLen := TO_UINT(aBuffer[uiOffset]) * 256 + TO_UINT(aBuffer[uiOffset + 1]);uiOffset := uiOffset + 2;IF uiStringLen > uiMaxLen THEN    F_MqttReadString := FALSE;    RETURN;END_IFIF (TO_UDINT(uiOffset) + TO_UDINT(uiStringLen)) > TO_UDINT(uiBufferLen) THEN    F_MqttReadString := FALSE;    RETURN;END_IFIF uiStringLen > 0 THEN    // 关键坑位：    // MQTT 报文缓冲区本身是 ARRAY[0..]，CodeSys/CODESYS 的 STRING 字符访问同样按 0 基下标工作。    // 曾经按 1 基写入会导致 CONNECT 协议名、SUBSCRIBE Topic Filter、PUBLISH Topic/Payload 全部错位。    FOR uiIndex := 0 TO uiStringLen - 1 DO        uiReadIndex := uiOffset + uiIndex;        IF uiReadIndex >= uiBufferLen THEN            F_MqttReadString := FALSE;            RETURN;        END_IF        sValue[uiIndex] := aBuffer[uiReadIndex];    END_FOR    sValue[uiStringLen] := 0;END_IFuiOffset := uiOffset + uiStringLen;F_MqttReadString := TRUE;

完整代码 15: F_MqttSkipVariableByteInteger.st

/// =======================================================================/// 名称      : F_MqttSkipVariableByteInteger/// 功能      : 跳过 MQTT 变长整数编码字段/// 说明      : MQTT 5.0 属性长度采用变长整数编码，当前轻量兼容层只需要校验并跳过该长度字段。/// 编程人员  : ControlRookie/// 时间      : 2026-05-08/// 版本      : V1.0/// ======================================================================={attribute 'hide_all_locals'}FUNCTION F_MqttSkipVariableByteInteger : BOOLVAR_INPUT    uiBufferLen  : UINT; // 当前 MQTT 完整报文长度或可用缓冲长度[byte]END_VARVAR_IN_OUT    aBuffer      : ARRAY[*] OF BYTE; // MQTT 原始报文缓冲区    uiOffset     : UINT; // 输入为变长整数起始偏移，成功后推进到变长整数之后[byte]END_VARVAR_OUTPUT    udiValue     : UDINT; // 解码出的变长整数数值，MQTT 5.0 属性长度使用该值[byte]END_VARVAR    udiMultiplier : UDINT; // MQTT 变长整数倍率，依次为 1、128、16384、2097152    byEncoded     : BYTE; // 当前读取的编码字节    uiLoop        : UINT; // 变长整数最多允许 4 个字节END_VAR// === IMPLEMENTATION ===udiValue := 0;udiMultiplier := 1;IF uiOffset >= uiBufferLen THEN    F_MqttSkipVariableByteInteger := FALSE;    RETURN;END_IFFOR uiLoop := 1 TO 4 DO    IF uiOffset >= uiBufferLen THEN        F_MqttSkipVariableByteInteger := FALSE;        RETURN;    END_IF    byEncoded := aBuffer[uiOffset];    udiValue := udiValue + TO_UDINT(byEncoded AND 16#7F) * udiMultiplier;    uiOffset := uiOffset + 1;    IF (byEncoded AND 16#80) = 0 THEN        F_MqttSkipVariableByteInteger := TRUE;        RETURN;    END_IF    udiMultiplier := udiMultiplier * 128;END_FORF_MqttSkipVariableByteInteger := FALSE;

完整代码 16: F_MqttStartsWith.st

/// =======================================================================/// 名称      : F_MqttStartsWith/// 功能      : 判断字符串是否以指定前缀开头/// 说明      : 避免依赖目标 IDE 的 LEFT 字符串库差异，供轻量 ACL 使用。/// 编程人员  : ControlRookie/// 时间      : 2026-05-08/// 版本      : V1.0/// ======================================================================={attribute 'hide_all_locals'}FUNCTION F_MqttStartsWith : BOOLVAR_INPUT    sValue  : STRING; // 需要检查的完整字符串    sPrefix : STRING; // 期望匹配的前缀，空前缀表示全部匹配END_VARVAR    uiValueLen  : UINT; // 完整字符串长度[byte]    uiPrefixLen : UINT; // 前缀字符串长度[byte]    uiIndex     : UINT; // 字符逐字节比较索引，CODESYS STRING 字符下标从 0 开始[byte]END_VAR// === IMPLEMENTATION ===uiValueLen := TO_UINT(LEN(sValue));uiPrefixLen := TO_UINT(LEN(sPrefix));IF uiPrefixLen = 0 THEN    F_MqttStartsWith := TRUE;    RETURN;END_IFIF uiValueLen < uiPrefixLen THEN    F_MqttStartsWith := FALSE;    RETURN;END_IFFOR uiIndex := 0 TO uiPrefixLen - 1 DO    IF sValue[uiIndex] <> sPrefix[uiIndex] THEN        F_MqttStartsWith := FALSE;        RETURN;    END_IFEND_FORF_MqttStartsWith := TRUE;

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

  • Broker 源码不要按“文件夹顺序”读，要按“入口、状态、数据、报文、路由、事务”读。
  • CodeSys ST 工程最容易失控的不是语法，而是对象职责边界混乱。
  • 只要你能把本篇源码对象和在线变量对应起来，后续排查连接、订阅、发布和 QoS 问题就不会乱。

系列导航

  • 第 1 篇：源码加更01_Broker 工程入口、容量边界和数据模型
  • 第 2 篇：源码加更02_FB_MqttBroker 顶层调度、连接池和权限边界
  • 第 3 篇：源码加更03_单连接槽位、TCP 字节流和发送队列
  • 第 4 篇：源码加更04_MQTT 编解码器和字节工具函数
  • 第 5 篇：源码加更05_订阅表、Retain、PUBLISH 路由和业务事件
  • 第 6 篇：源码加更06_QoS 事务调度、重试和生产级闭环
基本 文件 流程 错误 SQL 调试
  1. 请求信息 : 2026-07-23 13:41:55 HTTP/1.1 GET : https://www.yeyulingfeng.com/a/836075.html
  2. 运行时间 : 0.227575s [ 吞吐率：4.39req/s ] 内存消耗：4,953.13kb 文件加载：145
  3. 缓存信息 : 0 reads,0 writes
  4. 会话信息 : SESSION_ID=f9fa755c437e6c896be54d31c4cd8055
  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.000880s ] mysql:host=127.0.0.1;port=3306;dbname=wenku;charset=utf8mb4
  2. SHOW FULL COLUMNS FROM `fenlei` [ RunTime:0.001689s ]
  3. SELECT * FROM `fenlei` WHERE `fid` = 0 [ RunTime:0.000744s ]
  4. SELECT * FROM `fenlei` WHERE `fid` = 63 [ RunTime:0.001326s ]
  5. SHOW FULL COLUMNS FROM `set` [ RunTime:0.001821s ]
  6. SELECT * FROM `set` [ RunTime:0.028450s ]
  7. SHOW FULL COLUMNS FROM `article` [ RunTime:0.000987s ]
  8. SELECT * FROM `article` WHERE `id` = 836075 LIMIT 1 [ RunTime:0.000936s ]
  9. UPDATE `article` SET `lasttime` = 1784785315 WHERE `id` = 836075 [ RunTime:0.000969s ]
  10. SELECT * FROM `fenlei` WHERE `id` = 64 LIMIT 1 [ RunTime:0.000337s ]
  11. SELECT * FROM `article` WHERE `id` < 836075 ORDER BY `id` DESC LIMIT 1 [ RunTime:0.000569s ]
  12. SELECT * FROM `article` WHERE `id` > 836075 ORDER BY `id` ASC LIMIT 1 [ RunTime:0.000518s ]
  13. SELECT * FROM `article` WHERE `id` < 836075 ORDER BY `id` DESC LIMIT 10 [ RunTime:0.005774s ]
  14. SELECT * FROM `article` WHERE `id` < 836075 ORDER BY `id` DESC LIMIT 10,10 [ RunTime:0.002328s ]
  15. SELECT * FROM `article` WHERE `id` < 836075 ORDER BY `id` DESC LIMIT 20,10 [ RunTime:0.003079s ]
0.231899s