using System;
using System.Collections.Generic;
using System.Linq;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using System.Threading.Tasks;namespace 检测tcp连接状态
{public class TCPClient{private TcpClient client;private bool connected;private EventWaitHandle disconnectEvent;public event Action OnConnect;public event Action<byte[]> OnReceive;public event Action OnDisconnect;public TCPClient(){client = new TcpClient();connected = false;disconnectEvent = new AutoResetEvent(false);}public void Connect(string host, int port){try{client = new TcpClient(host, port);connected = true;OnConnect?.Invoke();Listen();}catch (Exception e){Console.WriteLine($"Failed to connect: {e.Message}");Disconnect();}}public void Send(byte[] data){try{NetworkStream stream = client.GetStream();stream.Write(data, 0, data.Length);}catch (Exception e){Console.WriteLine($"Error while sending data: {e.Message}");Disconnect();}}public void Disconnect(){if (connected){connected = false;client.Close();OnDisconnect?.Invoke();disconnectEvent.Set();}}private void Listen(){NetworkStream stream = client.GetStream();byte[] buffer = new byte[1024];while (connected){try{int bytesRead = stream.Read(buffer, 0, buffer.Length);if (bytesRead == 0){Disconnect();break;}byte[] receivedData = new byte[bytesRead];Array.Copy(buffer, receivedData, bytesRead);OnReceive?.Invoke(receivedData);}catch (Exception e){Console.WriteLine($"Error while receiving data: {e.Message}");Disconnect();}}}}
}

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;
using System.Threading;namespace 检测tcp连接状态
{public partial class Form2 : Form{private TCPClient tcpClient;private Thread connectThread;public Form2(){InitializeComponent();tcpClient = new TCPClient();tcpClient.OnConnect += () =>{UpdateStatusLabel("Connected");};tcpClient.OnReceive += (data) =>{// 处理接收到的数据string response1 = Encoding.UTF8.GetString(data, 0, data.Length);MessageBox.Show(response1);};tcpClient.OnDisconnect += () =>{UpdateStatusLabel("Disconnected");};}private void ConnectButton_Click(object sender, EventArgs e){connectThread = new Thread(() => tcpClient.Connect("127.0.0.1", 60000));connectThread.Start();}private void DisconnectButton_Click(object sender, EventArgs e){tcpClient.Disconnect();}private void UpdateStatusLabel(string status){if (StatusLabel.InvokeRequired){StatusLabel.BeginInvoke((MethodInvoker)(() =>{StatusLabel.Text = status;}));}else{StatusLabel.Text = status;}}}
}