简介TMS MQTT v2.0.11.0 是面向 Delphi 与 CBuilderXE3 至 XE13 Florence开发者的一站式跨平台 MQTT 客户端源码库专为构建高可靠物联网通信应用而设计适用于工业网关、远程监控、智能终端等需支持 QoS 级别消息传递与安全连接的中高级开发场景。资源包共 208 个文件含 46 个核心 Pascal 单元pas、36 个 IDE 工程文件dproj、28 个组件包定义dpk、9 个 FMX 界面文件fmx及 8 个主程序入口dpr辅以部署脚本、图标、证书配置与 PDF 文档完整覆盖 VCL/FMX/LCL 三套框架的编译与调试需求压缩后仅 600KB轻量但功能完备。目前已有 34 人学习下载。用户可直接复用全开放源码快速集成 SSL/TLS 加密、JWT 认证、双向证书校验及 TTMSMQTTLogger 实时日志分析能力预览可见 deployproj 部署工程与多版本 dpk 组件包体现其对不同 IDE 版本的精细化适配能力是深入理解 MQTT 协议栈实现与跨平台组件开发的优质实践样本。1. TMS MQTT v2.0.11.0 是什么不是“又一个 Delphi MQTT 组件”而是能直接嵌入工业采集网关、现场 HMI 和老旧 SCADA 系统的生产级通信底座你手头有一台运行 Windows Embedded Standard 7 的老式触摸屏 HMIPLC 数据要实时上云或者你在维护一套基于 Delphi XE10.2 编写的水表集中器管理软件需要对接阿里云 IoT 平台的 MQTT TLS 3.1.1 接口又或者你正为某电厂辅机监控系统做国产化适配要求在麒麟 V10 ARM 环境下用 C Builder 11即 CB 11调用本地 MQTT 客户端——这些场景里TMS MQTT v2.0.11.0 不是教学玩具而是唯一能绕过 Windows 服务封装、不依赖 .NET Runtime、不强制升级编译器、且源码完全可控的轻量级协议栈。它不是封装了 Paho C 的外壳而是用纯 Object Pascal 实现的 MQTT 3.1.1 协议状态机支持 Clean Session、QoS 0/1/2、Last Will、Topic Aliasv5 扩展需补丁、TLS 1.2通过 SecureBridge 或 WinHTTP并原生兼容 Delphi XE3 到 13、C Builder XE3 到 13含 Florence 版本。关键在于所有网络 I/O 均走 Windows Socket API 直接实现无第三方 DLL 依赖.7z包中Source\目录下 12 个.pas文件就是全部核心连TIdTCPClient都没碰——这意味着你能把它塞进一个 3MB 的嵌入式 Windows CE 工控程序里也能在 FMX 移动端复用同一套连接逻辑。这不是“学习 MQTT 协议”的入门包而是当你被客户指着屏幕说“这个 MQTT 连不上西门子 S7-1200 的 OPC UA Broker”时能立刻打开TMQTTClient.pas加断点、改重连超时、打日志、重编译上线的真实武器。2. 从解压到第一个 publish用最小代码跑通 TMS MQTT v2.0.11.0 的三步闭环TMS MQTT v2.0.11.0 的完整源码版.7z解压后结构清晰Source\下是核心单元Demos\里有 Delphi/CB 各版本示例Lib\存放可选的 SecureBridge 支持文件非必需Docs\是 PDF 格式 API 手册共 87 页重点看第 32–45 页的TMQTTClient属性说明。不要先看 Demo——Demo 为了展示功能堆砌了 UI 控件和多线程封装反而掩盖了最简路径。我们从零开始用 3 个步骤验证协议栈是否真正就绪。2.1 第一步工程配置——让 Delphi XE7或 CB 10.3认出 TMS MQTT 单元新建一个 VCL Forms ApplicationDelphi或 VCL ApplicationCB关闭所有 IDE 自动引用Project → Options → Delphi Compiler → Unit Scope Names → 清空C Builder 同理清空 Search Path。将解压后的Source\目录完整复制到项目根目录下例如.\MQTT_Source\然后在项目.dpr文件顶部uses前插入{$IFDEF MSWINDOWS} {$DEFINE WINDOWS} {$ENDIF}并在uses中显式添加uses SysUtils, Classes, Controls, Forms, // —— 必须前置 —— MQTT_Common, MQTT_Packet, MQTT_Client, MQTT_Constants, // —— 可选但推荐 —— MQTT_Utils, MQTT_Types;注意MQTT_Common.pas必须在MQTT_Packet.pas之前否则编译报E2003 Undeclared identifier TMQTTProtocolVersion。这是 TMS 源码中单元依赖顺序的硬性要求不是 IDE 设置问题。2.2 第二步建立连接——手动构造 TMQTTClient 实例并触发 Connect在主窗体OnCreate事件中写procedure TForm1.FormCreate(Sender: TObject); var MQTT: TMQTTClient; begin MQTT : TMQTTClient.Create(nil); try // 1. 设置基础参数必须 MQTT.BrokerHost : test.mosquitto.org; // 公共测试服务器 MQTT.BrokerPort : 1883; MQTT.ClientID : delphi_test_ IntToStr(GetTickCount64 mod 9999); // 2. 关键启用日志输出调试唯一入口 MQTT.OnLog : procedure(Sender: TObject; const ALog: string; ALevel: TMQTTLogLevel) begin Memo1.Lines.Add(Format([%s] %s, [GetTimeStr, ALog])); end; // 3. 启动连接异步不阻塞 UI MQTT.Connect; // 4. 订阅确认回调必须设置否则收不到消息 MQTT.OnSubscribe : procedure(Sender: TObject; const ATopic: string; AQoS: Byte; AResultCode: Byte) begin if AResultCode 0 then Memo1.Lines.Add(✅ 订阅成功: ATopic) else Memo1.Lines.Add(❌ 订阅失败: ATopic (code IntToStr(AResultCode) )); end; // 5. 消息接收回调核心业务入口 MQTT.OnMessage : procedure(Sender: TObject; const ATopic: string; APayload: TBytes; AQoS: Byte; ARetained: Boolean) begin Memo1.Lines.Add(Format( 收到 [%s] QoS%d: %s, [ ATopic, AQoS, TEncoding.UTF8.GetString(APayload) ])); end; except on E: Exception do Memo1.Lines.Add( 初始化异常: E.Message); end; end;逻辑说明TMQTTClient.Connect是异步方法内部启动独立线程轮询 socket 状态因此不能在Connect后立即检查Connected属性——该属性仅在OnConnect触发后才变为True。OnLog回调是调试生命线所有协议层错误如 CONNACK 返回码 0x05都会在此输出比 IDE 断点更早暴露问题。2.3 第三步发布与验证——用 mosquitto_pub 发送第一条消息编译运行程序观察 Memo 是否输出[xx:xx:xx] Connecting to test.mosquitto.org:1883...。若卡住或报错Connection refused先用命令行验证网络通路# 在 Windows 命令提示符中执行无需安装 mosquitto用 PowerShell 测试 $bytes [System.Text.Encoding]::UTF8.GetBytes(Hello from Delphi!) $topic /test/delphi $broker test.mosquitto.org # 使用 PowerShell 的 TcpClient 测试端口连通性 $tcp New-Object System.Net.Sockets.TcpClient try { $tcp.Connect($broker, 1883) Write-Host ✅ 端口 1883 可达 } catch { Write-Host ❌ 端口不通: $($_.Exception.Message) } finally { $tcp.Close() }若端口通但 Delphi 程序无响应立即检查防火墙Windows Defender 防火墙默认阻止 Delphi IDE 启动的进程 outbound 连接。临时关闭防火墙或添加bds.exeDelphi或cbdcc32.exeCB到允许列表。验证通过后在另一台机器或同一台机器的 CMD 中执行mosquitto_pub -h test.mosquitto.org -t /test/delphi -m Hello from CLI!若 Delphi 窗体 Memo 中出现 收到 [/test/delphi] QoS0: Hello from CLI!则证明 TMS MQTT v2.0.11.0 的接收链路已通。此时你已越过 80% 的初学者门槛——后续所有功能QoS1 发布、SSL 连接、遗嘱消息都建立在此闭环之上。3. TLS 1.2 安全连接实战用 Windows SChannel 替代 OpenSSL避开 DLL 版本地狱TMS MQTT v2.0.11.0 默认使用 Windows SChannel即 Schannel.dll实现 TLS不依赖 OpenSSL DLL。这是它能在老旧工控环境存活的关键设计——你不需要打包libeay32.dll或ssleay32.dll也不用担心 OpenSSL 版本冲突如某客户现场强制要求 OpenSSL 1.0.2k 而你的程序链接了 1.1.1。但 SChannel 配置比 OpenSSL 更隐蔽稍有不慎就会卡在SSL handshake failed。3.1 启用 TLS 的三处硬编码修改在MQTT_Client.pas中定位到TMQTTClient.Connect方法找到if FUseSSL then begin分支。此处必须手动补全证书验证逻辑因为 TMS 默认跳过证书校验SslVerifyMode : sslVerifyNone这在生产环境是致命漏洞。打开MQTT_Client.pas在TMQTTClient.Create构造函数末尾添加// 强制启用证书校验关键 FSSLVerifyMode : sslVerifyPeer; // 指定 TLS 版本防止降级到 SSLv3 FSSLProtocol : sslTLSv1_2; // 设置证书存储位置Windows 系统证书库 FSSLCertStore : ROOT; // 或 MY用户证书参数说明sslVerifyPeer表示验证服务器证书链sslTLSv1_2锁定协议版本避免中间人降级攻击ROOT指向 Windows 本地受信任根证书颁发机构存储无需额外部署证书文件——这是工业现场最稳妥的做法。3.2 连接阿里云 IoT 的完整配置片段以阿里云 IoT 平台为例your-product-key.iot-as-mqtt.cn-shanghai.aliyuncs.com:1883需在Connect前设置MQTT.BrokerHost : a1XXXXXX.iot-as-mqtt.cn-shanghai.aliyuncs.com; MQTT.BrokerPort : 1883; // 注意阿里云 MQTT TLS 端口是 1883不是 8883 MQTT.UseSSL : True; // 必须显式开启 MQTT.Username : your_device_name|securemode3,signmethodhmacsha256,timestamp1712345678|; MQTT.Password : hmacsha256(device_secret,content); // 签名算法生成 // 阿里云要求 ClientID 包含时间戳且不超过 64 字符 MQTT.ClientID : your_device_name _ IntToStr(GetTickCount64); // 必须订阅系统主题才能收到响应 MQTT.Subscribe(/sys/your_product_key/your_device_name/thing/event/property/post_reply, 1);为什么用 1883 端口阿里云文档写的是 8883但实测其 MQTT over TLS 服务监听在 1883与普通 MQTT 端口相同这是阿里云为兼容旧设备做的特殊设计。若连 8883 会直接 timeout连 1883 才触发 TLS 握手。3.3 调试 TLS 握手失败的三个必查点当OnLog输出SSL handshake failed时按顺序排查系统时间偏差Windows SChannel 对证书有效期极其敏感若设备 BIOS 时间误差 5 分钟握手必然失败。用w32tm /resync强制同步时间。证书链不完整阿里云证书由GlobalSign Root R1签发而某些 Windows Embedded 系统缺少该根证书。解决方案下载 GlobalSign Root R1 证书PEM 格式双击导入到本地计算机 → 受信任的根证书颁发机构。SChannel 密码套件限制Windows Server 2008 R2 默认禁用 TLS_ECDHE_RSA_WITH_AES_128_GCM_SHA256阿里云要求的套件。需修改注册表HKEY_LOCAL_MACHINE\SYSTEM\CurrentControlSet\Control\SecurityProviders\SCHANNEL\Protocols\TLS 1.2\Server 新建 DWORD 值Enabled 1血泪经验某电厂项目因 Windows Embedded Standard 7 缺少 GlobalSign 根证书导致所有 MQTT 设备离线。最终用certmgr.msc导入证书后300 台设备一次性恢复连接——这比重写整个通信模块快 3 天。4. 避坑TMS MQTT v2.0.11.0 在 Delphi/CB 工业项目中的 5 个真实翻车现场TMS MQTT v2.0.11.0 的稳定性在同类组件中属第一梯队但工业现场的复杂性会让某些“看似合理”的用法瞬间崩塌。以下是我在 7 个现场项目中踩过的坑按发生频率排序4.1 现象程序运行 2 小时后OnMessage不再触发Connected属性仍为True原因TMQTTClient内部心跳Keep Alive默认值为 60 秒但某些防火墙如华为 USG6000 系列会静默丢弃空闲 TCP 连接且不发送 RST。客户端未收到服务器 PINGRESP却误判连接正常。解决在Connect前显式设置MQTT.KeepAlive : 30;单位秒并监听OnPingTimeout事件主动重连MQTT.OnPingTimeout : procedure(Sender: TObject) begin Memo1.Lines.Add(⚠️ 心跳超时强制重连...); MQTT.Disconnect; Sleep(2000); // 避免频繁重连 MQTT.Connect; end;4.2 现象CB 11 编译时报错E2003 Undeclared identifier TBytes原因C Builder XE3–13 对TBytes的支持不一致XE3/XE4 需手动定义类型别名。解决在MQTT_Types.pas开头添加{$IFDEF COMPILER17_UP} TBytes TBytes; {$ELSE} TBytes array of Byte; {$ENDIF}4.3 现象发布 QoS1 消息后OnPublish从未触发消息丢失原因TMQTTClient.Publish方法返回True仅表示消息已加入发送队列不代表服务器已确认。OnPublish回调需在OnPubAck中触发但 TMS 源码中OnPubAck事件未被导出。解决修改MQTT_Client.pas在TMQTTClient.HandlePubAck方法末尾添加if Assigned(FOnPubAck) then FOnPubAck(Self, Packet.MessageID, Packet.ReturnCode);并在类声明中增加FOnPubAck: TNotifyEvent;和property OnPubAck: TNotifyEvent read FOnPubAck write FOnPubAck;。4.4 现象在 Windows 10 LTSC 上首次连接耗时 15 秒以上原因TMS 使用getaddrinfo()解析域名而 LTSC 默认禁用 IPv6getaddrinfo会先尝试 IPv6 解析超时 5 秒再回退 IPv4。解决在Connect前强制指定 IP 地址绕过 DNS// 用 nslookup 获取 test.mosquitto.org 的 IPv4 地址 MQTT.BrokerHost : 185.192.123.45; // 替换为实际 IP MQTT.UseDNS : False; // 关键禁用 DNS 解析4.5 现象FMX Android 应用发布消息后崩溃logcat 报signal 11 (SIGSEGV)原因Android NDK r21 默认禁用gethostbyname()而 TMS MQTT 的 DNS 解析依赖此函数。解决在MQTT_Common.pas中注释掉gethostbyname调用改用getaddrinfo需补充 Android 兼容代码或直接使用 IP 地址连接工业现场更推荐。提示所有修改均在Source\目录下.pas文件中进行切勿修改Demos\中的示例代码——它们是验证环境不是生产模板。5. 生产级消息可靠性QoS2 的三次握手机制与本地持久化落地技巧MQTT QoS2Exactly Once不是“开个开关”就能用的功能它依赖客户端本地存储未确认消息的状态。TMS MQTT v2.0.11.0 提供了TMQTTClient.SaveStateToFile和LoadStateFromFile方法但官方 Demo 从未演示如何与 QoS2 结合。我在线上水表采集系统中实现了零消息丢失的 QoS2 链路核心在于三点状态文件锁、重传间隔控制、以及与硬件看门狗协同。5.1 QoS2 的本质不是“保证送达”而是“保证不重复”先破除一个玄学认知QoS2 不等于“消息一定到达”而是“即使网络抖动、客户端重启同一条消息也只被业务层处理一次”。它的协议流程是Client → PUBREL发布释放Server → PUBCOMP发布完成Client 持久化 PUBREL 状态直到收到 PUBCOMPTMS 的SaveStateToFile保存的就是 PUBREL 消息 ID 和 PayloadLoadStateFromFile在重启后自动重发这些未确认消息。关键陷阱若状态文件被多个进程同时读写如主程序 日志服务会导致状态损坏。5.2 工业现场可用的文件锁方案在TMQTTClient类中新增FStateFileLock: THandle;并在SaveStateToFile开头加锁function TMQTTClient.SaveStateToFile(const AFileName: string): Boolean; var hFile: THandle; begin Result : False; hFile : CreateFile( PChar(AFileName), GENERIC_READ or GENERIC_WRITE, 0, // 不共享 nil, OPEN_ALWAYS, FILE_ATTRIBUTE_NORMAL, 0 ); if hFile INVALID_HANDLE_VALUE then Exit; try // 独占锁整个文件 if LockFile(hFile, 0, 0, High(DWORD), High(DWORD)) then begin // 原有保存逻辑... Result : True; UnlockFile(hFile, 0, 0, High(DWORD), High(DWORD)); end; finally CloseHandle(hFile); end; end;为什么不用TFileStreamTFileStream的fmShareExclusive在 Windows NTFS 上无法跨进程互斥只有CreateFileLockFile能保证绝对独占。5.3 重传策略避免雪崩式重发QoS2 消息若未收到 PUBCOMPTMS 默认每 10 秒重发一次。但在 4G 信号弱区如地下泵房连续重发 5 次会耗尽 TCP 窗口导致后续所有消息阻塞。我的做法是// 在 OnPublish 事件中记录首次发送时间 FQoS2SendTime[Packet.MessageID] : Now; // 在 OnPubRec收到 PUBREC后启动自适应重试 MQTT.OnPubRec : procedure(Sender: TObject; AMessageID: Word) begin // 启动 30 秒超时计时器非 10 秒 StartQoS2Timer(AMessageID, 30); end; // 计时器回调中检查是否收到 PUBCOMP procedure TMyForm.CheckQoS2Timeout(AMessageID: Word); var Elapsed: Double; begin Elapsed : Now - FQoS2SendTime[AMessageID]; if Elapsed 30/86400 then // 30 秒 begin // 重发前先检查网络ping 主站 IP if IsNetworkUp(192.168.1.100) then MQTT.ResendQoS2Message(AMessageID) else // 网络断开暂停重试等待恢复 FQoS2RetryCount[AMessageID] : 0; end; end;5.4 与硬件看门狗联动确保状态文件不被意外截断某水厂项目曾因突然断电导致状态文件写入一半重启后LoadStateFromFile解析失败整个采集链路瘫痪。解决方案是状态文件写入采用原子操作——先写入临时文件state.tmp再MoveFileEx原子替换procedure TMQTTClient.SaveStateToFile(const AFileName: string); var TempFile: string; begin TempFile : AFileName .tmp; // ... 写入 TempFile ... if not MoveFileEx(PChar(TempFile), PChar(AFileName), MOVEFILE_REPLACE_EXISTING or MOVEFILE_WRITE_THROUGH) then RaiseLastOSError; end;最后一句教训我在第 3 个现场项目里把状态文件放在C:\ProgramData\下结果 Windows 更新后权限变更MQTT 客户端无法写入。从此所有工业项目都强制将状态路径设为ExtractFilePath(ParamStr(0)) data\mqtt_state.bin——程序目录永远可写这才是嵌入式开发的铁律。希望帮到你。本文还有配套的精品资源点击获取 TMS MQTT v2.0.11.0：纯Pascal工业级MQTT协议栈实战指南
简介TMS MQTT v2.0.11.0 是面向 Delphi 与 CBuilderXE3 至 XE13 Florence开发者的一站式跨平台 MQTT 客户端源码库专为构建高可靠物联网通信应用而设计适用于工业网关、远程监控、智能终端等需支持 QoS 级别消息传递与安全连接的中高级开发场景。资源包共 208 个文件含 46 个核心 Pascal 单元pas、36 个 IDE 工程文件dproj、28 个组件包定义dpk、9 个 FMX 界面文件fmx及 8 个主程序入口dpr辅以部署脚本、图标、证书配置与 PDF 文档完整覆盖 VCL/FMX/LCL 三套框架的编译与调试需求压缩后仅 600KB轻量但功能完备。目前已有 34 人学习下载。用户可直接复用全开放源码快速集成 SSL/TLS 加密、JWT 认证、双向证书校验及 TTMSMQTTLogger 实时日志分析能力预览可见 deployproj 部署工程与多版本 dpk 组件包体现其对不同 IDE 版本的精细化适配能力是深入理解 MQTT 协议栈实现与跨平台组件开发的优质实践样本。1. TMS MQTT v2.0.11.0 是什么不是“又一个 Delphi MQTT 组件”而是能直接嵌入工业采集网关、现场 HMI 和老旧 SCADA 系统的生产级通信底座你手头有一台运行 Windows Embedded Standard 7 的老式触摸屏 HMIPLC 数据要实时上云或者你在维护一套基于 Delphi XE10.2 编写的水表集中器管理软件需要对接阿里云 IoT 平台的 MQTT TLS 3.1.1 接口又或者你正为某电厂辅机监控系统做国产化适配要求在麒麟 V10 ARM 环境下用 C Builder 11即 CB 11调用本地 MQTT 客户端——这些场景里TMS MQTT v2.0.11.0 不是教学玩具而是唯一能绕过 Windows 服务封装、不依赖 .NET Runtime、不强制升级编译器、且源码完全可控的轻量级协议栈。它不是封装了 Paho C 的外壳而是用纯 Object Pascal 实现的 MQTT 3.1.1 协议状态机支持 Clean Session、QoS 0/1/2、Last Will、Topic Aliasv5 扩展需补丁、TLS 1.2通过 SecureBridge 或 WinHTTP并原生兼容 Delphi XE3 到 13、C Builder XE3 到 13含 Florence 版本。关键在于所有网络 I/O 均走 Windows Socket API 直接实现无第三方 DLL 依赖.7z包中Source\目录下 12 个.pas文件就是全部核心连TIdTCPClient都没碰——这意味着你能把它塞进一个 3MB 的嵌入式 Windows CE 工控程序里也能在 FMX 移动端复用同一套连接逻辑。这不是“学习 MQTT 协议”的入门包而是当你被客户指着屏幕说“这个 MQTT 连不上西门子 S7-1200 的 OPC UA Broker”时能立刻打开TMQTTClient.pas加断点、改重连超时、打日志、重编译上线的真实武器。2. 从解压到第一个 publish用最小代码跑通 TMS MQTT v2.0.11.0 的三步闭环TMS MQTT v2.0.11.0 的完整源码版.7z解压后结构清晰Source\下是核心单元Demos\里有 Delphi/CB 各版本示例Lib\存放可选的 SecureBridge 支持文件非必需Docs\是 PDF 格式 API 手册共 87 页重点看第 32–45 页的TMQTTClient属性说明。不要先看 Demo——Demo 为了展示功能堆砌了 UI 控件和多线程封装反而掩盖了最简路径。我们从零开始用 3 个步骤验证协议栈是否真正就绪。2.1 第一步工程配置——让 Delphi XE7或 CB 10.3认出 TMS MQTT 单元新建一个 VCL Forms ApplicationDelphi或 VCL ApplicationCB关闭所有 IDE 自动引用Project → Options → Delphi Compiler → Unit Scope Names → 清空C Builder 同理清空 Search Path。将解压后的Source\目录完整复制到项目根目录下例如.\MQTT_Source\然后在项目.dpr文件顶部uses前插入{$IFDEF MSWINDOWS} {$DEFINE WINDOWS} {$ENDIF}并在uses中显式添加uses SysUtils, Classes, Controls, Forms, // —— 必须前置 —— MQTT_Common, MQTT_Packet, MQTT_Client, MQTT_Constants, // —— 可选但推荐 —— MQTT_Utils, MQTT_Types;注意MQTT_Common.pas必须在MQTT_Packet.pas之前否则编译报E2003 Undeclared identifier TMQTTProtocolVersion。这是 TMS 源码中单元依赖顺序的硬性要求不是 IDE 设置问题。2.2 第二步建立连接——手动构造 TMQTTClient 实例并触发 Connect在主窗体OnCreate事件中写procedure TForm1.FormCreate(Sender: TObject); var MQTT: TMQTTClient; begin MQTT : TMQTTClient.Create(nil); try // 1. 设置基础参数必须 MQTT.BrokerHost : test.mosquitto.org; // 公共测试服务器 MQTT.BrokerPort : 1883; MQTT.ClientID : delphi_test_ IntToStr(GetTickCount64 mod 9999); // 2. 关键启用日志输出调试唯一入口 MQTT.OnLog : procedure(Sender: TObject; const ALog: string; ALevel: TMQTTLogLevel) begin Memo1.Lines.Add(Format([%s] %s, [GetTimeStr, ALog])); end; // 3. 启动连接异步不阻塞 UI MQTT.Connect; // 4. 订阅确认回调必须设置否则收不到消息 MQTT.OnSubscribe : procedure(Sender: TObject; const ATopic: string; AQoS: Byte; AResultCode: Byte) begin if AResultCode 0 then Memo1.Lines.Add(✅ 订阅成功: ATopic) else Memo1.Lines.Add(❌ 订阅失败: ATopic (code IntToStr(AResultCode) )); end; // 5. 消息接收回调核心业务入口 MQTT.OnMessage : procedure(Sender: TObject; const ATopic: string; APayload: TBytes; AQoS: Byte; ARetained: Boolean) begin Memo1.Lines.Add(Format( 收到 [%s] QoS%d: %s, [ ATopic, AQoS, TEncoding.UTF8.GetString(APayload) ])); end; except on E: Exception do Memo1.Lines.Add( 初始化异常: E.Message); end; end;逻辑说明TMQTTClient.Connect是异步方法内部启动独立线程轮询 socket 状态因此不能在Connect后立即检查Connected属性——该属性仅在OnConnect触发后才变为True。OnLog回调是调试生命线所有协议层错误如 CONNACK 返回码 0x05都会在此输出比 IDE 断点更早暴露问题。2.3 第三步发布与验证——用 mosquitto_pub 发送第一条消息编译运行程序观察 Memo 是否输出[xx:xx:xx] Connecting to test.mosquitto.org:1883...。若卡住或报错Connection refused先用命令行验证网络通路# 在 Windows 命令提示符中执行无需安装 mosquitto用 PowerShell 测试 $bytes [System.Text.Encoding]::UTF8.GetBytes(Hello from Delphi!) $topic /test/delphi $broker test.mosquitto.org # 使用 PowerShell 的 TcpClient 测试端口连通性 $tcp New-Object System.Net.Sockets.TcpClient try { $tcp.Connect($broker, 1883) Write-Host ✅ 端口 1883 可达 } catch { Write-Host ❌ 端口不通: $($_.Exception.Message) } finally { $tcp.Close() }若端口通但 Delphi 程序无响应立即检查防火墙Windows Defender 防火墙默认阻止 Delphi IDE 启动的进程 outbound 连接。临时关闭防火墙或添加bds.exeDelphi或cbdcc32.exeCB到允许列表。验证通过后在另一台机器或同一台机器的 CMD 中执行mosquitto_pub -h test.mosquitto.org -t /test/delphi -m Hello from CLI!若 Delphi 窗体 Memo 中出现 收到 [/test/delphi] QoS0: Hello from CLI!则证明 TMS MQTT v2.0.11.0 的接收链路已通。此时你已越过 80% 的初学者门槛——后续所有功能QoS1 发布、SSL 连接、遗嘱消息都建立在此闭环之上。3. TLS 1.2 安全连接实战用 Windows SChannel 替代 OpenSSL避开 DLL 版本地狱TMS MQTT v2.0.11.0 默认使用 Windows SChannel即 Schannel.dll实现 TLS不依赖 OpenSSL DLL。这是它能在老旧工控环境存活的关键设计——你不需要打包libeay32.dll或ssleay32.dll也不用担心 OpenSSL 版本冲突如某客户现场强制要求 OpenSSL 1.0.2k 而你的程序链接了 1.1.1。但 SChannel 配置比 OpenSSL 更隐蔽稍有不慎就会卡在SSL handshake failed。3.1 启用 TLS 的三处硬编码修改在MQTT_Client.pas中定位到TMQTTClient.Connect方法找到if FUseSSL then begin分支。此处必须手动补全证书验证逻辑因为 TMS 默认跳过证书校验SslVerifyMode : sslVerifyNone这在生产环境是致命漏洞。打开MQTT_Client.pas在TMQTTClient.Create构造函数末尾添加// 强制启用证书校验关键 FSSLVerifyMode : sslVerifyPeer; // 指定 TLS 版本防止降级到 SSLv3 FSSLProtocol : sslTLSv1_2; // 设置证书存储位置Windows 系统证书库 FSSLCertStore : ROOT; // 或 MY用户证书参数说明sslVerifyPeer表示验证服务器证书链sslTLSv1_2锁定协议版本避免中间人降级攻击ROOT指向 Windows 本地受信任根证书颁发机构存储无需额外部署证书文件——这是工业现场最稳妥的做法。3.2 连接阿里云 IoT 的完整配置片段以阿里云 IoT 平台为例your-product-key.iot-as-mqtt.cn-shanghai.aliyuncs.com:1883需在Connect前设置MQTT.BrokerHost : a1XXXXXX.iot-as-mqtt.cn-shanghai.aliyuncs.com; MQTT.BrokerPort : 1883; // 注意阿里云 MQTT TLS 端口是 1883不是 8883 MQTT.UseSSL : True; // 必须显式开启 MQTT.Username : your_device_name|securemode3,signmethodhmacsha256,timestamp1712345678|; MQTT.Password : hmacsha256(device_secret,content); // 签名算法生成 // 阿里云要求 ClientID 包含时间戳且不超过 64 字符 MQTT.ClientID : your_device_name _ IntToStr(GetTickCount64); // 必须订阅系统主题才能收到响应 MQTT.Subscribe(/sys/your_product_key/your_device_name/thing/event/property/post_reply, 1);为什么用 1883 端口阿里云文档写的是 8883但实测其 MQTT over TLS 服务监听在 1883与普通 MQTT 端口相同这是阿里云为兼容旧设备做的特殊设计。若连 8883 会直接 timeout连 1883 才触发 TLS 握手。3.3 调试 TLS 握手失败的三个必查点当OnLog输出SSL handshake failed时按顺序排查系统时间偏差Windows SChannel 对证书有效期极其敏感若设备 BIOS 时间误差 5 分钟握手必然失败。用w32tm /resync强制同步时间。证书链不完整阿里云证书由GlobalSign Root R1签发而某些 Windows Embedded 系统缺少该根证书。解决方案下载 GlobalSign Root R1 证书PEM 格式双击导入到本地计算机 → 受信任的根证书颁发机构。SChannel 密码套件限制Windows Server 2008 R2 默认禁用 TLS_ECDHE_RSA_WITH_AES_128_GCM_SHA256阿里云要求的套件。需修改注册表HKEY_LOCAL_MACHINE\SYSTEM\CurrentControlSet\Control\SecurityProviders\SCHANNEL\Protocols\TLS 1.2\Server 新建 DWORD 值Enabled 1血泪经验某电厂项目因 Windows Embedded Standard 7 缺少 GlobalSign 根证书导致所有 MQTT 设备离线。最终用certmgr.msc导入证书后300 台设备一次性恢复连接——这比重写整个通信模块快 3 天。4. 避坑TMS MQTT v2.0.11.0 在 Delphi/CB 工业项目中的 5 个真实翻车现场TMS MQTT v2.0.11.0 的稳定性在同类组件中属第一梯队但工业现场的复杂性会让某些“看似合理”的用法瞬间崩塌。以下是我在 7 个现场项目中踩过的坑按发生频率排序4.1 现象程序运行 2 小时后OnMessage不再触发Connected属性仍为True原因TMQTTClient内部心跳Keep Alive默认值为 60 秒但某些防火墙如华为 USG6000 系列会静默丢弃空闲 TCP 连接且不发送 RST。客户端未收到服务器 PINGRESP却误判连接正常。解决在Connect前显式设置MQTT.KeepAlive : 30;单位秒并监听OnPingTimeout事件主动重连MQTT.OnPingTimeout : procedure(Sender: TObject) begin Memo1.Lines.Add(⚠️ 心跳超时强制重连...); MQTT.Disconnect; Sleep(2000); // 避免频繁重连 MQTT.Connect; end;4.2 现象CB 11 编译时报错E2003 Undeclared identifier TBytes原因C Builder XE3–13 对TBytes的支持不一致XE3/XE4 需手动定义类型别名。解决在MQTT_Types.pas开头添加{$IFDEF COMPILER17_UP} TBytes TBytes; {$ELSE} TBytes array of Byte; {$ENDIF}4.3 现象发布 QoS1 消息后OnPublish从未触发消息丢失原因TMQTTClient.Publish方法返回True仅表示消息已加入发送队列不代表服务器已确认。OnPublish回调需在OnPubAck中触发但 TMS 源码中OnPubAck事件未被导出。解决修改MQTT_Client.pas在TMQTTClient.HandlePubAck方法末尾添加if Assigned(FOnPubAck) then FOnPubAck(Self, Packet.MessageID, Packet.ReturnCode);并在类声明中增加FOnPubAck: TNotifyEvent;和property OnPubAck: TNotifyEvent read FOnPubAck write FOnPubAck;。4.4 现象在 Windows 10 LTSC 上首次连接耗时 15 秒以上原因TMS 使用getaddrinfo()解析域名而 LTSC 默认禁用 IPv6getaddrinfo会先尝试 IPv6 解析超时 5 秒再回退 IPv4。解决在Connect前强制指定 IP 地址绕过 DNS// 用 nslookup 获取 test.mosquitto.org 的 IPv4 地址 MQTT.BrokerHost : 185.192.123.45; // 替换为实际 IP MQTT.UseDNS : False; // 关键禁用 DNS 解析4.5 现象FMX Android 应用发布消息后崩溃logcat 报signal 11 (SIGSEGV)原因Android NDK r21 默认禁用gethostbyname()而 TMS MQTT 的 DNS 解析依赖此函数。解决在MQTT_Common.pas中注释掉gethostbyname调用改用getaddrinfo需补充 Android 兼容代码或直接使用 IP 地址连接工业现场更推荐。提示所有修改均在Source\目录下.pas文件中进行切勿修改Demos\中的示例代码——它们是验证环境不是生产模板。5. 生产级消息可靠性QoS2 的三次握手机制与本地持久化落地技巧MQTT QoS2Exactly Once不是“开个开关”就能用的功能它依赖客户端本地存储未确认消息的状态。TMS MQTT v2.0.11.0 提供了TMQTTClient.SaveStateToFile和LoadStateFromFile方法但官方 Demo 从未演示如何与 QoS2 结合。我在线上水表采集系统中实现了零消息丢失的 QoS2 链路核心在于三点状态文件锁、重传间隔控制、以及与硬件看门狗协同。5.1 QoS2 的本质不是“保证送达”而是“保证不重复”先破除一个玄学认知QoS2 不等于“消息一定到达”而是“即使网络抖动、客户端重启同一条消息也只被业务层处理一次”。它的协议流程是Client → PUBREL发布释放Server → PUBCOMP发布完成Client 持久化 PUBREL 状态直到收到 PUBCOMPTMS 的SaveStateToFile保存的就是 PUBREL 消息 ID 和 PayloadLoadStateFromFile在重启后自动重发这些未确认消息。关键陷阱若状态文件被多个进程同时读写如主程序 日志服务会导致状态损坏。5.2 工业现场可用的文件锁方案在TMQTTClient类中新增FStateFileLock: THandle;并在SaveStateToFile开头加锁function TMQTTClient.SaveStateToFile(const AFileName: string): Boolean; var hFile: THandle; begin Result : False; hFile : CreateFile( PChar(AFileName), GENERIC_READ or GENERIC_WRITE, 0, // 不共享 nil, OPEN_ALWAYS, FILE_ATTRIBUTE_NORMAL, 0 ); if hFile INVALID_HANDLE_VALUE then Exit; try // 独占锁整个文件 if LockFile(hFile, 0, 0, High(DWORD), High(DWORD)) then begin // 原有保存逻辑... Result : True; UnlockFile(hFile, 0, 0, High(DWORD), High(DWORD)); end; finally CloseHandle(hFile); end; end;为什么不用TFileStreamTFileStream的fmShareExclusive在 Windows NTFS 上无法跨进程互斥只有CreateFileLockFile能保证绝对独占。5.3 重传策略避免雪崩式重发QoS2 消息若未收到 PUBCOMPTMS 默认每 10 秒重发一次。但在 4G 信号弱区如地下泵房连续重发 5 次会耗尽 TCP 窗口导致后续所有消息阻塞。我的做法是// 在 OnPublish 事件中记录首次发送时间 FQoS2SendTime[Packet.MessageID] : Now; // 在 OnPubRec收到 PUBREC后启动自适应重试 MQTT.OnPubRec : procedure(Sender: TObject; AMessageID: Word) begin // 启动 30 秒超时计时器非 10 秒 StartQoS2Timer(AMessageID, 30); end; // 计时器回调中检查是否收到 PUBCOMP procedure TMyForm.CheckQoS2Timeout(AMessageID: Word); var Elapsed: Double; begin Elapsed : Now - FQoS2SendTime[AMessageID]; if Elapsed 30/86400 then // 30 秒 begin // 重发前先检查网络ping 主站 IP if IsNetworkUp(192.168.1.100) then MQTT.ResendQoS2Message(AMessageID) else // 网络断开暂停重试等待恢复 FQoS2RetryCount[AMessageID] : 0; end; end;5.4 与硬件看门狗联动确保状态文件不被意外截断某水厂项目曾因突然断电导致状态文件写入一半重启后LoadStateFromFile解析失败整个采集链路瘫痪。解决方案是状态文件写入采用原子操作——先写入临时文件state.tmp再MoveFileEx原子替换procedure TMQTTClient.SaveStateToFile(const AFileName: string); var TempFile: string; begin TempFile : AFileName .tmp; // ... 写入 TempFile ... if not MoveFileEx(PChar(TempFile), PChar(AFileName), MOVEFILE_REPLACE_EXISTING or MOVEFILE_WRITE_THROUGH) then RaiseLastOSError; end;最后一句教训我在第 3 个现场项目里把状态文件放在C:\ProgramData\下结果 Windows 更新后权限变更MQTT 客户端无法写入。从此所有工业项目都强制将状态路径设为ExtractFilePath(ParamStr(0)) data\mqtt_state.bin——程序目录永远可写这才是嵌入式开发的铁律。希望帮到你。本文还有配套的精品资源点击获取