c# mqtt服务器

using System;
using MQTTnet;
using MQTTnet.Server;

class Program
{
    static async System.Threading.Tasks.Task Main(string[] args)
    {
        // 创建MQTT服务器选项
        var mqttFactory = new MqttFactory();
        var mqttServer = mqttFactory.CreateMqttServer();

        // 配置服务器选项
        var optionsBuilder = new MqttServerOptionsBuilder()
            .WithDefaultEndpointPort(1883) // 设置默认端口为1883
            .WithConnectionValidator(context =>
            {
                Console.WriteLine($"客户端连接: {context.ClientId}");
                context.ReasonCode = MQTTnet.Protocol.MqttConnectReasonCode.Success;
            })
            .WithApplicationMessageInterceptor(context =>
            {
                Console.WriteLine($"收到消息: Topic={context.ApplicationMessage.Topic}, Payload={System.Text.Encoding.UTF8.GetString(context.ApplicationMessage.Payload)}");
            });

        // 启动MQTT服务器
        await mqttServer.StartAsync(optionsBuilder.Build());

        Console.WriteLine("MQTT服务器已启动，按任意键停止...");
        Console.ReadKey();

        // 停止MQTT服务器
        await mqttServer.StopAsync();
    }
}

代码解释说明：

1. 创建MQTT服务器实例：使用MqttFactory创建一个MQTT服务器实例。
2. 配置服务器选项：通过MqttServerOptionsBuilder配置服务器的各种选项，例如端口号、连接验证器和消息拦截器。
3. 启动服务器：调用StartAsync方法启动MQTT服务器，并监听指定的端口（默认1883）。
4. 处理客户端连接和消息：通过连接验证器和消息拦截器处理客户端连接请求和接收到的消息。
5. 停止服务器：当用户按下任意键时，调用StopAsync方法停止服务器。