### C# WinForms 使用 Socket 进行 TCP 数据发送与接收 #### 创建 TCP 服务器 为了实现基于 C# 的 WinForms 应用程序通过 Socket 实现数据的发送和接收，首先需要构建一个简单的 TCP 服务器。此部分代码展示了如何设置并监听来自客户端的消息。 ```csharp using System; using System.Net; using System.Net.Sockets; using System.Text; using System.Threading; public class TcpServer { private static void StartTcpListener() { int port = 8888; // 定义端口号 IPAddress localAddr = IPAddress.Parse("127.0.0.1"); // 设置本地IP地址 using (var listener = new TcpListener(localAddr, port)) { // 初始化TCP监听器 listener.Start(); // 启动监听 Console.WriteLine($"等待连接...{DateTime.Now}"); while (true) { var client = listener.AcceptTcpClient(); // 接受新的客户端请求 Thread thread = new Thread(HandleClientComm); thread.IsBackground = true; // 将线程设为后台模式 thread.Start(client); // 开启新线程处理通信逻辑 } } } private static void HandleClientComm(object obj) { using (TcpClient tcpClient = (TcpClient)obj) { NetworkStream stream = tcpClient.GetStream(); byte[] buffer = new byte[1024]; string dataFromClient = null; try { do { int bytesRead = stream.Read(buffer, 0, buffer.Length); dataFromClient = Encoding.ASCII.GetString(buffer, 0, bytesRead); Console.WriteLine($"收到消息: {dataFromClient} 时间:{DateTime.Now}"); // 反馈给客户端已接收到的信息 string responseMessage = "消息已成功接收"; byte[] sendBytes = Encoding.ASCII.GetBytes(responseMessage); stream.Write(sendBytes, 0, sendBytes.Length); } while (!string.IsNullOrEmpty(dataFromClient)); } catch (Exception e) { Console.WriteLine(e.Message); } } } } ``` 上述代码实现了基本的 TCP 服务器功能[^1]，能够持续监听指定 IP 和端口上的连接尝试，并针对每一个成功的连接启动一个新的线程来负责具体的读写操作。 #### 构建 TCP 客户端 对于想要向该服务器发送信息的应用来说，则需编写相应的客户端代码如下： ```csharp private async Task SendMessageAsync(string messageToSend) { try { using (TcpClient client = new TcpClient()) { await client.ConnectAsync("127.0.0.1", 8888).ConfigureAwait(false); using (NetworkStream ns = client.GetStream()) { byte[] msgBuffer = Encoding.UTF8.GetBytes(messageToSend); await ns.WriteAsync(msgBuffer, 0, msgBuffer.Length).ConfigureAwait(false); byte[] receiveBuffer = new byte[client.ReceiveBufferSize]; int receivedCount = await ns.ReadAsync(receiveBuffer, 0, receiveBuffer.Length).ConfigureAwait(false); string serverResponse = Encoding.UTF8.GetString(receiveBuffer[..receivedCount]); MessageBox.Show(serverResponse); } } } catch (Exception ex) { MessageBox.Show(ex.Message); } } ``` 这段代码描述了一个异步方法 `SendMessageAsync` ，它允许用户输入一条消息并通过网络流将其发送到之前定义好的服务器上；之后再从同一通道获取由服务器返回的结果并显示出来。