基本信息

---

下载

   友情提示：（无需注册或充值，赞助后即可获取资源下载链接）

---

     嘿，亲！知识可是无价之宝呢，但咱这精心整理的资料也耗费了不少心血呀。小小地破费一下，绝对物超所值哦！如有下载和支付问题，请联系我们QQ(微信同号)：813200300

本次赞助数额为： 2 元　

支付宝支付

微信支付

   源码介绍

---

private static IMqttServer server;
//根据Key读取<add>元素的Value
private static string hostIP = ConfigurationManager.AppSettings["hostIP"];
private static int hostPort = Convert.ToInt32(ConfigurationManager.AppSettings["hostPort"]);
private static int timeout = Convert.ToInt32(ConfigurationManager.AppSettings["timeout"]);
private static string username = ConfigurationManager.AppSettings["username"];
private static string password = ConfigurationManager.AppSettings["password"];
private static double ov = 0, rv;
static void Main(string[] args)
{
    var optionBuilder = new MqttServerOptionsBuilder().WithDefaultEndpointBoundIPAddress(System.Net.IPAddress.Parse(hostIP)).WithDefaultEndpointPort(hostPort).WithDefaultCommunicationTimeout(TimeSpan.FromMilliseconds(timeout)).WithConnectionValidator(t =>
        {
        if (t.Username != username || t.Password != password)
        {
            t.ReturnCode = MqttConnectReturnCode.ConnectionRefusedBadUsernameOrPassword;
        }
        t.ReturnCode = MqttConnectReturnCode.ConnectionAccepted;
        });
    var option = optionBuilder.Build();

    server = new MqttFactory().CreateMqttServer();
    server.ApplicationMessageReceived = Server_ApplicationMessageReceived;//绑定消息接收事件
    server.ClientConnected = Server_ClientConnected;//绑定客户端连接事件
    server.ClientDisconnected = Server_ClientDisconnected;//绑定客户端断开事件
    server.ClientSubscribedTopic = Server_ClientSubscribedTopic;//绑定客户端订阅主题事件
    server.ClientUnsubscribedTopic = Server_ClientUnsubscribedTopic;//绑定客户端退订主题事件
    server.Started = Server_Started;//绑定服务端启动事件
    server.Stopped = Server_Stopped;//绑定服务端停止事件
    try
    {
        //启动
        server.StartAsync(option);

    }
    catch
    {
        Console.WriteLine("服务启动异常，请检查网络或者IP准确性！");
    }
    Console.ReadKey();
}