Delphi TMSMQTT使用笔记

泥蛋發表於 2024-5-19 00:44:00

服务端用的是 mosquitto ，下载地址https://mosquitto.org/download/
安装完成后需要配置
找到安装目录：mosquitto.conf，打开后修改 allow_anonymous false（禁止匿名登录），password_file D:\Program Files\mosquitto\pwfile.example（密码存放位置）
创建新用户，安装目录下执行 mosquitto_passwd -c pwfile.example 用户名1 然后输入密码
主要记录Delphi开发过程，mosquitto 具体使用及配置自行百度
界面布局如下
<img src="https://img2024.cnblogs.com/blog/911540/202405/911540-20240519005612137-1519754410.png" alt="" loading="lazy">
 
当使用 TMSMQTTClient1 组件进行 MQTT 通信时，常用属性的详细设置如下：
<ul>
<li>BrokerHostName：设置为 MQTT 服务器的主机名或 IP 地址，例如 "mqtt.example.com"。</li>
<li>BrokerPort：设置为 MQTT 服务器的端口号，通常默认为 1883 或 8883（如果使用了 SSL 加密）。</li>
<li>Credentials.Username：设置为连接 MQTT 服务器所需的用户名。如果服务器不需要用户名认证，可以将其留空。</li>
<li>Credentials.Password：设置为连接 MQTT 服务器所需的密码。如果服务器不需要密码认证，可以将其留空。</li>
<li>ClientID：设置为客户端的唯一标识符，通常可以使用设备的序列号或其他唯一标识符。</li>
<li>LastWillSettings.QoS：设置遗嘱消息的服务质量等级，可选择 qosAtLeastOnce、qosAtMostOnce 或 qosExactlyOnce，取决于消息的重要性和可靠性要求。</li>
<li>LastWillSettings.Retain：设置为 true 或 false，指定是否将遗嘱消息保留在服务器上，以便订阅者在客户端断开连接后收到该消息。</li>
<li>KeepAliveInterval：设置客户端与服务器之间的通信心跳间隔时间，通常以秒为单位，例如 60 表示每 60 秒发送一次心跳。</li>
<li>CleanSession：设置为 true 或 false，指示服务器在客户端断开连接时是否清除会话信息。一般情况下，如果设置为 false，服务器会保存客户端的会话信息，以便客户端重新连接后可以恢复之前的订阅状态和会话信息。</li>
<li>OnConnect：设置连接成功时触发的事件处理程序，可以在此事件中执行连接后的操作。</li>
<li>OnDisconnect：设置断开连接时触发的事件处理程序，可以在此事件中处理连接断开后的清理工作。</li>
<li>OnMessage：设置接收到消息时触发的事件处理程序，可以在此事件中处理接收到的 MQTT 消息。</li>
</ul>
TMSMQTTLogger1可以用于记录以下内容：
<ul>
<li>连接建立和断开的事件；</li>
<li>客户端订阅和取消订阅主题的操作；</li>
<li>接收到的消息内容；</li>
<li>发布消息的操作；</li>
<li>错误和异常信息的记录。</li>
</ul>
连接按钮事件如下，详情见中文注释
<div class="cnblogs_code">
<pre>// 设置MQTT服务器主机名和端口
TMSMQTTClient1.BrokerHostName := Edit1.Text;
TMSMQTTClient1.BrokerPort := StrToInt(Edit2.Text);

// 设置用户名和密码
TMSMQTTClient1.Credentials.Username := Edit3.Text;
TMSMQTTClient1.Credentials.Password := Edit4.Text;

// 设置客户端ID
TMSMQTTClient1.ClientID := Edit5.Text;

// 设置遗嘱消息的服务质量等级
if ComboBox1.Text = 'qosAtLeastOnce' then
TMSMQTTClient1.LastWillSettings.QoS := qosAtLeastOnce
else if ComboBox1.Text = 'qosAtMostOnce' then
TMSMQTTClient1.LastWillSettings.QoS := qosAtMostOnce
else if ComboBox1.Text = 'qosExactlyOnce' then
TMSMQTTClient1.LastWillSettings.QoS := qosExactlyOnce
else if ComboBox1.Text = 'qosRESERVED' then
TMSMQTTClient1.LastWillSettings.QoS := qosRESERVED;

// 设置遗嘱消息的保留标志
TMSMQTTClient1.LastWillSettings.Retain := CheckBox1.Checked;

// 连接到MQTT服务器
TMSMQTTClient1.Connect();</pre>
</div>
连接后只有订阅相同Topic的才能收到内容，所以连接后需要先订阅，订阅按钮如下
<div class="cnblogs_code">
<pre>TMSMQTTClient1.Subscribe(edit7.Text);</pre>
</div>
状态改变后显示目前连接状态
<div class="cnblogs_code">
<pre>procedure TMQTTClient.TMSMQTTClient1ConnectedStatusChanged(ASender: TObject; const AConnected: Boolean; AStatus: TTMSMQTTConnectionStatus);
begin
case AStatus of
csConnectionLost:
 Memo3.Lines.Add('连接丢失');
csAuthenticating:
 Memo3.Lines.Add('正在进行身份验证');
csConnecting:
 Memo3.Lines.Add('连接中');
csConnected:
 Memo3.Lines.Add('已连接');
csNotConnected:
 Memo3.Lines.Add('未连接状态');
csReconnecting:
 Memo3.Lines.Add('重新连接中');
csDisconnecting:
 Memo3.Lines.Add('断开连接中');
end;
end;</pre>
</div>
具体状态内容如下
<div class="cnblogs_code">
<pre>csNotConnected：未连接状态
csConnectionRejected_InvalidProtocolVersion：连接被拒绝，协议版本无效
csConnectionRejected_InvalidIdentifier：连接被拒绝，标识符无效
csConnectionRejected_ServerUnavailable：连接被拒绝，服务器不可用
csConnectionRejected_InvalidCredentials：连接被拒绝，凭据无效
csConnectionRejected_ClientNotAuthorized：连接被拒绝，客户端未授权
csConnectionRejected_UnspecifiedError：连接被拒绝，未指定的错误
csConnectionRejected_MalformedPacket：连接被拒绝，数据包格式错误
csConnectionRejected_ProtocolError：连接被拒绝，协议错误
csConnectionRejected_ImplementationSpecificError：连接被拒绝，特定实现的错误
csConnectionRejected_ServerBusy：连接被拒绝，服务器繁忙
csConnectionRejected_Banned：连接被拒绝，被禁止
csConnectionRejected_BadAuthenticationMethod：连接被拒绝，身份验证方法错误
csConnectionRejected_TopicNameInvalid：连接被拒绝，主题名无效
csConnectionRejected_PacketTooLarge：连接被拒绝，数据包太大
csConnectionRejected_QuotaExceeded：连接被拒绝，超出配额
csConnectionRejected_PayloadFormatInvalid：连接被拒绝，负载格式无效
csConnectionRejected_RetainNotSupported：连接被拒绝，不支持retain
csConnectionRejected_QoSNotSupported：连接被拒绝，不支持QoS
csConnectionRejected_UseAnotherServer：连接被拒绝，使用其他服务器
csConnectionRejected_ServerMoved：连接被拒绝，服务器已移动
csConnectionRejected_ConnectionRateExceeded：连接被拒绝，连接速率超过限制
csConnectionLost：连接丢失
csAuthenticating：正在进行身份验证
csConnecting：连接中
csReconnecting：重新连接中
csConnected：已连接
csDisconnecting：断开连接中</pre>
</div>
发布消息代码如下
<div class="cnblogs_code">
<pre>TMSMQTTClient1.Publish(Edit6.Text, Memo1.Text);</pre>
</div>
订阅后收到的消息，在onPublishReceived事件中，可以根据收到的消息内容做自己想做的事，代码如下
<div class="cnblogs_code">
<pre>procedure TMQTTClient.TMSMQTTClient1PublishReceived(ASender: TObject; APacketID: Word; ATopic: string; APayload: TBytes);
begin
Memo3.Lines.Add('PublishReceived：' + TEncoding.UTF8.GetString(APayload));
if TEncoding.UTF8.GetString(APayload) = 'Hello' then
Memo3.Lines.Add('Say hello to you in the opposite direction！');
if TEncoding.UTF8.GetString(APayload) = '你好' then
Memo3.Lines.Add('对方向你问好！');
end;</pre>
</div>
记录TMSMQTTClient状态事件在TMSMQTTLogger1的onLog中，代码如下
<div class="cnblogs_code">
<pre>procedure TMQTTClient.TMSMQTTLogger1Log(Sender: TObject; ALevel: TTMSMQTTLogLevel; AMessage: string);
begin
Memo3.Lines.Add(AMessage);
end;</pre>
</div>
界面效果如下
<img src="https://img2024.cnblogs.com/blog/911540/202405/911540-20240519005525518-1879459064.png" alt="" loading="lazy">
 

</div>
<div id="MySignature" role="contentinfo">
本文来自博客园，作者：liessay，转载请注明原文链接：https://www.cnblogs.com/liessay/p/18199981 
来源：https://www.cnblogs.com/liessay/p/18199981

頁: [1]

琼殿技术论坛's Archiver

Delphi TMSMQTT使用笔记