WEP_V2.1.3/SourceCode/We.Zero/IwbYue.Zero/M2MClient/IwbM2MsgClient.cs


using System;
using System.Web.WebPages;
using Abp.UI;
using uPLibrary.Networking.M2Mqtt;

namespace IwbZero.M2MClient
{
    public class IwbM2MsgClient
    {
        private uPLibrary.Networking.M2Mqtt.MqttClient Client { get; set; }
        private int ConnectedCount { get; set; }
        private readonly object _lock = new object();
        private int HasReconnectCount { get; set; }
        public string ServerIp { get; set; }
        public int ServerPort { get; set; }
        public string ClientId { get; set; }
        public string ServerUserId { get; set; }
        public string ServerPassword { get; set; }

        public bool NotValidate => (ServerIp.IsEmpty() || ServerPort == 0 || ServerIp.IsEmpty() ||
                                    ClientId.IsEmpty() || ServerUserId.IsEmpty() || ServerPassword.IsEmpty());

        public void SetOptions(string serverIp, int serverPort, string clientId, string serverUserId, string serverPassword)
        {
            ServerIp = serverIp;
            ServerPort = serverPort;
            ClientId = clientId;
            ServerUserId = serverUserId;
            ServerPassword = serverPassword;
        }
        private void CreateClient()
        {
            if (NotValidate)
            {
                throw new UserFriendlyException("客户端配置参数不合法，请检查后再试！");
            }

            var client = new uPLibrary.Networking.M2Mqtt.MqttClient(ServerIp, ServerPort, false, null, null, MqttSslProtocols.None);

        }


    }
}