简介这份资源是面向C#初学者与.NET开发者的串口通讯与Socket通讯入门示例包聚焦设备交互、嵌入式系统及物联网场景下的两种常见通信方式。包内共31个文件以cs源码、config配置、exe可执行程序、resx资源、csproj工程文件及sln解决方案为主另有pdb调试符号、dll库与manifest清单等压缩包约62KB结构完整可直接编译运行。示例围绕SerialPort类的串口参数配置与数据收发以及Socket类在TCP/UDP下的服务端监听、客户端连接与数据交换展开帮助读者理解波特率、数据位、停止位、校验位等串口设置以及Bind、Listen、Accept、Connect、Send、Receive等网络编程关键步骤。目前已有981人学习适合需要快速上手两种通信方式、对照代码理解底层流程并应用于实际项目的开发者参考。1. 串口和 Socket 双通道通讯一个 Demo 能踩多少坑工控上位机、仪器控制、产线数据采集这类场景里C# 串口通讯和 Socket 通讯几乎是绕不开的两件事。串口负责跟下位机、PLC、传感器、扫码枪打交道Socket 负责把数据汇总到服务端或者跟远端设备对接。很多人第一次写这类 Demo代码跑起来看着没问题一上现场就翻车串口数据丢包、粘包、跨线程更新 UI 直接崩、Socket 断线重连写了个寂寞。这篇笔记不讲空泛概念就围绕一个能跑通的最小 Demo把串口和 Socket 两条链路的选型理由、参数怎么设、代码怎么写、坑在哪讲清楚。适合刚接触工控通讯的开发者也适合写过但总在稳定性上栽跟头的人。读完你应该能自己搭出一个双通道采集转发的小工具并且知道每个参数背后的取舍。2. 串口通讯从 SerialPort 参数到稳定收包2.1 为什么优先用 SerialPort 而不是第三方库.NET 里做串口常见做法有三种System.IO.Ports.SerialPort、第三方封装库、直接 P/Invoke 调 Win32 API。对绝大多数 Demo 和中小型项目我一般直接用SerialPort理由很实在。第一它是 BCL 自带的不需要引入额外依赖部署时少一个 DLL 就少一个版本冲突的可能。第二它的 API 足够覆盖 90% 的场景波特率、数据位、停止位、校验位、流控、读写超时都能设。第三第三方库的优势主要在跨平台和异步封装上但如果你就是 Windows 上位机这个优势用不上。SerialPort真正让人头疼的不是功能不够而是它的DataReceived事件行为有点玄学。这个事件在次线程触发触发时机和收到的字节数都不保证可能一次给你 1 个字节也可能一次给你 200 个字节。很多人直接在这个事件里更新 UI结果就是随机崩溃。正确做法是事件里只做数据搬运把收到的字节丢进缓冲区业务处理放到独立线程或线程池里。2.2 串口参数怎么设一张表说清每个值的取舍串口通讯能不能通八成问题出在参数不匹配。下面这张表是我实际调试时反复对照的参数含义和常见取值都列清楚。参数含义常见取值设置要点PortName端口号COM1、COM3用SerialPort.GetPortNames()动态获取别写死BaudRate波特率9600、19200、115200必须和下位机完全一致差一点都不行DataBits数据位8绝大多数设备是 8少数老设备是 7StopBits停止位One、Two默认 One仪表类设备常见 TwoParity校验位None、Even、Odd默认 None工业仪表常用 EvenHandshake流控None、RequestToSend默认 None长距离传输可能要用 RTSReadTimeout读超时500~2000 ms设太小会频繁抛异常设太大卡住线程WriteTimeout写超时500~1000 ms写操作一般很快超时设短一点这里有个血泪经验波特率和校验位是最容易出问题的地方。波特率不匹配收到的全是乱码校验位不匹配可能一个字节都收不到但也不报错就是干等。调试时先用串口助手确认参数再往代码里搬。2.3 一个能直接抄的串口收发封装下面这段代码是我常用的最小封装核心思路是打开串口、订阅事件、把数据丢进线程安全队列、由独立线程消费。这样 UI 线程永远不会被串口事件直接打扰。using System; using System.Collections.Concurrent; using System.IO.Ports; using System.Threading; public class SerialPortService : IDisposable { private SerialPort _port; private readonly ConcurrentQueuebyte[] _rxQueue new ConcurrentQueuebyte[](); private Thread _worker; private volatile bool _running; // 打开串口并启动消费线程 public void Open(string portName, int baudRate, Parity parity, int dataBits, StopBits stopBits) { _port new SerialPort(portName, baudRate, parity, dataBits, stopBits) { ReadTimeout 1000, WriteTimeout 1000, Handshake Handshake.None }; _port.DataReceived OnDataReceived; _port.Open(); _running true; _worker new Thread(ConsumeLoop) { IsBackground true }; _worker.Start(); } // 事件里只做搬运不做业务 private void OnDataReceived(object sender, SerialDataReceivedEventArgs e) { try { int len _port.BytesToRead; if (len 0) return; byte[] buf new byte[len]; _port.Read(buf, 0, len); _rxQueue.Enqueue(buf); } catch (Exception ex) { // 这里只记录不抛避免事件线程崩溃 Console.WriteLine(串口读取异常: ex.Message); } } // 独立线程消费队列业务逻辑放这里 private void ConsumeLoop() { while (_running) { if (_rxQueue.TryDequeue(out byte[] data)) { ProcessFrame(data); } else { Thread.Sleep(5); } } } // 实际业务处理Demo 里只打印 private void ProcessFrame(byte[] data) { Console.WriteLine($收到 {data.Length} 字节: {BitConverter.ToString(data)}); } // 发送数据加锁避免多线程同时写 public void Send(byte[] data) { lock (_port) { _port.Write(data, 0, data.Length); } } public void Dispose() { _running false; _worker?.Join(500); if (_port ! null) { _port.DataReceived - OnDataReceived; if (_port.IsOpen) _port.Close(); _port.Dispose(); } } }逻辑说明DataReceived事件里只做Read和入队保证事件线程快速返回ConsumeLoop在后台线程里从ConcurrentQueue取数据做业务处理这样即使业务处理慢也不会阻塞串口事件。Send方法加锁是因为SerialPort的写操作不是线程安全的多个线程同时写会出问题。参数说明ReadTimeout设 1000ms 是折中值太小会在没数据时频繁抛TimeoutException太大在拔线时线程会卡住。Thread.Sleep(5)是空队列时的让步避免 CPU 空转5ms 对大多数采集场景够用。2.4 粘包和分包串口收包绕不开的问题串口是字节流没有消息边界。下位机一次发 20 个字节你可能分三次收到8、8、4。也可能两次的数据粘在一起一次给你。这就是粘包和分包。常见做法是定协议帧头 长度 数据 校验。比如0xAA 0x55开头第三个字节是长度最后一个是 CRC。收包时维护一个缓冲区按帧头找起点按长度截取校验通过才算一帧。private readonly Listbyte _buffer new Listbyte(); private void ProcessFrame(byte[] data) { _buffer.AddRange(data); while (true) { // 找帧头 0xAA 0x55 int headIndex -1; for (int i 0; i _buffer.Count - 1; i) { if (_buffer[i] 0xAA _buffer[i 1] 0x55) { headIndex i; break; } } if (headIndex 0 || _buffer.Count - headIndex 3) return; int frameLen _buffer[headIndex 2]; if (_buffer.Count - headIndex frameLen 3) return; byte[] frame _buffer.GetRange(headIndex, frameLen 3).ToArray(); _buffer.RemoveRange(0, headIndex frameLen 3); // 这里做校验和业务处理 Console.WriteLine(完整帧: BitConverter.ToString(frame)); } }这段代码的关键是缓冲区只增不减会内存泄漏所以每次取完完整帧要RemoveRange。另外找帧头时如果一直找不到缓冲区会无限增长实际项目里要加一个上限超过就清空并记录异常。3. Socket 通讯TCP 客户端与服务端的落地写法3.1 TCP 还是 UDP先想清楚你的数据能不能丢Socket 通讯第一件事是选协议。TCP 可靠、有序、有连接UDP 快、无连接、可能丢包。工控场景里采集数据上报一般用 TCP因为丢一帧可能导致数据对不上。但如果是对实时性要求极高、偶尔丢一帧无所谓的场景比如高频传感器推送UDP 反而更合适。我一般这样判断数据需要落库、需要和业务对账用 TCP数据只是实时展示、丢了下一帧马上补上用 UDP。Demo 里两种都可以写但 TCP 的坑更多先把 TCP 写稳。3.2 TCP 客户端的连接、收发与断线重连下面是一个 TCP 客户端的骨架包含连接、收包循环、发送和断线重连。注意Receive是阻塞的要放在独立线程里。using System; using System.Net.Sockets; using System.Text; using System.Threading; public class TcpClientService { private TcpClient _client; private NetworkStream _stream; private Thread _recvThread; private volatile bool _running; private readonly string _host; private readonly int _port; public TcpClientService(string host, int port) { _host host; _port port; } public void Start() { _running true; _recvThread new Thread(ConnectLoop) { IsBackground true }; _recvThread.Start(); } // 连接循环断线后自动重连 private void ConnectLoop() { while (_running) { try { _client new TcpClient(); _client.Connect(_host, _port); _stream _client.GetStream(); Console.WriteLine(已连接服务端); ReceiveLoop(); } catch (Exception ex) { Console.WriteLine(连接异常: ex.Message); } finally { CloseClient(); } if (_running) Thread.Sleep(3000); // 3 秒后重连 } } // 收包循环按缓冲区读取 private void ReceiveLoop() { byte[] buffer new byte[4096]; while (_running _client.Connected) { int len _stream.Read(buffer, 0, buffer.Length); if (len 0) break; // 服务端关闭 byte[] data new byte[len]; Array.Copy(buffer, data, len); Console.WriteLine(收到: Encoding.UTF8.GetString(data)); } } public void Send(string msg) { if (_stream null || !_client.Connected) return; byte[] data Encoding.UTF8.GetBytes(msg); _stream.Write(data, 0, data.Length); } private void CloseClient() { try { _stream?.Close(); } catch { } try { _client?.Close(); } catch { } _stream null; _client null; } public void Stop() { _running false; CloseClient(); } }逻辑说明ConnectLoop是一个死循环连接成功就进ReceiveLoop收数据收不到或异常就退出finally里关闭连接然后Sleep(3000)再重连。这样即使服务端重启客户端也能自动恢复。参数说明buffer设 4096 是常见值太小会频繁读太大浪费内存。Sleep(3000)是重连间隔太短会在服务端没起来时疯狂重试太长恢复慢。实际项目里可以做成指数退避第一次 1 秒第二次 2 秒最多 30 秒。3.3 服务端怎么写Accept 循环和客户端管理服务端比客户端多一步要管理多个客户端连接。常见做法是主线程Accept每个客户端开一个线程收数据。using System; using System.Collections.Concurrent; using System.Net; using System.Net.Sockets; using System.Text; using System.Threading; public class TcpServerService { private TcpListener _listener; private volatile bool _running; private readonly ConcurrentDictionarystring, TcpClient _clients new ConcurrentDictionarystring, TcpClient(); public void Start(int port) { _listener new TcpListener(IPAddress.Any, port); _listener.Start(); _running true; Thread acceptThread new Thread(AcceptLoop) { IsBackground true }; acceptThread.Start(); } private void AcceptLoop() { while (_running) { try { TcpClient client _listener.AcceptTcpClient(); string key client.Client.RemoteEndPoint.ToString(); _clients[key] client; Console.WriteLine(客户端接入: key); Thread t new Thread(() ClientLoop(key, client)) { IsBackground true }; t.Start(); } catch (Exception ex) { Console.WriteLine(Accept 异常: ex.Message); } } } private void ClientLoop(string key, TcpClient client) { byte[] buffer new byte[4096]; try { NetworkStream stream client.GetStream(); while (_running client.Connected) { int len stream.Read(buffer, 0, buffer.Length); if (len 0) break; string msg Encoding.UTF8.GetString(buffer, 0, len); Console.WriteLine($[{key}] {msg}); } } catch (Exception ex) { Console.WriteLine($[{key}] 异常: {ex.Message}); } finally { _clients.TryRemove(key, out _); client.Close(); Console.WriteLine(客户端断开: key); } } public void Broadcast(string msg) { byte[] data Encoding.UTF8.GetBytes(msg); foreach (var kv in _clients) { try { kv.Value.GetStream().Write(data, 0, data.Length); } catch { } } } public void Stop() { _running false; _listener?.Stop(); foreach (var kv in _clients) kv.Value.Close(); _clients.Clear(); } }逻辑说明AcceptLoop只负责接受连接把每个客户端交给独立线程处理。ConcurrentDictionary存客户端方便广播和清理。ClientLoop里Read返回 0 表示对端关闭退出循环并清理。参数说明IPAddress.Any表示监听所有网卡如果只想本机访问可以改成IPAddress.Loopback。端口选 1024 以上避免和系统端口冲突。4. 串口与 Socket 联动数据转发和线程安全4.1 双通道联动的整体结构把串口和 Socket 拼起来典型结构是串口收下位机数据解析后通过 Socket 发给服务端Socket 收到服务端指令通过串口下发给下位机。两条链路各自独立线程中间用线程安全队列或事件解耦。我一般会定义一个DataBridge类持有SerialPortService和TcpClientService在串口回调里调Send在 Socket 回调里调串口Send。注意不要在串口事件线程里直接调 Socket 发送因为 Socket 写可能阻塞会拖慢串口收包。4.2 跨线程更新 UI 的正确姿势WinForms 或 WPF 里串口和 Socket 的回调都在后台线程直接更新控件会抛InvalidOperationException。正确做法是用Control.Invoke或Dispatcher.Invoke。// WinForms 示例 private void OnSerialDataReceived(byte[] data) { if (this.InvokeRequired) { this.Invoke(new Actionbyte[](OnSerialDataReceived), data); return; } // 这里已经在 UI 线程可以安全更新控件 txtLog.AppendText(BitConverter.ToString(data) Environment.NewLine); }逻辑说明InvokeRequired判断当前线程是不是 UI 线程不是就Invoke回 UI 线程。Invoke是同步的会阻塞后台线程直到 UI 处理完如果 UI 处理慢串口收包会受影响。高频场景可以用BeginInvoke异步投递但要注意消息堆积。参数说明Invoke和BeginInvoke的选择取决于数据频率。低频每秒几条用Invoke没问题高频每秒几百条用BeginInvoke并加节流比如每 100ms 批量更新一次 UI。4.3 一个完整的转发 Demo 主流程public class DataBridge { private SerialPortService _serial; private TcpClientService _tcp; public void Start(string comPort, int baudRate, string host, int port) { _serial new SerialPortService(); _serial.Open(comPort, baudRate, Parity.None, 8, StopBits.One); _tcp new TcpClientService(host, port); _tcp.Start(); // 串口收到数据后转发到 Socket _serial.OnFrameReceived frame { string hex BitConverter.ToString(frame); _tcp.Send(hex); }; // Socket 收到指令后转发到串口 _tcp.OnMessageReceived msg { byte[] data Encoding.UTF8.GetBytes(msg); _serial.Send(data); }; } }逻辑说明这里用事件解耦串口和 Socket 互不直接依赖。实际项目里事件回调要注意异常捕获一个回调抛异常不能影响其他回调。参数说明OnFrameReceived是自定义事件在ProcessFrame解析出完整帧后触发。事件回调里不要做耗时操作否则会阻塞消费线程。5. 避坑与排查那些让 Demo 翻车的细节5.1 串口打开失败端口被占用或权限不足现象SerialPort.Open()抛UnauthorizedAccessException或IOException。原因端口被其他程序占用比如串口助手没关或者当前用户没有权限访问该端口。解决先用GetPortNames()确认端口存在再检查是否有其他程序占用。如果是权限问题以管理员身份运行或者检查设备管理器里端口是否正常。拔插 USB 转串口线后端口号可能变代码里不要写死 COM 号。5.2 串口收到乱码波特率或校验位不匹配现象收到的字节全是0xFF或随机值或者一个字节都收不到。原因波特率、数据位、停止位、校验位中有一个和设备不一致。解决用串口助手逐个参数试确认能正常收到数据后再写进代码。特别注意有些设备标称 9600 但实际是 9600 8N1有些是 9600 8E1校验位差一位就全乱。5.3 Socket 连接成功但收不到数据缓冲区或粘包问题现象Connect成功Send也成功但Receive一直阻塞或收到不完整数据。原因TCP 是流协议没有消息边界。服务端发 100 字节客户端可能分多次收到。如果代码假设一次Read就是一条完整消息就会解析失败。解决和串口一样定协议、加帧头、按长度读取。或者用StreamReader按行读前提是协议里有换行符。5.4 断线重连写成死循环CPU 跑满现象服务端没启动时客户端疯狂重连CPU 占用飙升。原因重连循环里没有Sleep或者Sleep时间太短。解决重连间隔至少 1 秒推荐 3 秒起步。更好的做法是指数退避避免服务端长时间不可用时客户端一直高频重试。5.5 跨线程操作 UI 崩溃InvalidOperationException现象程序运行一段时间后随机崩溃异常信息是「线程间操作无效」。原因串口或 Socket 回调在后台线程直接更新了 UI 控件。解决所有 UI 更新都通过Invoke或BeginInvoke回到 UI 线程。高频场景用BeginInvoke并做批量合并避免消息队列堆积。6. 进阶技巧让双通道 Demo 更接近生产可用Demo 跑通只是第一步要接近生产可用还有几件事值得做。第一加日志。串口和 Socket 的收发都要记日志出问题时能回溯。日志至少包含时间戳、方向、字节内容。高频场景用异步日志库别用Console.WriteLine会拖慢主流程。第二加心跳。TCP 连接可能假死Connected属性不可靠。常见做法是每隔 30 秒发一个心跳包连续几次没响应就主动断开重连。串口也可以加心跳定期发查询帧收不到回复就认为设备离线。第三参数可配置。串口号、波特率、服务端地址、端口这些不要写死在代码里放到配置文件或界面里。现场调试时改配置比改代码快得多。第四异常隔离。串口异常不能影响 SocketSocket 异常不能影响串口。每个回调里都要try-catch记录异常但不要让它扩散。我见过一个 Demo串口拔线抛异常直接把整个程序带崩了就是因为事件回调里没兜住。第五资源释放。SerialPort和TcpClient都实现了IDisposable程序退出时要确保关闭。SerialPort有个坑如果不取消事件订阅就Close可能触发DataReceived导致异常。正确顺序是先取消订阅再Close再Dispose。public void Dispose() { _running false; _worker?.Join(500); if (_port ! null) { _port.DataReceived - OnDataReceived; // 先取消订阅 if (_port.IsOpen) _port.Close(); // 再关闭 _port.Dispose(); // 最后释放 } }这段顺序是我踩过坑之后固定下来的。有一次没取消订阅就Close程序退出时偶发崩溃查了半天才定位到事件还在触发。最后说一个验证方法用虚拟串口工具建一对 COM 口一端跑你的程序一端跑串口助手模拟下位机收发。Socket 端用netcat或自己写个简单服务端模拟断线重连。这样不用真实硬件也能把大部分逻辑测一遍。我自己写这类 Demo 的习惯是先把串口和 Socket 各自单独跑通确认能收发再拼到一起。拼的时候先跑通一条链路再加另一条。一上来就写完整联动出问题很难定位是串口还是 Socket 的锅。希望帮到你。本文还有配套的精品资源点击获取