第1篇_客户端写完了，为什么我还要在 PLC 里写一个 MQTT Broker？

PROGRAM PRG_MqttBrokerDemo
VAR
    fbBroker : FB_MqttBroker; // MQTT Broker 主功能块实例
    bEnable  : BOOL := TRUE;  // 示例总使能
END_VAR

fbBroker(
    bEnable := bEnable,
    sBindIP := '0.0.0.0',
    uiPort := GVL_MqttBroker.cnDefaultPort);

fbBroker(
    bEnable := TRUE,
    sBindIP := '192.168.20.100',
    uiPort := 1883);

/// =======================================================================
/// 名称      : PRG_MqttBrokerDemo
/// 功能      : MQTT Broker 最小运行示例
/// 说明      : 在 PLC 应用任务中周期调用本程序即可启动轻量 Broker。
/// 编程人员  : ControlRookie
/// 时间      : 2026-05-08
/// 版本      : V1.0
/// =======================================================================
PROGRAM PRG_MqttBrokerDemo
VAR
    fbBroker : FB_MqttBroker; // MQTT Broker 主功能块实例，负责监听、接入、路由和事务调度
    bEnable  : BOOL := TRUE; // 示例总使能，TRUE 时启动 Broker，FALSE 时停机释放运行态
END_VAR

// === IMPLEMENTATION ===
fbBroker(
    bEnable := bEnable,
    sBindIP := '0.0.0.0',
    uiPort := GVL_MqttBroker.cnDefaultPort);

/// =======================================================================
/// 名称      : GVL_MqttBroker
/// 功能      : MQTT Broker 全局常量
/// 说明      : 所有容量、协议默认值和超时策略集中定义，便于 PLC 项目按资源统一裁剪。
/// 编程人员  : ControlRookie
/// 时间      : 2026-05-08
/// 版本      : V1.0
/// =======================================================================
{attribute 'qualified_only'}
VAR_GLOBAL CONSTANT
    cnDefaultPort              : UINT  := 1883;  // Broker 默认 MQTT TCP 监听端口号
    cnMaxClientSlots           : UINT  := 8;     // PLC 侧 Broker 同时允许保持的最大客户端槽位数量
    cnMaxSubscriptions         : UINT  := 64;    // 全局订阅表最大条目数，所有客户端共享
    cnMaxRetainedMessages      : UINT  := 32;    // Retain 保留消息表最大条目数
    cnMaxRxInflight            : UINT  := 16;    // 入站 QoS>0 事务表容量，为未来 QoS2 接收去重预留
    cnMaxTxInflight            : UINT  := 32;    // 出站 QoS>0 事务表容量，为 QoS1 重发和未来 QoS2 投递预留
    cnMaxTopicLen              : UINT  := 256;   // MQTT Topic Name / Topic Filter 最大长度[byte]
    cnMaxClientIdLen           : UINT  := 128;   // MQTT ClientID 最大缓存长度[byte]
    cnMaxUsernameLen           : UINT  := 64;    // MQTT 用户名最大缓存长度[byte]
    cnMaxPasswordLen           : UINT  := 64;    // MQTT 密码最大缓存长度[byte]
    cnMaxPayloadLen            : UINT  := 1024;  // 单条消息载荷最大缓存长度[byte]
    cnRxBufferSize             : UINT  := 2048;  // 单连接 TCP 接收缓冲区容量[byte]
    cnTxBufferSize             : UINT  := 2048;  // 单连接 TCP 发送缓冲区容量[byte]
    cnMaxTopicItemsPerPacket   : UINT  := 8;     // 单个 SUBSCRIBE / UNSUBSCRIBE 报文最多解析的主题条目数
    cnMaxAuthUsers             : UINT  := 8;     // 固定用户表最大条目数，用于轻量基础认证
    cnMaxAclRules              : UINT  := 16;    // 固定 Topic 权限表最大条目数，用于轻量 ACL
    cnProtocolQueueSize        : UINT  := 8;     // 单连接协议优先队列容量，PUBACK/SUBACK/PINGRESP 等优先使用
    cnDeliveryQueueSize        : UINT  := 16;    // 单连接普通投递队列容量，PUBLISH 业务消息使用
    cnDeliveryQueueHighWater   : UINT  := 12;    // 单连接普通投递队列高水位，超过后进入慢客户端保护
    cnMaxTxFramesPerWrite      : UINT  := 8;     // 单次 TCP_Write 最多合并写出的 MQTT 控制报文帧数量；现场实测常见为 1~2 帧，保留 8 作为上限但不主动堆大突发[帧]
    cnMinTxBufferFree          : UINT  := 64;    // 批量编码时保留的发送缓冲安全余量，避免最后一帧贴边写入[byte]
    cnDiagHistorySize          : UINT  := 32;    // 诊断环形历史最大条目数
    cnDefaultKeepAlive         : UINT  := 60;    // 客户端未声明时采用的默认 KeepAlive 周期[s]
END_VAR