42-CATL-DianChiXian-SCADA_CATL/DT_SCADA/Core/Remote.Send.cs

using HslCommunication;
using HslCommunication.Core.Net;
using HslCommunication.Enthernet;
using MQTTnet;
using MQTTnet.Client.Connecting;
using MQTTnet.Client.Disconnecting;
using MQTTnet.Client.Options;
using MQTTnet.Client.Receiving;
using MQTTnet.Extensions.ManagedClient;
using MQTTnet.Formatter;
using System;
using System.Collections.Generic;
using System.Drawing;
using System.Linq;
using System.Net;
using System.Text;
using System.Text.RegularExpressions;
using System.Threading;
using System.Threading.Tasks;

/// <summary>
/// 
/// </summary>
namespace MesWork
{
    /// <summary>
    /// 
    /// </summary>
    public partial class Temp { }
    /// <summary>
    /// 
    /// </summary>
    public partial class MesWorkForm
    {
        /// <summary>
        /// 
        /// </summary>
        public static NetComplexClient complexClient = null;
        /// <summary>
        /// 
        /// </summary>
        static private IManagedMqttClient mqttClient = null;
        /// <summary>
        /// 
        /// </summary>
        string topic = "";
        /// <summary>
        /// 
        /// </summary>
        static bool OnLine_Mqtt = false;
        /// <summary>
        /// 
        /// </summary>
        /// <param name="uri"></param>
        /// <returns></returns>
        public async Task StartAsync(string uri)
        {
            var array = uri.Split(new char[] { ':', ',' });
            string mqttUser = array[2];
            string mqttPassword = "";
            var options = new MqttClientOptions
            {
                ClientId = $"{mqttUser}_{Guid.NewGuid().ToString()}",
                ProtocolVersion = MqttProtocolVersion.V311,
                ChannelOptions = new MqttClientTcpOptions { Server = array[0], Port = Convert.ToInt32(array[1]) },
                CleanSession = true,
                KeepAlivePeriod = TimeSpan.FromSeconds(15),
                Credentials = new MqttClientCredentials
                {
                    Username = mqttUser,
                    Password = Encoding.UTF8.GetBytes(mqttPassword)
                }
            };
            mqttClient = new MqttFactory().CreateManagedMqttClient();
            mqttClient.ConnectedHandler = new MqttClientConnectedHandlerDelegate(OnSubscriberConnected);
            mqttClient.DisconnectedHandler = new MqttClientDisconnectedHandlerDelegate(OnSubscriberDisconnected);
            mqttClient.ApplicationMessageReceivedHandler = new MqttApplicationMessageReceivedHandlerDelegate(OnSubscriberMessageReceived);
            await mqttClient.StartAsync(new ManagedMqttClientOptions { ClientOptions = options });
            this.topic = array[2];
            await mqttClient.SubscribeAsync(new MqttTopicFilter { Topic = topic });

        }
        /// <summary>
        /// 
        /// </summary>
        /// <param name="MesServer_IpPortName"></param>
        private void ClientConnection(string MesServer_IpPortName)
        {
            string serverIP = MesServer_IpPortName.Split(':')[0];
            string portString = MesServer_IpPortName.Split(':')[1].Split(',')[0];
            string opNameSocket = MesServer_IpPortName.Split(',')[1];

            if (!IPAddress.TryParse(serverIP, out IPAddress address))
            {
                return;
            }

            if (!int.TryParse(portString, out int port))
            {
                return;
            }

            try
            {
                // 连接 connect
                complexClient = new NetComplexClient();
                complexClient.ClientAlias = opNameSocket;
                complexClient.EndPointServer = new IPEndPoint(address, port);
                //complexClient.Token = new Guid(textBox3.Text);
                complexClient.AcceptString += ComplexClient_AcceptString;
                complexClient.MessageAlerts += ComplexClient_MessageAlerts;
                complexClient.ClientStart();
            }
            catch (Exception ex)
            {
                HslCommunication.BasicFramework.SoftBasic.ShowExceptionMessage(ex);
            }
        }
        /// <summary>
        /// 
        /// </summary>
        /// <param name="publish_topic"></param>
        /// <param name="publish_msg"></param>
        /// <returns></returns>
        private static async Task Publish(string publish_topic, string publish_msg)
        {
            if (mqttClient != null)
            {
                await mqttClient.PublishAsync(new MqttApplicationMessageBuilder().WithTopic(publish_topic).WithPayload(publish_msg).WithAtMostOnceQoS().Build());
            }
        }
        /// <summary>
        /// 
        /// </summary>
        /// <returns></returns>
        private async Task DisConnectService()
        {
            if (mqttClient != null)
            {
                await mqttClient.UnsubscribeAsync(new string[] { topic });
                await mqttClient.StopAsync();
            }
        }

        /// <summary>
        /// 
        /// </summary>
        /// <param name="text"></param>
        private void ComplexClient_MessageAlerts(string text)
        {
            //if (InvokeRequired)
            //{
            //    Invoke(new Action<string>(ComplexClient_MessageAlerts), text);
            //    return;
            //}

        }
        /// <summary>
        /// 连接完成
        /// </summary>
        /// <param name="x"></param>
        private void OnSubscriberConnected(MqttClientConnectedEventArgs x)
        {
            OnLine_Mqtt = true;
            //  textBox1_robotData.Text += "连接完成" + "\r\n";
            var rec = x.AuthenticateResult.ResultCode.ToString();
            // label_State.Text = rec;
           // textBox1_robotData.Text += rec + "\r\n";
        }
        /// <summary>
        /// 断开连接
        /// </summary>
        /// <param name="x"></param>
        private void OnSubscriberDisconnected(MqttClientDisconnectedEventArgs x)
        {
            OnLine_Mqtt = false;
            try
            {
               // textBox1_robotData.Text += "断开连接" + "\r\n";

                var rec = x.ClientWasConnected.ToString();
               // textBox1_robotData.Text += rec + "\r\n";
            }
            catch (Exception err)
            {
               // textBox1_robotData.Text += $"Message:{err.Message}\r\n\r\nStackTrace:{err.StackTrace}" + "\r\n";
            }

        }
        /// <summary>
        /// 接收信息
        /// </summary>
        /// <param name="x"></param>
        private void OnSubscriberMessageReceived(MqttApplicationMessageReceivedEventArgs x)
        {
            var recStr = x.ApplicationMessage.ConvertPayloadToString();
            ThreadPool.QueueUserWorkItem(LoadClientInfo, recStr);
        }
        /// <summary>
        /// 接收消息
        /// </summary>
        /// <param name="arg1"></param>
        /// <param name="arg2"></param>
        /// <param name="arg3"></param>
        private void ComplexClient_AcceptString(AppSession arg1, NetHandle arg2, string arg3)
        {
            ThreadPool.QueueUserWorkItem(LoadClientInfo, (string)arg3);
        }

        public static void SendMsg(string str)
        {
            try
            {
                switch (ConnectType)
                {
                    case 1:
                        complexClient.Send(1, str);
                        break;
                    case 2:
                        //var s = $"{MqttTargetTopic}\\?";
                        //var sendString = Regex.Split(str, s, RegexOptions.IgnoreCase);
                        //TOBS??SCADAMain?DT|C_B_JointMoveTo|
                        var topic = $"{str.Split('?')[2]}";
                        var content = $"{str.Split('?')[3]}";
                        Publish(topic, content);
                        break;
                    default:
                        break;
                }
            }
            catch (Exception err)
            {
            }
          
        }
        public static void SendMsg(string opName, string topic, string content)
        {
            try
            {
                switch (ConnectType)
                {
                    case 1:
                        complexClient.Send(1, content);
                        break;
                    case 2:
                        Publish(topic + opName, content);
                        break;
                    default:
                        break;
                }
            }
            catch (Exception err)
            {
            }

        }

        private void ConnectService()
        {
            switch (ConnectType)
            {
                case 1:
                    ClientConnection(IpPortSub);
                    break;
                case 2:
                    var _task = StartAsync(IpPortSub);
                    break;
                default:
                    break;
            }
        }


    }
}