无法使用 MQTTNet 库 .net 核心与代理连接

Question

我需要帮助，我无法联系到经纪人。我在我的 api 项目 .net 核心中使用 MQTTNet 库这是我的代码：

// GET: api/<SendCommandController>
[HttpGet]
public void Get()
{

    var options = new MqttClientOptionsBuilder()
    .WithTcpServer("broker.hivemq.com", 1883)
    .Build();

    var factory = new MqttFactory();
    var mqttClient = factory.CreateMqttClient();

    mqttClient.ConnectAsync(options, CancellationToken.None);

    var message = new MqttApplicationMessageBuilder()
    .WithTopic("Test/Mqtt")
    .WithPayload("Hello World")
    .WithExactlyOnceQoS()
    .WithRetainFlag()
    .Build();

    mqttClient.PublishAsync(message, CancellationToken.None); 
}

所以我按照教程进行操作，但无法连接到代理 hivemq，也无法连接到我的个人代理。因此，我使用 mqtt.fx 测试了 hivemq 代理并且可以正常工作。仅在代码中 return 已连接 = false.

有什么想法吗？错误是“客户端未连接”

Answer 1

C# 不是我经常使用的语言，但我假设您在 mqttClient.ConnectAsync(options, CancellationToken.None); 之前缺少 await，因此其余代码在尝试连接之前等待连接完成发送消息

无法使用 MQTTNet 库 .net 核心与代理连接

Not able to connect with broker using MQTTNet library .net core

c#

mqtt

.net-core

mqttnet