C#Scoket多线程收发，一个线发送心跳检测一个线程接收返回数据

C#Scoket多线程收发，一个线发送心跳检测一个线程接收返回数据

心跳检测包 格式为：${\"CMD_TYPE\": \"Keepalive\"}#

public  String serverIp { get; set; }
        public  int serverPort { get; set; }
        private Socket _clientSocket;
        private bool _isRunning;
        public bool _isSend { get; set; }
        private Thread _heartbeatThread;
        private Thread _heartThread;
        private readonly int _interval;
        private IPEndPoint serverEP = null;

private void button1_Click_1(object sender, EventArgs e)
        {
            // 创建 Socket 对象并连接到服务器

                serverIp = textBox1.Text.Trim();
                serverPort = int.Parse(textBox2.Text.Trim());
                serverEP = new IPEndPoint(
                IPAddress.Parse(serverIp),
                serverPort);

                _clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
                _clientSocket.BeginConnect(serverEP, new AsyncCallback(ConnectCallback), null);

                //_clientSocket.Connect(serverIp, serverPort);
                // 发送数据并接收服务器返回的数据
                //string heartbeatData = "${\"CMD_TYPE\": \"Keepalive\"}#";
                //byte[] sendData = System.Text.Encoding.UTF8.GetBytes(heartbeatData);


                // 创建心跳发送器
               
        }
        /// <summary>
        /// 监听成功回调开始执行
        /// </summary>
        /// <param name="iar"></param>
        private void ConnectCallback(IAsyncResult iar)
        {
            try
            {
                _clientSocket.EndConnect(iar);
                // 创建心跳发送器
                _isRunning = false;
                this.BeginInvoke((MethodInvoker)delegate ()
                {
                    this.richTextBox1.AppendText("已连接至服务器。" Environment.NewLine);
                    //richTextBox1.AppendText($"连接成功！\r\n");
                    button1.Enabled = false;
                    button2.Enabled = true;
                    button3.Enabled = true;
                    button4.Enabled = true;
                    button5.Enabled = true;
                });


                
                //heartbeatClient.BeginReceive();//启动等待
                //客户端心跳包检测
                heartbeatSenderStart();//每隔10秒进行一次心跳检测
            }
            catch (Exception err)
            {
                this.BeginInvoke((MethodInvoker)delegate ()
                {
                    button1.Enabled = true;
                    button2.Enabled = false;
                    button3.Enabled = false;
                    button4.Enabled = false;
                    button5.Enabled = false;
                    richTextBox1.AppendText($"连接失败！!!\r\n");
                });
                return;
            }
        }

//发送读卡指令

private void button3_Click(object sender, EventArgs e)
        {


            //if (heartbeatClient != null)
            //{

                _isSend = true;
            HeartbeatClient heartbeatClient = new HeartbeatClient(_clientSocket, this);//初始化类的Socket
            //heartbeatClient.BeginReceive();
            heartbeatClient.SendFile(false);
            
            //IsSendingImgs = false;
            //}
            ////ThreadPool.QueueUserWorkItem(DoWork);
            //if (heartbeatClient != null)
            //{
            //    _isSend = true;
            //    heartbeatClient.SendFile(1);
            //    //IsSendingImgs = false;
            //}
            //string heartbeatData = "${\"CMD_TYPE\": \"ReadTag\"}#";

            //byte[] heartbeatResp = new byte[200];
            //_isSend = true;
            //_clientSocket.Send(Encoding.ASCII.GetBytes(heartbeatData));
            //_isSend = false;
            //int respSize = _clientSocket.Receive(heartbeatResp);
            //if (respSize == 0)
            //{
            //    throw new Exception("Connection failed: no response received.");
            //}
            //string respMsg = Encoding.UTF8.GetString(heartbeatResp, 0, respSize);
            //respMsg = respMsg.Replace("\n", "").Replace("\t", "");
            //int startIndex = respMsg.IndexOf("$");
            //int endIndex = respMsg.IndexOf("#");

            //if (startIndex >= 0 && endIndex > 0)
            //{
            //    respMsg = respMsg.Substring(startIndex 1, endIndex - 1);
            //    //khd._isSend = false;//启动心跳包--用于接收完成之后继续开启心跳包用
            //    this.Invoke((MethodInvoker)delegate
            //    {
            //        richTextBox1.AppendText(respMsg "\r\n");
            //    });
            //}

        }