1

我正在做 POC，所以这里是快速而肮脏的代码。我使用 MQTT.fx 桌面客户端来测试 Pub/Sub 到我的 MQTT 服务器。工作正常。我可以发布/订阅我的主题。我可以从另一个 mqtt 客户端发布并收到消息。使用此代码时，当我从 MQTT.fx 或任何其他发布者发布消息时，我没有收到任何信息。如果我使用 mqttClient 发布（如果您取消注释该行），我会收到一些东西。我在挠头......有人可以帮忙吗？谢谢。

class Program
{
    private static CancellationTokenSource cts = new CancellationTokenSource(); //TODO create token using the Timeout delay from config
    private static async Task Main(string[] args)
    {
        var factory = new MqttFactory();
        var mqttClient = factory.CreateMqttClient();
        var options = new MqttClientOptionsBuilder()
            .WithClientId("MyClientIDHere")
            .WithTcpServer("IPAddressHere", 1883)
            //.WithCredentials("Wbo", string.Empty)
            //.WithTls()
            .WithCleanSession()
            .Build();
        try
        {
            mqttClient.UseApplicationMessageReceivedHandler(async e =>
            {
                Console.WriteLine("### RECEIVED APPLICATION MESSAGE ###");
                Console.WriteLine($"+ Topic = {e.ApplicationMessage.Topic}");
                Console.WriteLine($"+ Payload = {Encoding.UTF8.GetString(e.ApplicationMessage.Payload)}");
                Console.WriteLine($"+ QoS = {e.ApplicationMessage.QualityOfServiceLevel}");
                Console.WriteLine($"+ Retain = {e.ApplicationMessage.Retain}");
                Console.WriteLine();
            });
            mqttClient.UseConnectedHandler(async e =>
            {
                Console.WriteLine("### CONNECTED WITH SERVER ###");

                // Subscribe to a topic
                await mqttClient.SubscribeAsync(new TopicFilterBuilder().WithTopic("MyClientIDHere/Device_2/Instance_1").Build());

                Console.WriteLine("### SUBSCRIBED ###");
            });
            await mqttClient.ConnectAsync(options, cts.Token);
           // UNCOMMENT AND YOU WILL RECEIVE A MESSAGE Task.Run(() => mqttClient.PublishAsync("MyClientIDHere/Device_2/Instance_1","met=Temperature~data=29"));

        }

        catch (OperationCanceledException)
        {
            Console.WriteLine("task cancelled");   
        }
        catch (Exception e)
        {
            Console.WriteLine(e);
        }

        Console.ReadKey();
    }
}
4

1 回答 1

1

使用最新版本的 MQTTnet 我无法重现您的问题，它似乎在这里工作。我正在使用 mosquitto MQTT 服务器，该服务器位于另一台服务器上，而不是我运行程序的位置。

你的代码看起来不错。您可以通过在连接之前订阅主题来改进一些。

于 2021-03-09T09:15:25.383 回答