wxr
2024-10-23 47f179be722a61c95cc03c8f90e1aa91c12d1124
HDL_ON/DAL/DriverLayer/Control_TcpClient.cs
@@ -152,7 +152,6 @@
                                {
                                    try
                                    {
                                        //_tcpClient.ReceiveTimeout =
                                        _tcpClient.Connect(IPAddress.Parse(_ip), 8586);
                                        ReceiveMessage();//开启线程,不停接收消息
                                        isConnected = true;
@@ -164,8 +163,6 @@
                                }
                            }
                            Thread.Sleep(1000);
                        }
                    });
                    connectThread.Start();
@@ -224,14 +221,6 @@
        /// <param name="bytes">需要发送的字节</param>
        public void SendMessage(byte[] bytes)
        {
            if(_tcpClient == null)
            {
                return;
            }
            if (!_tcpClient.Connected)
            {
                return;
            }
            if (heartBeatLogIdList.Count > 3)
            {
                try
@@ -248,6 +237,14 @@
            }
            try
            {
                if (_tcpClient == null)
                {
                    return;
                }
                if (!_tcpClient.Connected)
                {
                    return;
                }
                if (_tcpClient.GetStream().CanWrite&& isConnected)
                {
                    _tcpClient.GetStream().Write(bytes, 0, bytes.Length);
@@ -367,12 +364,10 @@
                                    }
                                    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) { }
@@ -382,7 +377,6 @@
                            MainPage.Log($"tcp ReceiveMessage error :{ex.Message}");
                        }
                    });
                    //receiveThread.IsBackground = true;
                    receiveThread.Start();
                }
                else