//using System;
|
//using MQTTnet.Client;
|
//using MQTTnet;
|
//using MQTTnet.Client.Options;
|
//using System.Net.Sockets;
|
//using System.Threading.Tasks;
|
|
//namespace HDL_ON.DAL.Net
|
//{
|
// public static class Mqtt_A_Protocol
|
// {
|
// /// <summary>
|
// /// MqttClient
|
// /// </summary>
|
// public static IMqttClient mqttClient_A;
|
// public static string mqttClientIP;
|
// public static string mqttGatewayMAC;
|
// static bool remoteIsConnected;
|
|
// static bool onConnection = false;
|
|
// static Mqtt_A_Protocol()
|
// {
|
// InitMqtt();
|
// }
|
|
// /// <summary>
|
// /// 断开远程Mqtt的链接
|
// /// </summary>
|
// public static async Task DisConnectRemoteMqttClient(string s = "")
|
// {
|
// try
|
// {
|
// if (remoteIsConnected)
|
// {
|
// remoteIsConnected = false;
|
// System.Console.WriteLine($"Remote主动断开_{s}");
|
// //await RemoteMqttClient.DisconnectAsync(new MQTTnet.Client.Disconnecting.MqttClientDisconnectOptions { }, CancellationToken.None);
|
// await mqttClient_A.DisconnectAsync();
|
// }
|
// }
|
// catch (Exception e)
|
// {
|
// Console.WriteLine($"Remote断开通讯连接出异常:{e.Message}");
|
// }
|
// }
|
|
// static bool isSubscribeSuccess;
|
// static async Task SubscribeTopics()
|
// {
|
// if (remoteIsConnected && !isSubscribeSuccess)
|
// {
|
// try
|
// {
|
// var Topic1 = $"/BusGateWayToApp/{mqttGatewayMAC}/Common/Json";
|
// try
|
// {
|
// await mqttClient_A.SubscribeAsync(Topic1);
|
// }
|
// catch (Exception ex)
|
// {
|
// await DisConnectRemoteMqttClient(ex.Message);
|
// await StartMqtt();
|
// if (remoteIsConnected)
|
// {
|
// await mqttClient_A.SubscribeAsync(Topic1);
|
// }
|
// }
|
// }
|
// catch { }
|
// }
|
// }
|
|
// static void InitMqtt()
|
// {
|
// new System.Threading.Thread(async () => {
|
// while (true)
|
// {
|
// try
|
// {
|
// System.Threading.Thread.Sleep(1000);
|
// //if (!CommonPage.IsRemote)
|
// // continue;
|
// if (remoteIsConnected)
|
// continue;
|
// await StartMqtt();
|
// await SubscribeTopics();
|
// }
|
// catch { }
|
// }
|
// })
|
// { IsBackground = true }.Start();
|
// }
|
|
// /// <summary>
|
// /// 启动A协议Mqtt
|
// /// </summary>
|
// public static async Task StartMqtt()
|
// {
|
// try
|
// {
|
// if (remoteIsConnected)
|
// return;
|
// if (onConnection)
|
// return;
|
// onConnection = true;
|
// new System.Threading.Thread(async () =>
|
// {
|
// if (remoteIsConnected)
|
// return;
|
// try
|
// {
|
// if (mqttClient_A == null)
|
// {
|
// mqttClient_A = new MqttFactory().CreateMqttClient();
|
// mqttClient_A.UseApplicationMessageReceivedHandler(async e =>
|
// {
|
// var aesDecryptTopic = e.ApplicationMessage.Topic;
|
// var aesDecryptPayload = e.ApplicationMessage.Payload;
|
// MainPage.Log(aesDecryptTopic);
|
// MainPage.Log($"Des Topic={aesDecryptTopic}");
|
// });
|
|
// mqttClient_A.UseConnectedHandler(async (e) => {
|
// MainPage.Log("mqtt connected !!");
|
// onConnection = false;
|
// });
|
// }
|
// try
|
// {
|
// int readCount = 0;
|
// BusSocket.Stop();
|
// System.Threading.Thread.Sleep(1000);
|
// BusSocket.Start(6688);
|
// System.Threading.Thread.Sleep(1000);
|
// Control.ReadGatewayIPAddress();
|
// while (true)
|
// {
|
// if (!string.IsNullOrEmpty(mqttClientIP))
|
// {
|
// break;
|
// }
|
// else if (readCount > 10)
|
// {
|
// onConnection = false;
|
// return;
|
// }
|
// else
|
// {
|
// Control.ReadGatewayIPAddress();
|
// System.Threading.Thread.Sleep(200);
|
// }
|
// }
|
// BusSocket.Stop();
|
// System.Threading.Thread.Sleep(1000);
|
// BusSocket.Start(6000);
|
// System.Threading.Thread.Sleep(1000);
|
|
// var options = new MqttClientOptionsBuilder()//MQTT连接参数填充
|
// .WithClientId(Guid.NewGuid().ToString().Substring(0, 5))//客户端ID
|
// .WithTcpServer(mqttClientIP, 1883)//MQTTServerIP.Text, Int32.Parse(MQTTServerPort.Text.ToString()))//TCP服务端 1883 ，即MQTT服务端
|
// .WithCredentials("", "")//"", "")//凭证 帐号 密码
|
// .WithCommunicationTimeout(new TimeSpan(0, 0, 60)) //重连超时时间，默认5s
|
// .WithKeepAlivePeriod(new TimeSpan(0, 0, 15)) //保持连接时间，默认5s，心跳包
|
// .Build();
|
// await mqttClient_A.ConnectAsync(options);
|
// remoteIsConnected = true;
|
// }
|
// catch { }
|
// }
|
// catch (Exception ex)
|
// {
|
// }
|
// finally
|
// {
|
// onConnection = false;
|
// }
|
// })
|
// { IsBackground = true }.Start();
|
// }
|
// catch (Exception ex)
|
// {
|
// MainPage.Log("============>" + ex.Message);
|
// }
|
// }
|
|
|
|
|
// /// <summary>
|
// ///
|
// /// </summary>
|
// /// <param name="message">附加数据包</param>
|
// /// <param name="optionType">操作类型：0=网关控制；1=订阅网关数据;2=订阅网关上线数据</param>
|
// /// <returns></returns>
|
// public static async Task MqttRemoteSend(byte[] message)
|
// {
|
// try
|
// {
|
// if (mqttClient_A == null || !mqttClient_A.IsConnected)
|
// {
|
// await StartMqtt();
|
// }
|
// if (!mqttClient_A.IsConnected)
|
// {
|
// return;
|
// }
|
// var topicName = $"/AppToBusGateWay/{mqttGatewayMAC}/Common/Json";
|
// var m = new MqttApplicationMessage { Topic = topicName, Payload = message, Retain = false, QualityOfServiceLevel = MQTTnet.Protocol.MqttQualityOfServiceLevel.ExactlyOnce };
|
// await mqttClient_A?.PublishAsync(m);
|
// }
|
// catch (Exception e)
|
// {
|
// }
|
// }
|
// }
|
//}
|
