在C#中使用MQTT服务器监听客户端在线与离线状态

2024-02-19 17:38:14

准备工作

在开始之前，您需要确保已安装以下软件：

Visual Studio 2019或更高版本
MQTT.NET库
MQTT客户端（如MQTT.fx）

创建MQTT服务器

打开Visual Studio，创建一个新的C#控制台应用程序项目。
在项目中安装MQTT.NET库。
在项目中添加以下代码：

using MQTTnet;
using MQTTnet.Server;
using System;

namespace MqttServer
{
    class Program
    {
        static void Main(string[] args)
        {
            // 创建MQTT服务器
            var server = new MqttServerFactory().CreateMqttServer();

            // 设置服务器监听端口
            server.StartAsync(new MqttServerOptionsBuilder().WithDefaultEndpointPort(1883).Build());

            // 等待服务器启动
            Console.WriteLine("MQTT服务器已启动，按任意键退出...");
            Console.ReadKey();

            // 停止服务器
            server.StopAsync();
        }
    }
}

运行MQTT服务器

运行MQTT服务器项目。
打开MQTT客户端（如MQTT.fx）。
在客户端中连接到MQTT服务器。

监听客户端在线与离线状态

在MQTT服务器中，您可以使用以下代码来监听客户端的在线和离线状态：

server.ClientConnected += (s, e) =>
{
    Console.WriteLine($"客户端已连接：{e.ClientId}");
};

server.ClientDisconnected += (s, e) =>
{
    Console.WriteLine($"客户端已断开连接：{e.ClientId}");
};