C# 如何进行TCP/IP套接字(Socket)编程 - 客户端与服务器的实现

C# TCP/IP Socket编程核心是使用System.Net.Sockets命名空间下的Socket类及封装类TcpClient/TcpListener;服务器用TcpListener监听并处理连接,客户端用TcpClient连接收发数据,需注意异步通信、资源释放与异常处理。

C# 中 TCP/IP Socket 编程的核心是使用 System.Net.Sockets 命名空间下的 Socket 类,配合 TcpClientTcpListener(更高级、更简洁的封装)来实现客户端与服务器通信。关键在于理解连接建立、数据收发和资源释放的流程,避免阻塞主线程或内存泄漏。

服务器端:用 TcpListener 监听并处理客户端连接

推荐初学者优先使用 TcpListener,它封装了底层 Socket 的复杂性,代码更清晰、不易出错。

  • 创建监听器:指定 IP 地址(如 IPAddress.Any)和端口(如 8080
  • 调用 Start() 开始监听;用 AcceptTcpClient() 阻塞等待连接(或用 BeginAcceptTcpClient 异步)
  • 每个客户端连接返回一个 TcpClient 实例,通过其 Ge

    tStream()
    获取 NetworkStream 进行读写
  • 务必在处理完后关闭 TcpClientNetworkStream,防止句柄泄漏

示例片段(控制台服务器):

TcpListener listener = new TcpListener(IPAddress.Any, 8080);
listener.Start();
Console.WriteLine("服务器已启动,等待连接...");
TcpClient client = listener.AcceptTcpClient();
using (var stream = client.GetStream())
{
  byte[] buffer = new byte[1024];
  int len = stream.Read(buffer, 0, buffer.Length);
  string msg = Encoding.UTF8.GetString(buffer, 0, len);
  Console.WriteLine($"收到:{msg}");
  string reply = "Hello from server";
  byte[] replyBytes = Encoding.UTF8.GetBytes(reply);
  stream.Write(replyBytes, 0, replyBytes.Length);
}
client.Close();
listener.Stop();

客户端:用 TcpClient 主动连接并收发数据

客户端逻辑更简单:创建 TcpClient → 调用 Connect() 连接服务器 → 用 GetStream() 发送/接收数据。

  • 连接时建议加超时控制(可使用 BeginConnect + AsyncWaitHandle,或新建线程+取消令牌)
  • 发送字符串前需编码为字节数组(常用 Encoding.UTF8);接收时注意流可能未一次性返回全部数据,需循环读取或按协议解析长度头
  • 不要假设一次 Read() 就能读完所有内容——TCP 是字节流,无消息边界

示例片段(简单客户端):

TcpClient client = new TcpClient();
client.Connect("127.0.0.1", 8080);
using (var stream = client.GetStream())
{
  string msg = "Hello Server";
  byte[] data = Encoding.UTF8.GetBytes(msg);
  stream.Write(data, 0, data.Length);
  byte[] buffer = new byte[1024];
  int len = stream.Read(buffer, 0, buffer.Length);
  string response = Encoding.UTF8.GetString(buffer, 0, len);
  Console.WriteLine($"服务器回复:{response}");
}
client.Close();

进阶要点:异步通信与多客户端支持

实际应用中,服务器不能只处理一个客户端,也不能让 AcceptRead 阻塞整个程序。

  • TcpListener.BeginAcceptTcpClient + 回调,或 C# 5.0+ 推荐的 await listener.AcceptTcpClientAsync()
  • 对每个 TcpClient 启动独立任务(Task.Run)或使用 NetworkStream.ReadAsync/WriteAsync 实现非阻塞 I/O
  • 若需自定义协议(如带长度头的消息),先读 4 字节表示后续内容长度,再读指定字节数,避免粘包
  • 异常处理不可少:网络中断、对方关闭连接、IOExceptionObjectDisposedException 都要捕获并安全清理资源

底层 Socket 方式(按需选用)

当需要精细控制(如设置 SocketOptionName、使用 UDP、重用地址、绑定特定网卡等),才直接操作 Socket 类。

  • 服务器:创建 Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)BindListenAccept
  • 客户端:同上创建 Socket → ConnectSend/Receive
  • 记得设置 socket.Blocking = false 或改用 BeginXXX/EndXXX 方法做异步
  • TcpClient 更灵活,但也更容易写出 bug,不推荐新手从这里起步

基本上就这些。用好 TcpClientTcpListener 足以覆盖大多数 C# 网络通信场景。重点不在“怎么写”,而在于“怎么安全、稳定、可扩展地写”——关注连接生命周期、异常恢复、线程安全和协议设计。