在C#中创建自定义端口MQTT Broker启动失败问题排查

问题场景 #

• 系统环境：Windows 11、.NET 6.0、MQTTnet 4.2.1.781，同时安装了mosquitto 2.0.15
• 需求：基于MQTTnet创建使用1884端口的MQTT Broker
• 现象：Broker启动失败，已确认端口1884未被任何程序占用、防火墙已关闭
• 相关代码：

class Program
{
    static async Task Main(string[] args)
    {
        // Create and configure the MQTT broker
        var optionsBuilder = new MqttServerOptionsBuilder()
            .WithDefaultEndpointPort(1884);
        var mqttServer = new MqttFactory().CreateMqttServer(optionsBuilder.Build());
        try
        {
            await mqttServer.StartAsync();
        }
        catch (Exception)
        {
            throw;
        }
        await Task.Delay(10000);
        Console.WriteLine("MQTT broker started on port 1884.");

        // Create a client to subscribe to a topic
        var subscriberClient = new MqttFactory().CreateMqttClient();
        var subscriberOptions = new MqttClientOptionsBuilder()
            .WithClientId("SubscriberClient")
            .WithTcpServer("localhost", 1884)
            .Build();
        await subscriberClient.ConnectAsync(subscriberOptions);
        await subscriberClient.SubscribeAsync(new MqttTopicFilterBuilder()
            .WithTopic("$SYS/broker/clients/active")
            .Build());
        subscriberClient.ApplicationMessageReceivedAsync += async e =>
        {
            var payload = Encoding.UTF8.GetString(e.ApplicationMessage.Payload);
            Console.WriteLine($"Received message: {payload}");
        };

        // Create a client to publish messages to the topic
        var publisherClient = new MqttFactory().CreateMqttClient();
        var publisherOptions = new MqttClientOptionsBuilder()
            .WithClientId("PublisherClient")
            .WithTcpServer("localhost", 1884)
            .Build();
        await publisherClient.ConnectAsync(publisherOptions);

        Console.WriteLine("Publisher client connected.");

        // Publish messages to the topic
        for (int i = 0; i < 5; i++)
        {
            var message = new MqttApplicationMessageBuilder()
                .WithTopic("mytopic")
                .WithPayload(Encoding.UTF8.GetBytes($"Message {i}"))
                .Build();
            await publisherClient.PublishAsync(message);

            Console.WriteLine($"Published message {i} to 'mytopic'.");
            await Task.Delay(1000);
        }

        // Stop the broker
        await mqttServer.StopAsync();

        Console.WriteLine("MQTT broker stopped.");
    }
}

可能的排查方向 #

• 捕获具体异常信息：原代码的catch块直接抛出异常未输出详情，修改后可定位根本原因：

  try
  {
      await mqttServer.StartAsync();
  }
  catch (Exception ex)
  {
      Console.WriteLine($"Broker启动失败：{ex.Message}\n{ex.StackTrace}");
      throw;
  }
  

• 完善服务器配置：仅指定端口可能存在监听范围限制，添加IP绑定确保监听所有网卡：

  var optionsBuilder = new MqttServerOptionsBuilder()
      .WithDefaultEndpointPort(1884)
      .WithDefaultEndpointBoundIPAddress(IPAddress.Any);
  

• 检查mosquitto服务冲突：虽然使用MQTTnet自建Broker，但运行中的mosquitto服务可能引发隐性资源冲突，尝试暂时停止mosquitto服务后重试
• 管理员权限运行：Windows下绑定部分端口需要管理员权限，右键程序选择“以管理员身份运行”测试
• 版本兼容性验证：确认MQTTnet 4.2.1.781与.NET 6的兼容性，或尝试升级至MQTTnet最新稳定版

编辑：我已找到其他解决方法，不再跟进此问题。

内容的提问来源于stack exchange，提问作者Berusella