/// =======================================================================/// 名称      : M_TcpClient/// 功能      : 控制 TCP 客户端的连接与断开/// 说明      : 封装 NBS TCP 客户端连接调用，输出连接状态与错误信息。/// 编程人员  : ControlRookie/// 时间      : 2026-01-10/// 版本      : V1.1/// ======================================================================={attribute 'hide_all_locals'}METHOD M_TcpClientVAR_INPUT    bEnable                : BOOL;           // TCP 连接使能标志    sIP                    : STRING;         // 服务器 IP 地址    uiPortNum              : UINT;           // 目标 Broker 提供 MQTT 服务的监听端口号END_VARVAR_OUTPUT    bIsConnected           : BOOL;           // 连接成功标志    bError                 : BOOL;           // 错误标志    eError                 : NBS.ERROR;      // NBS 错误码END_VARVAR    stIP                   : NBS.IP_ADDR;    // 服务器地址结构END_VAR// === IMPLEMENTATION ===// 把字符串地址先转成 NBS 需要的地址结构，再交给底层 TCP_Client。stIP.sAddr := sIP;fbTcpClient(    xEnable     := bEnable,    ipAddr      := stIP,    uiPort      := uiPortNum,    eError      => eError,    hConnection => hConnection);// 统一把底层错误状态透传到上层状态机。bError := fbTcpClient.xError;// 只有底层已经 active 且句柄有效时，才认为 TCP 连接真正建立成功。IF fbTcpClient.xActive AND fbTcpClient.hConnection <> 0 THEN    bIsConnected := TRUE;ELSE    bIsConnected := FALSE;END_IF

/// =======================================================================/// 名称      : M_TcpRead/// 功能      : 从 TCP 连接读取数据到接收缓冲区/// 说明      : 封装 NBS.TCP_Read，读取成功后输出完成标志和实际字节数。/// 编程人员  : ControlRookie/// 时间      : 2026-05-05/// 版本      : V1.2/// ======================================================================={attribute 'hide_all_locals'}METHOD M_TcpReadVAR_INPUT    bEnable        : BOOL;            // TCP 读取使能标志    pDataReceive   : POINTER TO BYTE; // 接收数据区首地址    udiDataSize    : UDINT;           // 本次允许写入接收缓冲区的最大字节数[byte]END_VARVAR_OUTPUT    bDone          : BOOL;            // 读取完成标志    bError         : BOOL;            // 错误标志    eError         : NBS.ERROR;       // NBS 错误码    udiBytesRead   : UDINT;           // 本次实际从 TCP 连接读取的字节数[byte]END_VAR// === IMPLEMENTATION ===// 每周期持续调用底层 TCP_Read，是否真的读由 bEnable 控制。fbTcpRead(    xEnable      := bEnable,    xError       => bError,    hConnection  := hConnection,    szSize       := udiDataSize,    pData        := pDataReceive,    eError       => eError);// 只有底层声明 ready 且无错误时，才把本次读取结果上报给上层状态机。IF fbTcpRead.xReady AND NOT fbTcpRead.xError THEN    bDone := TRUE;    udiBytesRead := TO_UDINT(fbTcpRead.szCount);ELSE    bDone := FALSE;    udiBytesRead := 0;END_IF// 关闭读取使能时，显式把完成标志和本次字节数清零，避免上层误判复用旧结果。IF NOT bEnable THEN    bDone := FALSE;    udiBytesRead := 0;END_IF

/// =======================================================================/// 名称      : M_TcpWrite/// 功能      : 向 TCP 连接发送缓冲区数据/// 说明      : 包装 NBS.TCP_Write，发送成功后置位完成标志。/// 编程人员  : ControlRookie/// 时间      : 2026-05-05/// 版本      : V1.1/// ======================================================================={attribute 'hide_all_locals'}METHOD M_TcpWriteVAR_INPUT    bExecute               : BOOL;              // TCP 写入执行标志    pDataSend              : POINTER TO BYTE;   // 发送数据区首地址    udiDataSize            : UDINT;             // 本次计划发送的字节数[byte]END_VARVAR_OUTPUT    bDone                  : BOOL;              // 发送完成标志    bError                 : BOOL;              // 错误标志    eError                 : NBS.ERROR;         // NBS 错误码END_VAR// === IMPLEMENTATION ===// 每周期持续调用底层 TCP_Write，是否真正触发发送由 bExecute 控制。fbTcpWrite(    xExecute     := bExecute,    xError       => bError,    hConnection  := hConnection,    szSize       := udiDataSize,    pData        := pDataSend,    eError       => eError);// 发送脉冲撤销时立即清掉完成锁存，确保下一次发送重新形成独立 done 事件。IF NOT bExecute THEN    bWriteDoneLatched := FALSE;ELSIF fbTcpWrite.xError THEN    bWriteDoneLatched := FALSE;ELSIF fbTcpWrite.xDone THEN    // xDone 只要出现一次就锁存住，交给上层状态机在下一拍读取。    bWriteDoneLatched := TRUE;END_IFbDone := bWriteDoneLatched;

/// =======================================================================/// 名称      : FB_EncodeRemainingLength/// 功能      : 编码 MQTT 剩余长度字段/// 说明      : 将载荷长度编码为 MQTT 可变字节整数格式/// 编程人员  : ControlRookie/// 时间      : 2026-01-10/// 版本      : V1.1/// ======================================================================={attribute 'hide_all_locals'}FUNCTION_BLOCK FB_EncodeRemainingLengthVAR_INPUT    uiNumberOfBytes           : UINT;                  // 待写入报文头的 MQTT 剩余长度[byte]END_VARVAR_OUTPUT    iEncodedBytesCount        : INT;                   // MQTT 剩余长度编码结果的字节数[byte]    aEncodedBytes             : ARRAY[0..3] OF BYTE;  // MQTT 剩余长度编码结果缓冲区[byte]END_VARVAR    byEncodedByte             : BYTE;                  // 当前编码字节    uiTemp                    : UINT;                  // 中间长度变量    bContinue                 : BOOL;                  // 是否继续编码下一个字节END_VAR// === IMPLEMENTATION ===// Remaining Length 采用 MQTT 可变字节整数编码：// 每个字节低 7 位承载数值，最高位表示“后面还有没有后续字节”。uiTemp := uiNumberOfBytes;iEncodedBytesCount := 0;REPEAT    byEncodedByte := TO_BYTE(uiTemp MOD 128);    uiTemp := uiTemp / 128;    // 只要后面还有剩余数值，就把续位标志位置 1。    IF uiTemp > 0 THEN        byEncodedByte := byEncodedByte OR 16#80;        bContinue := TRUE;    ELSE        bContinue := FALSE;    END_IF;    aEncodedBytes[iEncodedBytesCount] := byEncodedByte;    iEncodedBytesCount := iEncodedBytesCount + 1;    // MQTT 标准规定 Remaining Length 最多只允许编码成 4 个字节。    IF iEncodedBytesCount >= 4 THEN        bContinue := FALSE;    END_IF;UNTIL (NOT bContinue)END_REPEAT;

/// =======================================================================/// 名称      : FB_DecodeRemainingLength/// 功能      : 解码 MQTT 剩余长度字段/// 说明      : 将 MQTT 可变字节整数格式解码为实际长度值/// 编程人员  : ControlRookie/// 时间      : 2026-01-10/// 版本      : V1.1/// ======================================================================={attribute 'hide_all_locals'}FUNCTION_BLOCK FB_DecodeRemainingLengthVAR_INPUT    pEncodedBytes             : POINTER TO BYTE;       // 指向 MQTT Remaining Length 编码起始字节的缓冲区指针END_VARVAR_OUTPUT    uiDecodedLength           : UINT;                  // 解码得到的 MQTT 剩余长度[byte]    uiBytesUsed               : UINT;                  // 解码该长度字段实际消耗的字节数[byte]    bDone                     : BOOL;                  // 解码是否成功END_VARVAR    uiMultiplier              : UINT := 1;            // 可变字节整数权重    uiValue                   : UINT := 0;            // 解码中间值    byByte                    : BYTE;                 // 当前读取字节    pCurrent                  : POINTER TO BYTE;      // 当前读取指针    uiCount                   : UINT := 0;            // 当前已读取的编码字节数[byte]END_VAR// === IMPLEMENTATION ===// Remaining Length 采用 MQTT 的可变字节整数编码，最多 4 个字节。// 这里逐字节累乘 128 权重，把编码值还原成真实长度。pCurrent := pEncodedBytes;bDone := FALSE;uiCount := 0;WHILE uiCount < 4 DO    IF uiCount = 0 THEN        uiValue := 0;        uiMultiplier := 1;    END_IF    // 低 7 位是本字节贡献的值，最高位是“后面是否还有字节”的续位标志。    byByte := pCurrent^;    uiValue := uiValue + (BYTE_TO_UINT(byByte AND 16#7F) * uiMultiplier);    uiMultiplier := uiMultiplier * 128;    uiCount := uiCount + 1;    IF (byByte AND 16#80) = 0 THEN        bDone := TRUE;        EXIT;    END_IF;    pCurrent := pCurrent + 1;END_WHILE;IF bDone THEN    uiDecodedLength := uiValue;    uiBytesUsed := uiCount;ELSE    // 超过 4 字节仍未结束时视为非法编码，输出清零并报失败。    uiDecodedLength := 0;    uiBytesUsed := 0;END_IF;

/// =======================================================================/// 名称      : M_EncodeRemainingLength/// 功能      : 编码 MQTT 剩余长度字段/// 说明      : 将剩余长度按 MQTT 可变长度格式写入缓冲区并返回字节数。/// 编程人员  : ControlRookie/// 时间      : 2026-05-05/// 版本      : V1.0/// ======================================================================={attribute 'hide_all_locals'}METHOD M_EncodeRemainingLength : UINTVAR_INPUT    udiLength    : UDINT;             // 待编码写入报文头的 MQTT 剩余长度[byte]    pBuffer      : POINTER TO BYTE;   // 指向剩余长度编码输出起始地址的指针END_VARVAR    uiBytes      : UINT := 0;         // 当前已写入的 VBI 编码字节数[byte]    byEncodedByte: BYTE;              // 当前准备写入缓冲区的 1 个 VBI 编码字节    udiX         : UDINT;             // Remaining Length 编码过程中的剩余待分解数值[byte]    pByte        : POINTER TO BYTE;   // 当前 VBI 编码字节写入位置指针    uiLoopGuard  : UINT := 0;         // VBI 编码循环保护计数器（最多允许写 4 个字节）END_VAR// === IMPLEMENTATION ===// Remaining Length 采用 MQTT 可变字节整数编码：// 每个字节低 7 位承载数值，最高位表示“后面是否还有后续字节”。pByte := pBuffer;udiX := udiLength;REPEAT    byEncodedByte := UDINT_TO_BYTE(udiX MOD 128);    udiX := udiX / 128;    // 只要后面还有剩余数值，就把续位标志位置 1。    IF udiX > 0 THEN        byEncodedByte := byEncodedByte OR 16#80;    END_IF    pByte^ := byEncodedByte;    pByte := pByte + 1;    uiBytes := uiBytes + 1;    // MQTT 标准规定 Remaining Length 最多只允许编码成 4 个字节，这里用保护计数强制收口。    uiLoopGuard := uiLoopGuard + 1;UNTIL(udiX = 0 OR uiLoopGuard >= 4)END_REPEATM_EncodeRemainingLength := uiBytes;

/// =======================================================================/// 名称      : M_DecodeRemainingLength/// 功能      : 解码 MQTT 剩余长度字段/// 说明      : 从缓冲区解析可变长度编码，返回消耗字节数并输出长度值。/// 编程人员  : ControlRookie/// 时间      : 2026-05-05/// 版本      : V1.0/// ======================================================================={attribute 'hide_all_locals'}METHOD M_DecodeRemainingLength : UINTVAR_INPUT    pBuffer     : POINTER TO BYTE; // 指向 MQTT 剩余长度编码起始字节的指针END_VARVAR_OUTPUT    uiLength            : UINT;          // 解码得到的 MQTT 剩余长度[byte]END_VARVAR    uiBytes             : UINT := 0;     // 当前已消费的编码字节数[byte]    uiMultiplier        : UINT := 1;     // 可变字节整数权重    byEncodedByte       : BYTE;          // 当前编码字节    pByte               : POINTER TO BYTE;// 当前读取指针END_VAR// === IMPLEMENTATION ===pByte := pBuffer;uiLength := 0;REPEAT    byEncodedByte := pByte^;    uiLength := uiLength + ((byEncodedByte AND 127) * uiMultiplier);    uiMultiplier := uiMultiplier * 128;    pByte := pByte + 1;    uiBytes := uiBytes + 1;UNTIL (byEncodedByte AND 128) = 0 OR uiBytes >= 4END_REPEATM_DecodeRemainingLength := uiBytes;

/// =======================================================================/// 名称      : M_AppendString/// 功能      : 追加 UTF-8 字符串到发送缓冲区/// 说明      : 先写入 2 字节长度前缀，再写入字符串内容并返回总字节数。/// 编程人员  : ControlRookie/// 时间      : 2026-05-05/// 版本      : V1.0/// ======================================================================={attribute 'hide_all_locals'}METHOD M_AppendString : UINTVAR_INPUT    sStr        : STRING(GVL_Mqtt.cnMaxPayloadSize); // 需要按 MQTT UTF-8 字符串格式写入的文本内容    pBuffer     : POINTER TO BYTE;   // 指向目标字符串写入起始地址的缓冲区指针END_VARVAR    uiLen       : UINT;              // 待写入字符串内容长度[byte]    i           : DINT;              // 逐字节复制字符串内容时使用的循环索引    pWrite      : POINTER TO BYTE;   // 当前字符串写入位置指针END_VAR// === IMPLEMENTATION ===uiLen := TO_UINT(LEN(sStr));// 长度前缀（MSB + LSB）pWrite := pBuffer;pWrite^ := UINT_TO_BYTE(SHR(uiLen, 8));pWrite := pWrite + 1;pWrite^ := UINT_TO_BYTE(uiLen AND 16#FF);// 字符串内容pWrite := pBuffer + 2;IF uiLen > 0 THEN    FOR i := 1 TO TO_DINT(uiLen) DO        pWrite^ := TO_BYTE(sStr[i - 1]);        pWrite := pWrite + 1;    END_FOREND_IFM_AppendString := uiLen + 2;

/// =======================================================================/// 名称      : M_AppendPayload/// 功能      : 追加消息载荷到发送缓冲区/// 说明      : 按字节拷贝字符串载荷并返回写入字节数。/// 编程人员  : ControlRookie/// 时间      : 2026-05-05/// 版本      : V1.0/// ======================================================================={attribute 'hide_all_locals'}METHOD M_AppendPayload : UINTVAR_INPUT    sPayload    : STRING(GVL_Mqtt.cnMaxPayloadSize); // 需要原样拷贝到 MQTT 载荷区的字符串内容    pBuffer     : POINTER TO BYTE;   // 指向目标载荷写入起始地址的缓冲区指针END_VARVAR    uiLen       : UINT;              // 待写入字符串载荷长度[byte]    i           : DINT;              // 逐字节复制载荷时使用的循环索引    pWrite      : POINTER TO BYTE;   // 当前载荷写入位置指针END_VAR// === IMPLEMENTATION ===uiLen := TO_UINT(LEN(sPayload));pWrite := pBuffer;IF uiLen > 0 THEN    FOR i := 1 TO TO_DINT(uiLen) DO        pWrite^ := TO_BYTE(sPayload[i - 1]);        pWrite := pWrite + 1;    END_FOREND_IFM_AppendPayload := uiLen;

/// =======================================================================/// 名称      : M_CopyBytesToString/// 功能      : 将字节缓冲区复制到字符串/// 说明      : 用顺序拷贝替代逐字符 CONCAT，降低接收解析中的字符串构造开销。/// 编程人员  : ControlRookie/// 时间      : 2026-05-07/// 版本      : V2.0/// ======================================================================={attribute 'hide_all_locals'}METHOD M_CopyBytesToString : BOOLVAR_INPUT    pSource       : POINTER TO BYTE;   // 源字节缓冲区首地址    uiByteCount   : UINT;              // 计划从源缓冲区复制到字符串的字节数[byte]END_VARVAR_IN_OUT    sTarget       : STRING;            // 目标字符串END_VARVAR    pRead         : POINTER TO BYTE;   // 当前源读取指针    pWrite        : POINTER TO BYTE;   // 当前目标写入指针    uiCopyLen     : UINT;              // 实际复制字节数    uiTargetLen   : UINT;              // 目标字符串最大可写字符数    i             : DINT;              // 循环索引END_VAR// === IMPLEMENTATION ===pWrite := ADR(sTarget);// 零长度时按“合法空字符串”处理，显式写入终止符。IF uiByteCount = 0 THEN    pWrite^ := 0;    M_CopyBytesToString := TRUE;    RETURN;END_IF// 空指针代表上游解析上下文异常，返回 FALSE 并输出空字符串。IF pSource = 0 THEN    pWrite^ := 0;    M_CopyBytesToString := FALSE;    RETURN;END_IF// 目标缓冲区至少要能放下 1 个字符串结束符。IF SIZEOF(sTarget) <= 1 THEN    pWrite^ := 0;    M_CopyBytesToString := FALSE;    RETURN;END_IF// 实际复制长度永远裁剪到目标字符串可容纳的最大字符数，避免越界写入。uiTargetLen := TO_UINT(SIZEOF(sTarget) - 1);uiCopyLen := uiByteCount;IF uiCopyLen > uiTargetLen THEN    uiCopyLen := uiTargetLen;END_IFpRead := pSource;IF uiCopyLen > 0 THEN    // 逐字节顺序拷贝比反复 CONCAT 更轻量，适合接收路径里的高频字符串组装。    FOR i := 1 TO TO_DINT(uiCopyLen) DO        pWrite^ := pRead^;        pWrite := pWrite + 1;        pRead := pRead + 1;    END_FOREND_IF// 手动补 0 结束符，把原始字节缓冲区显式收口成 IEC STRING。pWrite^ := 0;M_CopyBytesToString := TRUE;

/// =======================================================================/// 名称      : M_ReadIntoBuffer/// 功能      : 统一执行接收并累加到缓冲区/// 说明      : 读取 TCP 数据并做边界检查，成功返回 TRUE/// 编程人员  : ControlRookie/// 时间      : 2026-05-08/// 版本      : V2.0/// ======================================================================={attribute 'hide_all_locals'}METHOD M_ReadIntoBuffer : BOOLVAREND_VAR// === IMPLEMENTATION ===// 先打开底层读取请求；真正是否拿到数据，由 M_TcpRead 回填的 bHasRead 决定。bTcpRead := TRUE;// 本周期底层还没拿到数据时，先退出，等待下一个扫描周期继续。IF NOT bHasRead THEN    M_ReadIntoBuffer := FALSE;    RETURN;END_IFbTcpRead := FALSE;// 把本次读取结果拼到接收缓冲区尾部前，先做容量保护。IF uiRxLength + TO_UINT(udiBytesRead) > SIZEOF(aRxBuf) THEN    M_SetError(        uiErrorCode := TO_UINT(E_ReasonCode.uiErrBufferOverflow),        sMessage := 'Receive buffer overflow');    eState := E_MqttState.iTcpDisconnect;    M_ReadIntoBuffer := FALSE;    RETURN;END_IFuiRxLength := uiRxLength + TO_UINT(udiBytesRead);M_ReadIntoBuffer := TRUE;

/// =======================================================================/// 名称      : M_IsValidUtf8String/// 功能      : 校验字符串是否满足 MQTT UTF-8 基础约束/// 说明      : 当前实现做 PLC 可承受范围内的基础校验，拒绝 NUL、代理区与非法续字节/// 编程人员  : ControlRookie/// 时间      : 2026-05-05/// 版本      : V1.0/// ======================================================================={attribute 'hide_all_locals'}METHOD M_IsValidUtf8String : BOOLVAR_INPUT    sValue               : STRING(GVL_Mqtt.cnMaxTopicLen); // 待校验字符串END_VARVAR    uiLen                : UINT;           // 字符串长度    uiIndex              : UINT;           // 当前扫描到待校验字符串的第几个字节位置    byLead               : BYTE;           // 首字节    byCont1              : BYTE;           // 第 1 个续字节    byCont2              : BYTE;           // 第 2 个续字节    byCont3              : BYTE;           // 第 3 个续字节END_VAR// === IMPLEMENTATION ===/// MQTT 字符串在协议层要求使用 UTF-8。/// 这里按字节扫描，拒绝最常见的非法场景：/// - NUL 字节/// - 残缺多字节序列/// - 非法续字节/// - 代理区和超出 Unicode 上限的编码uiLen := TO_UINT(LEN(sValue));uiIndex := 1;WHILE uiIndex <= uiLen DO    byLead := TO_BYTE(sValue[uiIndex - 1]);    /// MQTT UTF-8 字符串中不允许出现 NUL。    IF byLead = 0 THEN        M_IsValidUtf8String := FALSE;        RETURN;    END_IF    IF byLead < 16#80 THEN        /// 单字节 ASCII。        uiIndex := uiIndex + 1;    ELSIF (byLead >= 16#C2) AND (byLead <= 16#DF) THEN        /// 2 字节序列：110xxxxx 10xxxxxx        IF uiIndex + 1 > uiLen THEN            M_IsValidUtf8String := FALSE;            RETURN;        END_IF        byCont1 := TO_BYTE(sValue[uiIndex]);        IF (byCont1 < 16#80) OR (byCont1 > 16#BF) THEN            M_IsValidUtf8String := FALSE;            RETURN;        END_IF        uiIndex := uiIndex + 2;    ELSIF byLead = 16#E0 THEN        /// 3 字节序列特例：限制第二字节下界，避免过短编码。        IF uiIndex + 2 > uiLen THEN            M_IsValidUtf8String := FALSE;            RETURN;        END_IF        byCont1 := TO_BYTE(sValue[uiIndex]);        byCont2 := TO_BYTE(sValue[uiIndex + 1]);        IF (byCont1 < 16#A0) OR (byCont1 > 16#BF) OR           (byCont2 < 16#80) OR (byCont2 > 16#BF) THEN            M_IsValidUtf8String := FALSE;            RETURN;        END_IF        uiIndex := uiIndex + 3;    ELSIF ((byLead >= 16#E1) AND (byLead <= 16#EC)) OR ((byLead >= 16#EE) AND (byLead <= 16#EF)) THEN        /// 常规 3 字节序列。        IF uiIndex + 2 > uiLen THEN            M_IsValidUtf8String := FALSE;            RETURN;        END_IF        byCont1 := TO_BYTE(sValue[uiIndex]);        byCont2 := TO_BYTE(sValue[uiIndex + 1]);        IF (byCont1 < 16#80) OR (byCont1 > 16#BF) OR           (byCont2 < 16#80) OR (byCont2 > 16#BF) THEN            M_IsValidUtf8String := FALSE;            RETURN;        END_IF        uiIndex := uiIndex + 3;    ELSIF byLead = 16#ED THEN        /// 代理区特例：第二字节只能到 16#9F，避免落入 UTF-16 surrogate 范围。        IF uiIndex + 2 > uiLen THEN            M_IsValidUtf8String := FALSE;            RETURN;        END_IF        byCont1 := TO_BYTE(sValue[uiIndex]);        byCont2 := TO_BYTE(sValue[uiIndex + 1]);        IF (byCont1 < 16#80) OR (byCont1 > 16#9F) OR           (byCont2 < 16#80) OR (byCont2 > 16#BF) THEN            M_IsValidUtf8String := FALSE;            RETURN;        END_IF        uiIndex := uiIndex + 3;    ELSIF byLead = 16#F0 THEN        /// 4 字节序列下界特例：避免过短编码。        IF uiIndex + 3 > uiLen THEN            M_IsValidUtf8String := FALSE;            RETURN;        END_IF        byCont1 := TO_BYTE(sValue[uiIndex]);        byCont2 := TO_BYTE(sValue[uiIndex + 1]);        byCont3 := TO_BYTE(sValue[uiIndex + 2]);        IF (byCont1 < 16#90) OR (byCont1 > 16#BF) OR           (byCont2 < 16#80) OR (byCont2 > 16#BF) OR           (byCont3 < 16#80) OR (byCont3 > 16#BF) THEN            M_IsValidUtf8String := FALSE;            RETURN;        END_IF        uiIndex := uiIndex + 4;    ELSIF (byLead >= 16#F1) AND (byLead <= 16#F3) THEN        /// 常规 4 字节序列。        IF uiIndex + 3 > uiLen THEN            M_IsValidUtf8String := FALSE;            RETURN;        END_IF        byCont1 := TO_BYTE(sValue[uiIndex]);        byCont2 := TO_BYTE(sValue[uiIndex + 1]);        byCont3 := TO_BYTE(sValue[uiIndex + 2]);        IF (byCont1 < 16#80) OR (byCont1 > 16#BF) OR           (byCont2 < 16#80) OR (byCont2 > 16#BF) OR           (byCont3 < 16#80) OR (byCont3 > 16#BF) THEN            M_IsValidUtf8String := FALSE;            RETURN;        END_IF        uiIndex := uiIndex + 4;    ELSIF byLead = 16#F4 THEN        /// 4 字节序列上界特例：Unicode 最高只允许到 U+10FFFF。        IF uiIndex + 3 > uiLen THEN            M_IsValidUtf8String := FALSE;            RETURN;        END_IF        byCont1 := TO_BYTE(sValue[uiIndex]);        byCont2 := TO_BYTE(sValue[uiIndex + 1]);        byCont3 := TO_BYTE(sValue[uiIndex + 2]);        IF (byCont1 < 16#80) OR (byCont1 > 16#8F) OR           (byCont2 < 16#80) OR (byCont2 > 16#BF) OR           (byCont3 < 16#80) OR (byCont3 > 16#BF) THEN            M_IsValidUtf8String := FALSE;            RETURN;        END_IF        uiIndex := uiIndex + 4;    ELSE        /// 其余首字节模式都不属于 MQTT 可接受的 UTF-8 编码。        M_IsValidUtf8String := FALSE;        RETURN;    END_IFEND_WHILEM_IsValidUtf8String := TRUE;