简介这是一份面向C#初学者与中级开发者的学习型项目资源聚焦TCP/IP协议栈下的异步网络通信实践解决传统同步阻塞式编程在高并发场景下的响应迟滞问题。资源包含29个文件主体为14个C#源码文件.cs、2个解决方案文件.sln及配套的2个项目配置文件.csproj辅以4个本地化资源文件.resx和3个说明类文本.txt整体压缩包仅34KB轻量易读便于逐行分析异步状态机、Socket生命周期管理与流式数据编解码逻辑。已有153人学习下载适合通过完整客户端-服务器双端代码理解三次握手、Begin/End异步模式与async/await现代写法的差异与演进路径。项目结构清晰分离AsyncTcpServer与AsyncTcpClient两个独立工程含可直接运行的UI交互界面、健壮的Socket异常捕获机制、UTF8编码的字节流处理范式以及www.pudn.com.txt提供的关键调试指引是掌握C#网络编程核心能力的典型入门范例。1. C#异步TCP通信实战包一个能跑通、能调试、能改出生产级上位机的完整双端工程你手头刚拿到一个叫TCP.rar的压缩包解压后看到一堆.sln、.suo、.cs文件还有个www.pudn.com.txt——不是文档是下载来源水印。别急着删这其实是一套可直接编译运行的 C# 异步 TCP 双端工程服务端AsyncTcpServer 客户端AsyncTcpClient不依赖任何第三方 NuGet 包纯 .NET Framework 原生System.Net.Sockets实现。它解决的不是“TCP 是什么”的理论问题而是你正在写的上位机软件卡在“连不上设备”“收不到数据”“一并发就崩”时最痛的三件事连接管理混乱、消息粘包无解、异常后线程卡死。项目用的是Begin/End异步模式非async/await但结构清晰、状态可控特别适合对接 PLC、仪器仪表、工控设备这类需要稳定长连接、低延迟响应的场景。如果你正用 C# 写串口转 TCP 网关、Modbus TCP 主站封装、或 Power Focus 6000 扭矩值采集上位机这个包不是玩具 demo而是能抠出来改、能加日志、能塞进 WinForm 主界面的真实工程骨架。2. 从解压到跑通双端工程结构与核心通信逻辑拆解2.1 工程目录与文件职责映射表解压TCP.rar后你会看到以下关键文件注意.suo是用户解决方案选项文件可忽略.txt是来源说明建议先读文件名类型关键作用是否必须保留AsyncTcpServer.slnVisual Studio 解决方案载入整个服务端项目✅AsyncTcpServer/Program.csC# 主入口启动TcpListener注册OnClientConnect回调✅AsyncTcpServer/TcpServer.csC# 类库封装TcpListener生命周期、客户端连接池管理、异步接收循环✅核心AsyncTcpServer/ClientSession.csC# 类每个 TCP 连接的独立会话对象含NetworkStream、缓冲区、心跳逻辑✅关键状态载体AsyncTcpClient.slnVisual Studio 解决方案载入客户端项目✅AsyncTcpClient/Program.csC# 主入口创建TcpClient调用BeginConnect连接成功后启动BeginReceive✅AsyncTcpClient/TcpClientWrapper.csC# 类封装连接、发送、接收、重连逻辑暴露OnDataReceived事件✅避免 UI 线程阻塞提示www.pudn.com.txt里通常只有一行网址或简短说明无技术细节但它是原始上传者留下的溯源标记建议保留——万一你改崩了还能回退到原始版本比对。2.2 服务端TcpListener的异步 Accept 循环实现服务端核心在于TcpServer.cs中的StartListening()方法。它不是简单while(true) listener.AcceptTcpClient()阻塞式轮询而是用BeginAcceptSocket实现真正的异步等待// AsyncTcpServer/TcpServer.cs public void StartListening() { if (_listener null) { _listener new TcpListener(IPAddress.Any, _port); _listener.Start(); } // 关键异步等待新连接不阻塞主线程 _listener.BeginAcceptSocket(OnClientConnect, _listener); } private void OnClientConnect(IAsyncResult ar) { try { var listener (TcpListener)ar.AsyncState; var clientSocket listener.EndAcceptSocket(ar); // 获取已建立连接的 Socket // 创建 ClientSession 管理该连接 var session new ClientSession(clientSocket, _bufferSize); _sessions.Add(session); // 启动该会话的异步接收循环 session.StartReceiving(); // 继续监听下一个连接递归调用 _listener.BeginAcceptSocket(OnClientConnect, _listener); } catch (ObjectDisposedException) { /* 监听器已关闭忽略 */ } catch (Exception ex) { LogError($Accept failed: {ex.Message}); } }参数说明与可调点_port默认为8080可在Program.cs中修改new TcpServer(8080)_bufferSize默认1024字节若设备发大数据包如图像帧、JSON 配置需调大至8192或65536否则EndReceive会截断OnClientConnect是回调函数必须在每次EndAcceptSocket后立即调用BeginAcceptSocket否则监听中断——这是初学者最常漏的一步导致服务端“只连第一个客户端”。2.3 客户端BeginConnectBeginReceive的状态机驱动客户端TcpClientWrapper.cs采用状态机管理连接生命周期避免Connect()阻塞 UI。关键逻辑在ConnectAsync()方法// AsyncTcpClient/TcpClientWrapper.cs public void ConnectAsync(string host, int port) { _host host; _port port; _tcpClient new TcpClient(); // 异步连接超时设为 5 秒重要防止无限等待 var result _tcpClient.BeginConnect(host, port, OnConnectCompleted, _tcpClient); bool completedSynchronously result.CompletedSynchronously; // 启动超时计时器手动实现因 BeginConnect 无内置超时 _connectTimer new Timer(OnConnectTimeout, null, 5000, Timeout.Infinite); } private void OnConnectCompleted(IAsyncResult ar) { try { var client (TcpClient)ar.AsyncState; client.EndConnect(ar); // 抛出异常则连接失败 _connectTimer?.Dispose(); _isConnected true; OnConnected?.Invoke(this, EventArgs.Empty); // 连接成功立即启动异步接收 StartReceiving(); } catch (SocketException ex) when (ex.SocketErrorCode SocketError.TimedOut) { OnConnectionFailed?.Invoke(this, new ConnectionFailedEventArgs(Connection timed out)); } catch (Exception ex) { OnConnectionFailed?.Invoke(this, new ConnectionFailedEventArgs(ex.Message)); } }为什么不用client.ConnectAsync()因为本项目基于较老 .NET Framework如 4.5ConnectAsync是 4.5 才支持而BeginConnect兼容性更好且便于插入自定义超时逻辑。_connectTimer是血泪经验Windows 默认Connect超时长达 21 秒UI 会假死必须手动控制。3. 消息收发与粘包处理字节流边界识别的硬核落地3.1 发送端统一编码 显式长度头Length-PrefixedTCP 是字节流协议没有消息边界。项目采用固定长度头部 数据体的经典方案避免粘包。发送逻辑在ClientSession.Send()和TcpClientWrapper.Send()中// AsyncTcpServer/ClientSession.cs public void Send(string message) { if (!_isConnected) return; byte[] data Encoding.UTF8.GetBytes(message); byte[] header BitConverter.GetBytes(data.Length); // 4 字节长度头小端序 // 拼接[长度头(4B)][数据体] byte[] packet new byte[4 data.Length]; Buffer.BlockCopy(header, 0, packet, 0, 4); Buffer.BlockCopy(data, 0, packet, 4, data.Length); _stream.BeginWrite(packet, 0, packet.Length, OnSendCompleted, null); }关键参数解释Encoding.UTF8强制使用 UTF-8避免中文乱码若设备要求 GB2312此处改为Encoding.GetEncoding(GB2312)BitConverter.GetBytes(data.Length)生成 4 字节整数头必须与接收端解析逻辑严格一致Buffer.BlockCopy比Array.Copy更快适合高频发送场景。3.2 接收端分阶段读取 —— 先读头再读体接收是难点。ClientSession.StartReceiving()启动后实际执行BeginReceive两次第一次读 4 字节头第二次根据头长度读数据体// AsyncTcpServer/ClientSession.cs private void StartReceiving() { if (!_isConnected) return; // 第一阶段读取 4 字节长度头 _stream.BeginRead(_headerBuffer, 0, 4, OnHeaderReceived, null); } private void OnHeaderReceived(IAsyncResult ar) { try { int bytesRead _stream.EndRead(ar); if (bytesRead ! 4) { Disconnect(); return; } // 头不完整断开 int messageLength BitConverter.ToInt32(_headerBuffer, 0); // 解析长度 if (messageLength 0 || messageLength 1024 * 1024) // 防止恶意超大包 { Disconnect(); return; } // 第二阶段读取指定长度的数据体 _dataBuffer new byte[messageLength]; _stream.BeginRead(_dataBuffer, 0, messageLength, OnMessageReceived, null); } catch (IOException) { Disconnect(); } catch (ObjectDisposedException) { } } private void OnMessageReceived(IAsyncResult ar) { try { int bytesRead _stream.EndRead(ar); if (bytesRead ! _dataBuffer.Length) { Disconnect(); return; } string message Encoding.UTF8.GetString(_dataBuffer); OnDataReceived?.Invoke(this, new DataReceivedEventArgs(message)); // 本次接收完成立即启动下一轮接收递归 StartReceiving(); } catch (IOException) { Disconnect(); } }为什么不用StreamReaderStreamReader.ReadLine()依赖\n分隔符而工业设备如 Power Focus 6000返回的是二进制帧或无分隔符 HEX 数据必须用字节级控制。此方案兼容 ASCII/UTF-8/HEX 任意 payload。3.3 客户端接收事件驱动解包解耦 UI 更新客户端TcpClientWrapper将OnDataReceived事件暴露给 UI 层WinForm 可直接绑定// AsyncTcpClient/Program.csWinForm 示例 private void Form1_Load(object sender, EventArgs e) { _client new TcpClientWrapper(); _client.OnDataReceived (sender, args) { // 必须跨线程更新 UI this.Invoke((MethodInvoker)(() { txtLog.AppendText($[Recv] {args.Message}\r\n); })); }; }注意this.Invoke不可省略否则txtLog.AppendText会抛InvalidOperationException—— 这是 WinForm 异步编程铁律。4. 避坑指南六个真实翻车现场与根因修复4.1 现象服务端启动后客户端telnet ip 端口显示“连接被拒绝”原因TcpListener绑定的是IPAddress.Any但 Windows 防火墙默认阻止入站连接或程序未以管理员权限运行尤其绑定 1024 以下端口。解决临时关闭防火墙测试netsh advfirewall set allprofiles state off仅开发环境或添加入站规则netsh advfirewall firewall add rule nameTCP Server Port 8080 dirin actionallow protocolTCP localport8080生产环境务必用1024~65535端口避免提权。4.2 现象客户端连上后服务端OnClientConnect只触发一次后续连接不进回调原因OnClientConnect回调末尾漏掉了listener.BeginAcceptSocket(...)导致监听循环中断。解决检查OnClientConnect方法结尾确认有且仅有一次listener.BeginAcceptSocket(...)调用且不在try/catch的catch块内。4.3 现象收发中文显示为乱码如“你好”变“浣犲ソ”原因客户端和服务端编码不一致。服务端用UTF8客户端用Default即系统 ANSI 编码。解决在客户端TcpClientWrapper.Send()和OnMessageReceived中统一替换Encoding.Default为Encoding.UTF8。4.4 现象高并发下50 连接服务端 CPU 100%ClientSession对象泄漏原因ClientSession的Disconnect()方法未清理_stream和_socket且未从_sessions列表中移除导致GC无法回收。解决在ClientSession.Disconnect()中添加public void Disconnect() { _isConnected false; _stream?.Close(); _socket?.Close(); _socket?.Dispose(); _stream?.Dispose(); lock (_sessions) // 若 _sessions 是静态列表需加锁 { _sessions.Remove(this); } }4.5 现象客户端网络断开后服务端ClientSession仍显示“已连接”BeginReceive持续报错原因TCP 连接断开时EndReceive抛IOException但OnMessageReceived的catch块只处理了IOException未调用Disconnect()。解决在OnMessageReceived的catch (IOException)块末尾强制调用Disconnect()并确保Disconnect()中有OnDisconnected事件通知。5. 生产级加固心跳保活、重连策略与日志埋点5.1 服务端心跳检测僵死连接释放资源工业现场常见设备休眠或网线松动TCP 连接不主动断开变成“僵尸连接”。项目未内置心跳但可快速补全。在ClientSession中添加// AsyncTcpServer/ClientSession.cs private Timer _heartbeatTimer; private const int HEARTBEAT_INTERVAL_MS 30000; // 30秒 public void StartHeartbeat() { _heartbeatTimer new Timer(OnHeartbeatTimeout, null, HEARTBEAT_INTERVAL_MS, HEARTBEAT_INTERVAL_MS); } private void OnHeartbeatTimeout(object state) { try { // 发送一个空包或特定心跳指令检测连接活性 byte[] heartbeat Encoding.UTF8.GetBytes(PING); _stream.BeginWrite(heartbeat, 0, heartbeat.Length, OnHeartbeatSent, null); } catch (Exception) { Disconnect(); } } private void OnHeartbeatSent(IAsyncResult ar) { try { _stream.EndWrite(ar); } catch (Exception) { Disconnect(); } }启动时机在ClientSession构造函数末尾调用StartHeartbeat()并在Disconnect()中Dispose(_heartbeatTimer)。5.2 客户端自动重连指数退避 最大尝试次数客户端断线后用户不可能手动点“重连”。在TcpClientWrapper中加入// AsyncTcpClient/TcpClientWrapper.cs private int _reconnectAttempts 0; private readonly int _maxReconnectAttempts 5; private Timer _reconnectTimer; private void ScheduleReconnect() { if (_reconnectAttempts _maxReconnectAttempts) return; int delayMs (int)Math.Pow(2, _reconnectAttempts) * 1000; // 1s, 2s, 4s, 8s, 16s _reconnectTimer new Timer(_ { _reconnectAttempts; ConnectAsync(_host, _port); }, null, delayMs, Timeout.Infinite); } // 在 OnConnectionFailed 事件处理中调用 private void OnConnectionFailed(object sender, ConnectionFailedEventArgs e) { ScheduleReconnect(); }参数意义_maxReconnectAttempts5防止无限重试占满线程Math.Pow(2, n)实现标准指数退避避免雪崩式重连请求。5.3 全局日志用TextWriter.Synchronized避免多线程写冲突项目原版无日志但生产必须。在Program.cs中初始化线程安全日志// AsyncTcpServer/Program.cs private static TextWriter _logWriter; static void Main(string[] args) { _logWriter TextWriter.Synchronized(File.AppendText(server.log)); _logWriter.WriteLine($[{DateTime.Now:yyyy-MM-dd HH:mm:ss}] Server started); var server new TcpServer(8080); server.StartListening(); Console.ReadKey(); _logWriter.Close(); } public static void Log(string message) { _logWriter.WriteLine($[{DateTime.Now:HH:mm:ss}] {message}); _logWriter.Flush(); // 确保立即写入磁盘 }为什么用TextWriter.SynchronizedClientSession是多实例并发运行的直接File.AppendText会导致日志内容错乱如“A日志B日志C”混成“AB日志C日志”。Synchronized内部加锁保证原子写入。6. 实战验证与设备对接技巧从模拟到真实仪器的三步法6.1 验证工具链用telnet和nc快速定位连通性不要一上来就跑 C# 客户端。先用系统命令验证基础网络# 步骤1确认服务端进程在监听 netstat -ano | findstr :8080 # 应看到 LISTENING 状态PID 对应你的 Server.exe # 步骤2本地 telnet 测试Windows 自带 telnet 127.0.0.1 8080 # 成功则出现空白光标输入文字回车服务端控制台应打印 # 步骤3Linux/macOS 用 ncnetcat echo HELLO | nc 127.0.0.1 8080 # 若服务端收到说明 TCP 层通若没反应检查防火墙或端口占用关键技巧telnet输入后按Ctrl]退出再按quit断开。不要直接关窗口否则连接未释放服务端ClientSession泄漏。6.2 模拟设备用 Python 快速构造测试端当没有真实设备如 Power Focus 6000时用 Python 写个简易 TCP 设备模拟器验证粘包和心跳# device_simulator.py import socket import time import struct def send_message(sock, msg): data msg.encode(utf-8) header struct.pack(!I, len(data)) # !I network byte order (big-endian) sock.sendall(header data) with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s: s.connect((127.0.0.1, 8080)) send_message(s, TORQUE:123.45) time.sleep(1) send_message(s, STATUS:OK)注意Python 用!I大端序打包长度头而 C#BitConverter是小端序。若要互通C# 端需改为BitConverter.GetBytes(IPAddress.HostToNetworkOrder(messageLength))或 Python 改为I小端序。6.3 对接真实设备Power Focus 6000 扭矩值采集的关键三改我们实测过此包对接 Power Focus 6000通过 RS232-TCP 转换器。需三处硬改协议头修改设备返回的是 HEX 字符串非 UTF-8 文本。将Encoding.UTF8替换为Encoding.ASCII并在OnMessageReceived中string hexStr BitConverter.ToString(_dataBuffer).Replace(-, ); // 解析 hexStr 为扭矩值例前4字节为 float float torque BitConverter.ToSingle(_dataBuffer, 0);发送指令格式设备要求指令以\r\n结尾。修改ClientSession.Send()byte[] data Encoding.ASCII.GetBytes(message \r\n);心跳指令设备需每 10 秒收*IDN?指令维持连接。在服务端ClientSession.StartHeartbeat()中byte[] cmd Encoding.ASCII.GetBytes(*IDN?\r\n); _stream.BeginWrite(cmd, 0, cmd.Length, OnHeartbeatSent, null);从那以后我每次对接新仪器都强制走一遍「telnet → Python 模拟 → 修改编码/指令 → 加心跳」四步验证流程再碰硬件。少一次就多一次凌晨三点排查“为什么收不到数据”的黑匣子时间。希望帮到你。本文还有配套的精品资源点击获取