第8篇_PLC 侧 MQTT Broker 现场排障：连不上、订阅失败、发布延迟、Retain 收不到该怎么查

xTcpAcceptActive 闪
uiAcceptFreeSlot 闪
uiActiveSlotCount 闪

// 示例：在线监控时优先观察这些输出，而不是只盯客户端日志。
xBrokerRunning := fbBroker.xRunning;
xBrokerError := fbBroker.xError;
eBrokerError := fbBroker.eLastError;
uiActiveSlotCount := fbBroker.uiActiveSlotCount;
uiAcceptFreeSlot := fbBroker.uiAcceptFreeSlot;
stSlot1Snapshot := fbBroker.aSnapshots[1];

cnMaxFramesPerConnectionScan = 8
cnMaxTxFramesPerWrite = 8
cnConnectFirstReadDelayMs = 20
cnConnectionInactiveGraceMs = 3000

TYPE ST_MqttBrokerConnectionSnapshot :
STRUCT
    xUsed                : BOOL; // 当前槽位是否占用
    xMqttConnected       : BOOL; // 当前槽位是否完成 MQTT 会话建立
    xDisconnectRequested : BOOL; // 当前槽位是否已经请求断开和清理
    xTcpReadError        : BOOL; // 当前槽位 TCP_Read 是否报错
    xTcpWriteError       : BOOL; // 当前槽位 TCP_Write 是否报错
    xWriteBusy           : BOOL; // 当前槽位是否正在等待 TCP_Write 完成
    xWriteExecute        : BOOL; // 当前槽位当前扫描周期是否触发 TCP_Write
    xConnectionActive    : BOOL; // 当前槽位对应的 NBS TCP_Connection 是否仍处于 Active 状态
    xLastTcpReadError    : BOOL; // 当前槽位生命周期内是否曾经捕获 TCP_Read 报错
    uiSlot               : UINT; // 当前槽位编号[1..cnMaxClientSlots]
    uiTcpReadErrorCount  : UINT; // 当前槽位连续 TCP_Read 错误次数，达到阈值才释放连接
    byProtocolLevel      : BYTE; // 当前会话实际使用的 MQTT 协议级别，3 表示 3.1，4 表示 3.1.1，5 表示 5.0 基础兼容模式
    uiKeepAlive          : UINT; // 客户端声明或 Broker 默认的 KeepAlive 周期[s]
    udiLastActivityMs    : ULINT; // 最近一次收到 MQTT 控制报文的系统时间戳[ms]
    udiLastTcpActiveMs   : ULINT; // 最近一次监听层确认 TCP_Connection 仍 Active 的系统时间戳[ms]
    udiLastBytesRead     : UDINT; // 当前槽位最近一次 TCP_Read 读到的字节数[byte]
    udiLastNonZeroBytesRead : UDINT; // 当前槽位生命周期内最近一次非零 TCP_Read 字节数[byte]
    hConnection          : NBS.CAA.HANDLE; // 当前槽位绑定的 TCP 连接句柄，0 表示槽位没有有效连接
    uiRxLength           : UINT; // 当前槽位接收缓冲区已缓存字节数[byte]
    uiTxLength           : UINT; // 当前槽位发送缓冲区待发送字节数[byte]
    uiLastTxFrameCount   : UINT; // 当前槽位最近一次 TCP_Write 实际合并写出的 MQTT 帧数量[帧]
    uiLastTxBytes        : UINT; // 当前槽位最近一次 TCP_Write 实际写出的总字节数[byte]
    udiTxBatchCount      : UDINT; // 当前槽位累计启动 TCP 批量写出的次数[次]
    udiTxFrameCount      : UDINT; // 当前槽位累计写出的 MQTT 帧数量[帧]
    uiMaxDeliveryQueueCountSeen : UINT; // 当前槽位生命周期内普通投递队列最高水位[条]
    uiMaxProtocolQueueCountSeen : UINT; // 当前槽位生命周期内协议优先队列最高水位[条]
    udiTxQueueFullDropped : UDINT; // 当前槽位因队列高水位或队列满而丢弃的 QoS0 投递数量[条]
    uiLastFrameLen       : UINT; // 当前槽位最近一次识别到的 MQTT 完整帧长度[byte]
    byLastPacketType     : BYTE; // 当前槽位最近一次处理的 MQTT 控制报文类型高 4 位，例如 16#10 表示 CONNECT
    byLastConnectLevel   : BYTE; // 当前槽位最近一次 CONNECT 协议级别字节，3 表示 3.1，4 表示 3.1.1，5 表示 5.0 基础兼容模式
    xLastConnectParsed   : BOOL; // 当前槽位最近一次 CONNECT 是否已经成功解析并进入会话建立流程
    uiProtocolQueueCount : UINT; // 协议优先队列占用数量
    uiDeliveryQueueCount : UINT; // 普通投递队列占用数量
    uiRxInflightCount    : UINT; // 当前连接关联的入站 QoS>0 事务数量
    uiTxInflightCount    : UINT; // 当前连接关联的出站 QoS>0 事务数量
    eState               : E_MqttConnectionState; // 当前连接状态机状态
    eLastError           : E_MqttBrokerError; // 当前连接最近错误码
    eLastParseError      : E_MqttBrokerError; // 当前槽位最近一次 MQTT 报文解析失败原因，uiNoError 表示最近解析未失败
    eTcpReadErrorID      : NBS.ERROR; // 当前槽位 TCP_Read 原始错误码
    eLastTcpReadErrorID  : NBS.ERROR; // 当前槽位生命周期内最近一次 TCP_Read 报错原始错误码，避免禁用读 FB 后被清零
    eTcpWriteErrorID     : NBS.ERROR; // 当前槽位 TCP_Write 原始错误码
    sClientId            : STRING(GVL_MqttBroker.cnMaxClientIdLen); // 当前连接 ClientID
    sUsername            : STRING(GVL_MqttBroker.cnMaxUsernameLen); // 当前连接认证用户名
END_STRUCT
END_TYPE

/// =======================================================================
/// 名称      : M_LogDiag
/// 功能      : 写入 Broker 诊断环形历史
/// 说明      : 所有关键异常和维护动作写入固定 ring buffer，避免动态内存和日志文件依赖。
/// 编程人员  : ControlRookie
/// 时间      : 2026-05-08
/// 版本      : V1.0
/// =======================================================================
{attribute 'hide_all_locals'}
METHOD M_LogDiag : BOOL
VAR_INPUT
    uiSlot   : UINT; // 事件关联客户端槽位，0 表示 Broker 顶层事件[1..cnMaxClientSlots]
    eError   : E_MqttBrokerError; // 事件关联错误码或状态码
    sMessage : STRING; // 面向现场工程师的简短中文诊断文本
END_VAR

// === IMPLEMENTATION ===
IF (uiDiagWriteIndex < 1) OR (uiDiagWriteIndex > GVL_MqttBroker.cnDiagHistorySize) THEN
    uiDiagWriteIndex := 1;
END_IF

aDiagHistory[uiDiagWriteIndex].xUsed := TRUE;
aDiagHistory[uiDiagWriteIndex].uiSlot := uiSlot;
aDiagHistory[uiDiagWriteIndex].eError := eError;
aDiagHistory[uiDiagWriteIndex].udiTimeMs := udiNowMs;
aDiagHistory[uiDiagWriteIndex].sMessage := sMessage;
IF uiDiagHistoryCount < GVL_MqttBroker.cnDiagHistorySize THEN
    uiDiagHistoryCount := uiDiagHistoryCount + 1;
END_IF

uiDiagWriteIndex := uiDiagWriteIndex + 1;
IF uiDiagWriteIndex > GVL_MqttBroker.cnDiagHistorySize THEN
    uiDiagWriteIndex := 1;
END_IF

M_LogDiag := TRUE;