c# - MQTTNet 监听主题消息

Question

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

目前使用以下方法来启动代理:

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);
                }
            });