在C# WinForm中，TCP/IP服务端程序处理多个客户端并发连接可以采用多线程或异步编程的方法。 ### 多线程方式 为每个客户端连接创建一个新线程进行处理，避免阻塞主线程，确保界面的响应性。以下是一个示例代码： ```csharp using System; using System.Net; using System.Net.Sockets; using System.Text; using System.Threading; using System.Windows.Forms; namespace TcpServerWinForm { public partial class Form1 : Form { private TcpListener server; private Thread listenThread; public Form1() { InitializeComponent(); } private void StartServer() { try { server = new TcpListener(IPAddress.Any, 8888); server.Start(); listenThread = new Thread(ListenForClients); listenThread.Start(); } catch (Exception ex) { MessageBox.Show("启动服务器时出错: " + ex.Message); } } private void ListenForClients() { while (true) { try { TcpClient client = server.AcceptTcpClient(); Thread clientThread = new Thread(() => HandleClient(client)); clientThread.Start(); } catch (Exception ex) { MessageBox.Show("监听客户端时出错: " + ex.Message); } } } private void HandleClient(TcpClient client) { try { NetworkStream stream = client.GetStream(); byte[] buffer = new byte[1024]; int bytesRead = stream.Read(buffer, 0, buffer.Length); string message = Encoding.ASCII.GetString(buffer, 0, bytesRead); this.Invoke((MethodInvoker)delegate { richTextBox1.Text += "收到消息: " + message + Environment.NewLine; }); string response = "消息已收到"; byte[] responseBytes = Encoding.ASCII.GetBytes(response); stream.Write(responseBytes, 0, responseBytes.Length); client.Close(); } catch (Exception ex) { MessageBox.Show("处理客户端时出错: " + ex.Message); } } private void buttonStart_Click(object sender, EventArgs e) { StartServer(); } } } ``` ### 异步编程方式 使用`async`和`await`关键字实现异步操作，提高程序的性能和响应性。以下是一个简单示例： ```csharp private async void StartServerAsync() { try { server = new TcpListener(IPAddress.Any, 8888); server.Start(); while (true) { TcpClient client = await server.AcceptTcpClientAsync(); await HandleClientAsync(client); } } catch (Exception ex) { MessageBox.Show("启动服务器时出错: " + ex.Message); } } private async Task HandleClientAsync(TcpClient client) { try { using (NetworkStream stream = client.GetStream()) { byte[] buffer = new byte[1024]; int bytesRead = await stream.ReadAsync(buffer, 0, buffer.Length); string message = Encoding.ASCII.GetString(buffer, 0, bytesRead); this.Invoke((MethodInvoker)delegate { richTextBox1.Text += "收到消息: " + message + Environment.NewLine; }); string response = "消息已收到"; byte[] responseBytes = Encoding.ASCII.GetBytes(response); await stream.WriteAsync(responseBytes, 0, responseBytes.Length); } client.Close(); } catch (Exception ex) { MessageBox.Show("处理客户端时出错: " + ex.Message); } } ```