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