我正在使用 MQTTNet,这是一个 .NET 库,用于基于以下链接的 MQTT 通信
https://github.com/chkr1011/MQTTnet
我正在使用managed MQTT Client下面的链接
https://github.com/chkr1011/MQTTnet/wiki/ManagedClient
我有以下代码来publish发送消息MQTT server。
var messagePayload = new MqttApplicationMessageBuilder()
.WithTopic("Topic1")
.WithPayload(message)
.WithExactlyOnceQoS()
.WithRetainFlag()
.Build();
try
{
await mqttClient.PublishAsync(messagePayload);
}
catch (Exception ex)
{
//Why I am not getting exception?
}
Run Code Online (Sandbox Code Playgroud)
此行为是 MQTT 托管客户端设计的。它使用内部队列。所有发布的消息都会添加到此队列中,然后在服务器可用时发送到服务器。它还确保消息不会丢失,并且即使应用程序重新启动也可以重新发送。引用自项目 wiki。
所有 MQTT 应用程序消息都会添加到内部队列中,并在服务器可用时进行处理。可以存储所有 MQTT 应用程序消息,以支持在应用程序重新启动后发送它们
| 归档时间: |
|
| 查看次数: |
2660 次 |
| 最近记录: |