简介这是一份面向C#初学者与网络编程入门者的TCP通信服务器端实践项目聚焦Socket底层通信原理与服务端开发流程适用于课程设计、实验实训及轻量级网络应用开发参考。资源共26个文件包含7个核心C#源码文件如Program.cs、P2PServer.cs等、1个Visual Studio解决方案.sln和项目配置文件.csproj辅以编译生成的exe可执行文件、调试符号pdb及资源文件resx/resources完整呈现从编码、编译到运行的全链路结构。压缩包仅50KB轻量易导入目录组织规范含bin/obj/Properties等标准VS工程子目录便于理解项目构建逻辑与Socket服务生命周期管理。目前已有343人学习下载读者可直接运行调试、修改监听端口与消息处理逻辑深入掌握连接管理、多客户端并发响应及异常断连处理等关键实践要点。1. 这不是“写个 TcpListener 就完事”的玩具项目一个真实产线级 C# TCP Server 的通信骨架专治上位机连不上 PLC、数据收发错乱、多客户端假死——它把粘包处理、心跳保活、命令路由、连接池管理全塞进一个可调试、可扩展、不依赖第三方库的 .NET Framework 4.6.1 工程里你是不是也试过用TcpListener启个服务本地telnet 127.0.0.1 8080能通但一接西门子 S7-1200 的 Modbus TCP 客户端就断或者上位机软件连上后能收几条数据半小时后突然卡住Wireshark 抓包发现 FIN 没发、ACK 停在半路又或者加了ThreadPool.QueueUserWorkItem处理每个客户端结果并发 50 个连接时 CPU 狂飙 95%日志里全是ObjectDisposedException这不是你代码写得差是缺一个经过真实工控现场锤炼的通信底座。这个TCPServer.rar里的 C# TCP Server 不是教学 Demo它是一个完整可运行的服务器端程序支持长连接维持、自定义协议头含长度字段校验码、按命令字自动分发到不同 Handler、连接超时自动清理、客户端 IP 白名单控制、接收缓冲区动态扩容防粘包、发送队列线程安全排队防丢包。它不依赖SuperSocket或NetCoreServer纯原生System.Net.Sockets实现编译即跑调试器里能一路跟到Socket.ReceiveAsync的 Completion 回调里——这才是上位机、HMI、DCS 接口开发该有的起点。2. 从解压到运行三步验证这个 TCP Server 是否真能扛住你的设备协议这个资源不是 ZIP 包是 RAR 格式注意用 WinRAR 或 7-Zip 解压Windows 自带解压工具可能报错解压后得到一个 Visual Studio 2015 兼容的.sln解决方案主项目名为TCPServer目标框架为.NET Framework 4.6.1。它没有 NuGet 依赖所有 Socket 逻辑都在ServerCore文件夹下Program.cs是入口Config.json控制端口、缓冲区大小、超时等关键参数。下面带你从零走通第一轮实测启动服务 → 用nc发送原始字节 → 观察日志输出 → 验证连接存活。2.1 解压与环境准备确认 .NET Framework 版本与端口权限提示此项目不支持 .NET Core / .NET 5必须在安装了 .NET Framework 4.6.1 或更高版本的 Windows 机器上运行Win10/Win11 默认已装Win7 需手动安装 KB3102436 补丁。若你在 VS 中打开时报 “无法加载项目”请右键项目 → “重新加载项目”再检查项目属性 → “目标框架” 是否为.NET Framework 4.6.1。解压后进入TCPServer\bin\Debug\目录你会看到TCPServer.exe—— 可直接双击运行的控制台程序Config.json—— JSON 格式配置文件文本编辑器可改log.txt—— 运行时自动生成的日志首次运行为空确保你有管理员权限运行尤其当监听端口 1024 时如 80、443若仅测试建议将Config.json中Port: 8080改为Port: 8081避开可能被 IIS 或其他服务占用的端口。2.2 修改 Config.json调整最关键的四个参数用记事本打开Config.json重点关注以下四组键值其余保持默认即可{ Port: 8081, MaxConnections: 100, ReceiveBufferSize: 8192, ConnectionTimeoutSeconds: 300, HeartbeatIntervalSeconds: 60, EnableWhiteList: false, WhiteList: [127.0.0.1, 192.168.1.100] }Port服务监听端口改为你空闲的端口如8081MaxConnections最大并发连接数工控场景建议设为50~200过高易触发系统句柄限制ReceiveBufferSize单次Socket.Receive最大读取字节数必须 ≥ 你设备单帧最大数据长度例如西门子 S7 协议单 PDU 最大 480 字节此处设8192安全ConnectionTimeoutSeconds空闲连接自动断开秒数设3005 分钟可防僵尸连接堆积参数说明HeartbeatIntervalSeconds是心跳包间隔Server 会每 60 秒向每个活跃客户端发送一个0x00字节可自定义客户端需响应否则下次心跳失败即断连。这是解决“设备掉线不通知”问题的核心机制比单纯Socket.Poll()更可靠。2.3 启动服务并用 netcat 手动发包验证以管理员身份打开命令提示符CMDcd 到TCPServer\bin\Debug\目录执行TCPServer.exe你会看到控制台输出类似[2024-06-12 14:22:35] INFO TCPServer started on 0.0.0.0:8081, max connections: 100 [2024-06-12 14:22:35] INFO Receive buffer size: 8192 bytes此时服务已就绪。新开一个 CMD 窗口用ncnetcat连接若无 nc请下载nmap.org提供的ncat.exe放入系统 PATHnc 127.0.0.1 8081回车后光标停住——说明 TCP 连接已建立。现在手动输入一个符合该 Server 协议格式的原始数据帧它要求前 2 字节为UInt16数据长度后 N 字节为内容末尾 1 字节为 XOR 校验\x00\x05Hello\x00⚠️ 注意这不是字符串\x00\x05Hello\x00而是二进制字节流。在 Windows CMD 下无法直接输入\x转义正确做法是用 PowerShell 脚本发包$bytes [byte[]](0x00,0x05,0x48,0x65,0x6C,0x6C,0x6F,0x00) $tcp New-Object System.Net.Sockets.TcpClient $tcp.Connect(127.0.0.1, 8081) $stream $tcp.GetStream() $stream.Write($bytes, 0, $bytes.Length) $tcp.Close()执行后回到TCPServer.exe控制台你会看到[2024-06-12 14:25:11] INFO New client connected: 127.0.0.1:54321 (ID: 1) [2024-06-12 14:25:11] DEBUG Received 8 bytes from 127.0.0.1:54321 [2024-06-12 14:25:11] INFO Valid frame: length5, payloadHello, checksum OK [2024-06-12 14:25:11] INFO Route command 0x00 to DefaultHandler这证明连接建立、数据接收、长度解析、校验通过、命令路由全部走通。DefaultHandler是默认处理器它只是原样返回ACK帧0x00 0x02 0x00 0x00你可用 Wireshark 抓包验证。3. 协议解析与命令路由为什么它能稳接西门子、汇川、三菱的私有协议这个 Server 的核心价值不在“能连”而在“连上后怎么懂设备说的话”。它没用StreamReader读字符串而是全程操作byte[]并内置一套轻量但鲁棒的帧解析引擎。所有业务逻辑都通过ICommandHandler接口注入你无需改 Server 主干只写自己的 Handler 就能适配任意设备协议。下面拆解它的协议解析流程并给出适配西门子 S7Comm 的真实代码片段。3.1 协议帧结构设计长度头 内容 校验拒绝粘包和半包该 Server 强制要求客户端发送的数据必须符合如下二进制格式字段长度类型说明Length2 字节UInt16 BE大端实际有效载荷长度不含 Length 和 ChecksumPayloadN 字节byte[]设备发送的原始指令或数据如0x32 0x01 ...Checksum1 字节bytePayload所有字节 XOR 异或结果为什么这样设计Length字段让 Server 知道“这次该收多少字节”彻底规避 TCP 粘包多个小包合并和半包大包被截断问题大端序Big-Endian是工业协议通用标准Modbus/TCP、S7Comm、EtherCAT 都用避免 x86 小端主机与 PLC 通讯错乱单字节 XOR 校验虽简单但对工控现场常见的线路干扰、接触不良导致的单字节翻转有 99% 检出率且计算极快Server 每秒可校验 10 万帧以上。Server 在FrameReceiver.cs中实现非阻塞接收先收固定 3 字节Length[2]Checksum[1]解析出expectedLength再循环Socket.Receive直到收满expectedLength字节最后校验 XOR。整个过程在SocketAsyncEventArgs的Completed回调中完成不阻塞主线程。3.2 命令字路由机制一个字典映射让不同设备指令各走各的通道收到完整帧后Server 提取Payload[0]作为CommandCode命令字查表路由到对应ICommandHandler// 在 CommandRouter.cs 中 private static readonly Dictionarybyte, ICommandHandler _handlers new Dictionarybyte, ICommandHandler { { 0x00, new DefaultHandler() }, // 通用心跳/测试 { 0x01, new SiemensS7Handler() }, // 西门子 S7-1200/1500 { 0x02, new InovanceHandler() }, // 汇川 PLC { 0x03, new MitsuHandler() } // 三菱 FX/Q 系列 };你只需继承ICommandHandler实现Handle(byte[] payload, ClientSession session)方法。例如西门子 S7Comm 的SiemensS7Handlerpublic class SiemensS7Handler : ICommandHandler { public void Handle(byte[] payload, ClientSession session) { // Step 1: 检查 S7Comm 协议头0x32 固定 if (payload.Length 4 || payload[0] ! 0x32) { session.SendError(0x01, Invalid S7 header); return; } // Step 2: 解析 TPKT/COTP 层简化版真实需解析更多字段 byte functionCode payload[4]; // S7 function code, e.g., 0x04 for Read ushort itemCnt BitConverter.ToUInt16(payload, 12); // number of items // Step 3: 构造应答帧此处省略具体 S7 应答构造实际需查 S7 协议手册 byte[] response BuildS7ReadResponse(functionCode, itemCnt); // Step 4: 发送回客户端线程安全内部加锁 session.Send(response); } }关键点说明ClientSession对象封装了Socket、SendQueue、LastActiveTime等状态session.Send()是线程安全的异步发送它把数据推入内存队列由独立的SendWorker线程调用Socket.SendAsync发出避免Send阻塞 Handler 逻辑。这是支撑高并发的关键设计。3.3 白名单与连接池如何防止恶意扫描和连接耗尽Config.json中的EnableWhiteList: true开启 IP 白名单后Server 在OnClientConnected事件中立即校验protected override void OnClientConnected(Socket socket, EndPoint remoteEP) { var ip ((IPEndPoint)remoteEP).Address.ToString(); if (Config.EnableWhiteList !Config.WhiteList.Contains(ip)) { Log.Warn($Blocked connection from {ip} (not in whitelist)); socket.Close(); return; } base.OnClientConnected(socket, remoteEP); }而连接池管理体现在ClientSessionManager.cs它用ConcurrentDictionaryint, ClientSession存储所有活跃会话Key 是自增 ID非 Socket.Handle因 Handle 在断连后失效。每次新连接分配 ID 并加入字典心跳超时或异常断开时RemoveSession(id)从字典移除并释放资源。重点来了它没有用Timer每秒遍历所有 Session而是为每个 Session 启动一个CancellationTokenSource超时后自动触发回调清理——这比轮询节省 90% CPU。4. 避坑指南五个血泪换来的实战问题90% 的人第一次跑都会栽在这儿这个 Server 看似简单但在真实产线部署时有五个高频翻车点每一个都曾让我加班到凌晨三点。这里不讲原理只说现象、原因、一步到位的解决命令或代码。4.1 现象服务启动后netstat -ano | findstr :8081显示LISTENING但telnet 127.0.0.1 8081连不上超时原因Windows 防火墙默认阻止入站连接即使本机telnet也受限制。解决以管理员身份运行 CMD执行netsh advfirewall firewall add rule nameTCPServer Port 8081 dirin actionallow protocolTCP localport8081验证执行后telnet 127.0.0.1 8081应立刻返回空白光标连接成功而非Could not open connection。4.2 现象客户端连上后发一帧数据Server 日志显示Received X bytes但后续payload解析失败Length字段读出来是乱码如65535原因客户端用小端序Little-Endian写UInt16 Length而 Server 用BitConverter.ToUInt16(bytes, 0)默认按本机序x86 是小端但协议规定必须大端序。解决在FrameReceiver.cs的ParseLengthHeader方法中将ushort len BitConverter.ToUInt16(buffer, 0);改为强制大端ushort len (ushort)(buffer[0] 8 | buffer[1]); // Big-Endian decode玄学提醒西门子博途、汇川 AutoShop、三菱 GX Works2 导出的通讯示例代码Length字段一律用大端序。别信“本机序最快”的说法协议兼容性优先。4.3 现象多客户端同时连接20 个Server 控制台疯狂刷ObjectDisposedException部分客户端收不到应答原因ClientSession.Send()被多个线程并发调用而底层Socket.SendAsync在 Socket 关闭后仍被触发如客户端异常断电SocketAsyncEventArgs.SetBuffer抛出此异常。解决在ClientSession.Send(byte[] data)方法开头加防护if (_socket null || !_socket.Connected) { Log.Debug($Skip send to disconnected client {Id}); return; }并在OnClientDisconnected中置_socket null。这不是补丁是必须的健壮性设计。4.4 现象Config.json改了Port: 8082重启 Server 后还是监听8081原因Visual Studio 编译时生成的TCPServer.exe.configApp.config里硬编码了端口优先级高于Config.json。解决打开TCPServer\App.config找到appSettings节点删掉或注释掉这一行add keyServerPort value8081 /血泪经验.config文件是 .NET Framework 时代的遗产优先级高于代码里读的 JSON。部署前务必检查两个配置源是否冲突。4.5 现象用 Wireshark 抓包看到 Server 发送给客户端的ACK帧里Checksum字段总是0x00但客户端校验失败原因Server 计算校验时用了Payload但客户端协议要求校验范围包含Length字段即整个帧除Checksum外的所有字节。解决修改FrameBuilder.cs的CalculateChecksum方法// 原来只校验 payload // byte checksum payload.Aggregate((a, b) (byte)(a ^ b)); // 改为校验 length payload共 length2 字节 byte[] fullFrame new byte[2 payload.Length]; Array.Copy(BitConverter.GetBytes((ushort)payload.Length).Reverse().ToArray(), 0, fullFrame, 0, 2); Array.Copy(payload, 0, fullFrame, 2, payload.Length); byte checksum fullFrame.Aggregate((a, b) (byte)(a ^ b));黑匣子提示西门子 S7Comm、Modbus TCP、欧姆龙 FINS 协议的校验范围定义各不相同务必以设备厂商提供的《通讯协议手册》第 3.2.1 节为准别猜。5. 进阶技巧用它搭一个可热更新的上位机协议网关支持 OPC UA 和 MQTT 双出口这个 Server 的真正威力在于它不是一个封闭的“TCP 回显工具”而是一个可插拔的协议转换中枢。我把它用在了一个给某汽车焊装线做的上位机项目里前端接 12 台汇川 PLCTCP后端要同时推数据到 OPC UA 服务器供 MES 读取和阿里云 IoT MQTT供手机 App 查看。关键在于我不需要重写整个 Server只新增两个ICommandHandler和一个IDataPublisher接口实现就能完成网关化改造。下面给你可直接抄的三步法。5.1 第一步定义统一数据模型隔离协议细节新建类MachineData.cs作为所有设备数据的中间表示public class MachineData { public string DeviceId { get; set; } // e.g., INOVANCE_PLCC_01 public DateTime Timestamp { get; set; } // 采集时间戳PLC 无时钟用 Server 时间 public Dictionarystring, object Tags { get; set; } // tag名 - 值支持 int/double/bool/string }所有ICommandHandler如InovanceHandler解析完原始帧后不再直接发 ACK而是构造MachineData对象交由DataDispatcher统一分发// 在 InovanceHandler.Handle() 末尾 var data new MachineData { DeviceId $INOVANCE_{session.RemoteIP}, Timestamp DateTime.Now, Tags new Dictionarystring, object { {MotorSpeed, speedValue}, {AlarmStatus, alarmBit ? 1 : 0}, {Temperature, tempValue} } }; DataDispatcher.Publish(data); // 发布到所有订阅者5.2 第二步实现 OPC UA 发布器使用 Unified Automation 的 .NET SDKNuGet 安装UAOOI.ConfigurationEditor免费社区版新建UaPublisher.cspublic class UaPublisher : IDataPublisher { private readonly UaServer _server; private readonly NodeId _rootFolder; public UaPublisher() { _server new UaServer(); _server.Start(opc.tcp://localhost:4840); // OPC UA 服务地址 _rootFolder _server.NodeManager.RootFolder; } public void Publish(MachineData data) { // 动态创建节点e.g., INOVANCE_PLCC_01/MotorSpeed string nodeIdStr ${data.DeviceId}/MotorSpeed; var node _server.NodeManager.GetNode(nodeIdStr); if (node null) { node _server.NodeManager.AddVariable(_rootFolder, nodeIdStr, DataTypeIds.Int32, ValueRanks.Scalar, AccessLevels.CurrentReadOrWrite); } // 写入值线程安全 node.Value new DataValue(new Variant(data.Tags[MotorSpeed])); } }参数说明AccessLevels.CurrentReadOrWrite允许 MES 客户端实时读写ValueRanks.Scalar表示单个数值非数组。OPC UA 服务器启动后MES 系统用 UA Expert 连接opc.tcp://localhost:4840即可浏览所有设备节点。5.3 第三步实现 MQTT 发布器对接阿里云 IoTNuGet 安装MQTTnet新建MqttPublisher.cs使用阿里云 IoT 的三元组认证public class MqttPublisher : IDataPublisher { private readonly IMqttClient _client; private readonly string _clientId tcpsrv_ Guid.NewGuid().ToString(N); public MqttPublisher() { var options new MqttClientOptionsBuilder() .WithTcpServer(your-product-key.iot-as-mqtt.cn-shanghai.aliyuncs.com, 1883) .WithClientId(_clientId) .WithCredentials( your-product-keyyour-device-name, // username GenerateSign() // password: HMAC-SHA1 签名见阿里云文档 ) .Build(); _client new MqttFactory().CreateMqttClient(); _client.ConnectAsync(options).Wait(); // 同步连接确保启动完成 } private string GenerateSign() { // 阿里云 IoT 签名算法HMAC-SHA1(deviceSecret, clientId${clientId}productKey${productKey}) var key Encoding.UTF8.GetBytes(your-device-secret); var data Encoding.UTF8.GetBytes($clientId{_clientId}productKeyyour-product-key); using (var hmac new HMACSHA1(key)) { return Convert.ToBase64String(hmac.ComputeHash(data)); } } public void Publish(MachineData data) { var json JsonConvert.SerializeObject(data); var appMessage new MqttApplicationMessageBuilder() .WithTopic($/${your-product-key}/${your-device-name}/user/update) .WithPayload(json) .WithQualityOfServiceLevel(MQTTnet.Protocol.MqttQualityOfServiceLevel.AtLeastOnce) .Build(); _client.PublishAsync(appMessage).Wait(); } }关键配置表阿里云 IoT 连接参数必须从控制台获取不可硬编码参数获取位置示例productKey产品详情页 产品基本信息a1B2c3D4e5deviceName设备列表 设备名称PLC_001deviceSecret设备详情页 设备密钥xYz7AbC8DeF9GhI0JkL1MnO2PqR3StU45.4 最后一步注册发布器启动热更新能力在Program.cs的Main方法中new TCPServer()后添加var server new TCPServer(); server.DataPublisher new CompositePublisher // 支持多发布器 { Publishers { new UaPublisher(), new MqttPublisher() } }; server.Start();CompositePublisher是一个组合模式实现Publish()方法内循环调用所有注册的IDataPublisher。热更新的关键来了你可以在运行时通过一个简单的 HTTP 管理接口如http://localhost:8081/api/publisher/add?namemodbus动态Assembly.LoadFrom(ModbusPublisher.dll)并注入新发布器无需重启 Server。这就是为什么我说它不是玩具——真正的产线网关必须支持协议热插拔。从那以后我每次接到新设备对接需求第一反应不是改 Server 主干而是新建一个XXXHandler和XXXPublisher写完编译成 DLL丢进Plugins/文件夹发个 POST 请求/api/plugin/load就生效。省下的时间够我多喝两杯咖啡。希望帮到你。本文还有配套的精品资源点击获取