wxr
2023-06-06 592974441a4df95fffd9167c90192da1a390b1c2
HDL_ON/DAL/DriverLayer/Control_TcpClient.cs
@@ -6,6 +6,7 @@
using System.Threading.Tasks;
using HDL_ON.Entity;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
namespace HDL_ON.DriverLayer
{
@@ -15,7 +16,25 @@
        //声明IP,端口,和一个用来连接的Socket
        public string _ip;
        private TcpClient _tcpClient;
        private TcpClient _clinet;
        private TcpClient _tcpClient {
            get
            {
                return _clinet;
            }
            set
            {
                _clinet = value;
                if (_clinet == null) {
                    if(connectThread!= null)
                    {
                        connectThread.Abort();
                        connectThread = null;
                    }
                }
            }
        }
        //创建一个委托,用来满足其他类调用
        //public delegate void DelegateMessage(string str);
@@ -25,10 +44,47 @@
        /// 连接次数
        /// </summary>
        private int reconnectIndex = 0;
        private bool _isConnected = false;
        /// <summary>
        /// 是否连接成功
        /// </summary>
        public bool isConnected = false;
        public bool isConnected {
            get
            {
                return _isConnected;
            }
            set
            {
                _isConnected = value;
                if (value)
                {
                    Control.Ins.LoginGateway();
                    HeartBeat();
                }
                else
                {
                    try
                    {
                        _tcpClient.Close();
                        _tcpClient = null;
                    }
                    catch (Exception)
                    {
                    }
                }
            }
        }
        private List<string> heartBeatLogIdList = new List<string>();
        /// <summary>
        /// 心跳记录
        /// </summary>
        public void ClearHeartBeatLog()
        {
            heartBeatLogIdList.Clear();
        }
        /// <summary>
@@ -53,14 +109,14 @@
            try
            {
                _tcpClient.Connect(IPAddress.Parse(_ip), 8586);
                Task.Run(new Action(ReceiveMessage));//开启线程,不停接收消息
                ReceiveMessage();//开启线程,不停接收消息
                MainPage.Log($"打开tcp client{_ip}:8586");
                isConnected = true;
            }
            catch (Exception e)
            {
                MainPage.Log(e.Message);
                throw;
                MainPage.Log($"打开tcp异常:"+e.Message);
                return false;
            }
            return true;//返回连接状态
        }
@@ -74,42 +130,80 @@
        /// </summary>
        public void Connect()
        {
            if(connectThread == null)
            lock (lockObj)
            {
                connectThread = new Thread(() => {
                    while (Control.Ins.GatewayOnline_Local)
                if (isConnected)
                {
                    return;
                }
                if (connectThread == null)
                {
                    connectThread = new Thread(() =>
                    {
                        if (_tcpClient == null)
                        while (Control.Ins.GatewayOnline_Local && !isConnected)
                        {
                            ConnectToTcp();
                        }
                        else
                        {
                            if (!_tcpClient.Connected)
                            if (_tcpClient == null)
                            {
                                try
                                ConnectToTcp();
                            }
                            else
                            {
                                if (!_tcpClient.Connected)
                                {
                                    //_tcpClient.ReceiveTimeout =
                                    _tcpClient.Connect(IPAddress.Parse(_ip), 8586);
                                    Task.Run(new Action(ReceiveMessage));//开启线程,不停接收消息
                                }
                                catch (Exception ex)
                                {
                                    MainPage.Log($"tcp重连异常:{ex.Message}");
                                    _tcpClient.Close();
                                    _tcpClient = null;
                                    try
                                    {
                                        //_tcpClient.ReceiveTimeout =
                                        _tcpClient.Connect(IPAddress.Parse(_ip), 8586);
                                        ReceiveMessage();//开启线程,不停接收消息
                                        isConnected = true;
                                    }
                                    catch (Exception ex)
                                    {
                                        MainPage.Log($"tcp重连异常:{ex.Message}");
                                    }
                                }
                            }
                            Thread.Sleep(1000);
                        }
                        Thread.Sleep(1000);
                    });
                    connectThread.Start();
                }
                else
                {
                    if (!isConnected)
                    {
                        try
                        {
                            connectThread?.Abort();
                        }
                        catch { }
                        finally
                        {
                            connectThread = null;
                        }
                        Connect();
                    }
                });
                connectThread.Start();
                }
            }
        }
        /// <summary>
        /// 重连
        /// </summary>
        public void Reconect()
        {
            if (_tcpClient == null)
            {
                Connect();
            }
            else
            {
                _tcpClient.Close();
                _tcpClient = null;
                Connect();
            }
        }
        /// <summary>
        /// 关闭连接
@@ -130,29 +224,84 @@
        /// <param name="bytes">需要发送的字节</param>
        public void SendMessage(byte[] bytes)
        {
            if (_tcpClient.GetStream().CanWrite)
            if (heartBeatLogIdList.Count > 3)
            {
                _tcpClient.GetStream().Write(bytes, 0, bytes.Length);
                try
                {
                    MainPage.Log("心跳多次未回复,断开tcp连接");
                    heartBeatLogIdList.Clear();
                    isConnected = false;
                    Reconect();
                    return;
                }catch (Exception ex)
                {
                    MainPage.Log($"重连tcp异常:{ex.Message}");
                }
            }
            try
            {
                if (_tcpClient.GetStream().CanWrite&& isConnected)
                {
                    _tcpClient.GetStream().Write(bytes, 0, bytes.Length);
                }
            }catch(Exception ex)
            {
                MainPage.Log($"tcp客户端发送数据异常:{ex.Message}");
                isConnected = false;
            }
        }
        /// <summary>
        /// 心跳包线程
        /// </summary>
        private Thread heartBeatThread;
        private DateTime heartBeatTime;
        public void HeartBeat()
        {
            if(heartBeatThread == null)
            lock (lockObj)
            {
                heartBeatThread = new Thread(() => {
                    if(_tcpClient.Connected&&10 *1000 <(System.DateTime.Now - heartBeatTime).TotalMilliseconds)
                if (heartBeatThread == null)
                {
                    MainPage.Log($"心跳包线程启动");
                    heartBeatThread = new Thread(() =>
                    {
                        var sendBytes = Control.Ins.ConvertSendBodyData(CommunicationTopic.ct.HeartBeat, "");
                        SendMessage(sendBytes);
                        while (isConnected)
                        {
                            if (_tcpClient.Connected && 10 * 1000 < (System.DateTime.Now - heartBeatTime).TotalMilliseconds)
                            {
                                string msgId = Control.Ins.msg_id.ToString();
                                heartBeatLogIdList.Add(msgId);
                                var sendJob = new JObject { { "id", Control.Ins.msg_id.ToString() }, { "time_stamp", Utlis.GetTimestamp() } };
                                var bodyString = JsonConvert.SerializeObject(sendJob);
                                var sendBytes = Control.Ins.ConvertSendBodyData(CommunicationTopic.ct.HeartBeat, bodyString, false);
                                SendMessage(sendBytes);
                                heartBeatTime = DateTime.Now;
                            }
                            Thread.Sleep(100);
                        }
                    });
                    heartBeatThread.Start();
                }
                else
                {
                    try
                    {
                        heartBeatThread?.Abort();
                    }
                    Thread.Sleep(100);
                });
                heartBeatThread.Start();
                    catch (Exception ex)
                    {
                        MainPage.Log($"启动心跳线程,重启线程异常:{ex.Message}");
                    }
                    finally
                    {
                        if (heartBeatThread != null)
                        {
                            heartBeatThread = null;
                        }
                        HeartBeat();
                    }
                }
            }
        }
        /// <summary>
@@ -160,49 +309,89 @@
        /// </summary>
        private Thread receiveThread;
        private object lockObj = new object();
        //接收消息
        public void ReceiveMessage()
        {
            if(receiveThread == null)
            lock (lockObj)
            {
                receiveThread = new Thread(() => {
                    while (true)
                if (receiveThread == null)
                {
                    receiveThread = new Thread(() =>
                    {
                        if(_tcpClient == null)
                        try
                        {
                            receiveThread.Abort();
                            receiveThread = null;
                            return;
                        }
                        if (!_tcpClient.Connected)
                            while (isConnected)
                            {
                                if (_tcpClient == null)
                                {
                                    try
                                    {
                                        receiveThread?.Abort();
                                    }
                                    catch { }
                                    finally
                                    {
                                        receiveThread = null;
                                    }
                                    return;
                                }
                                if (!_tcpClient.Connected)
                                {
                                    MainPage.Log("tcp客户端断开了连接...");
                                    isConnected = false;
                                    return;
                                }
                                try
                                {
                                    // 定义一个2M的缓存区;
                                    byte[] arrMsgRec = new byte[1024 * 1024 * 2];
                                    try
                                    {
                                        int size = _tcpClient.GetStream().Read(arrMsgRec, 0, arrMsgRec.Length);
                                    }
                                    catch (Exception ex)
                                    {
                                        isConnected = false;
                                        MainPage.Log($"局域网tcp数据接收异常:{ex.Message}");
                                        return;
                                    }
                                    var tcpDataString = System.Text.Encoding.UTF8.GetString(arrMsgRec, 0, arrMsgRec.Length);
                                    if (!string.IsNullOrEmpty(tcpDataString))
                                    {
                                        MainPage.Log($"局域网tcp数据接收");
                                        Control.Ins.ConvertReceiveData(arrMsgRec, null);
                                    }
                                }
                                catch (Exception) { }
                            }
                        }catch (Exception ex)
                        {
                            MainPage.Log("tcp客户端断开了连接...");
                            receiveThread.Abort();
                            receiveThread = null;
                            isConnected = false;
                            return;
                            MainPage.Log($"tcp ReceiveMessage error :{ex.Message}");
                        }
                        // 定义一个2M的缓存区;
                        byte[] arrMsgRec = new byte[1024 * 1024 * 2];
                        int size = _tcpClient.GetStream().Read(arrMsgRec, 0, arrMsgRec.Length);
                        var tcpDataString = System.Text.Encoding.UTF8.GetString(arrMsgRec, 0, arrMsgRec.Length);
                        if (!string.IsNullOrEmpty(tcpDataString))
                        {
                            MainPage.Log($"局域网tcp数据接收");
                            Control.Ins.ConvertReceiveData(arrMsgRec, null);
                        }
                    });
                    //receiveThread.IsBackground = true;
                    receiveThread.Start();
                }
                else
                {
                    try
                    {
                        receiveThread?.Abort();
                    }
                });
                //receiveThread.IsBackground = true;
                receiveThread.Start();
                    catch { }
                    finally
                    {
                        receiveThread = null;
                        ReceiveMessage();
                    }
                }
            }
        }
    }
}