MQTTNet监听主题消息

Question

我正在将MQTT集成到我们现有的应用程序中，我已经使用这个https://github.com/chkr1011/MQTTnet库来运行嵌入式MQTT代理。

目前启动broker的方式如下：

public async Task StarBrokerAsync()
{
    var optionsBuilder = new MqttServerOptionsBuilder()
        .WithConnectionBacklog(ConnectionBacklog)
        .WithDefaultEndpointPort(Port);

    MqttServer = new MqttFactory().CreateMqttServer();
    await MqttServer.StartAsync(optionsBuilder.Build());
 }

我想要的是监听特定主题中的消息，而不需要创建单独的客户端。我还没有找到该库的文档或任何类似的问题。

这个问题有什么解决方案吗？

Answer 1

mqttServer.UseApplicationMessageReceivedHandler(e =>
            {
                try
                {
                    string topic = e.ApplicationMessage.Topic;
                    if (string.IsNullOrWhiteSpace(topic) == false)
                    {
                        string payload = Encoding.UTF8.GetString(e.ApplicationMessage.Payload);
                        Console.WriteLine($"Topic: {topic}. Message Received: {payload}");
                    }
                }
                catch (Exception ex)
                {
                    Console.WriteLine(ex.Message, ex);
                }
            });