MQTT服务端

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