简介这份源码面向使用 VB.NET 进行网络编程的开发者尤其是需要搭建实时在线云消费机一卡通消费服务器端的初中级程序员。它基于 Socket 与 UDP 协议实现端口监听与消息收发展示了如何持续接收终端设备上报的消费数据并向端口回发信息开发者只需在此基础上接入数据库的增、删、查、改即可快速扩展为完整的实时一卡通消费系统也可作为学习 VB.NET 网络通信与端口监听的实践范例。资源包共 105 个文件约 2.91MB包含 8 个 vb 源码文件、26 个 dll 依赖库、7 个 exe 可执行程序以及 config 配置、xml 与 resx 资源、bat 控件注册脚本等覆盖工程编译与运行所需的主要组件。目前已有 199 人学习下载。通过阅读源码可掌握 UDP 监听、消息收发与工程结构组织方式并借助注册脚本与配置文件快速跑通示例为后续接入数据库、构建实时消费系统提供可直接复用的骨架与排错参考。1. 从一台收银机的 UDP 心跳说起这套 VB.NET 服务端源码到底能跑什么做过一卡通消费系统的人大概都遇到过这种场景几十台消费机分布在食堂、超市、门禁点位上机器每隔几秒往服务器发一次心跳和交易流水服务器要实时收、实时回、实时落库。用 TCP 当然稳但设备端资源紧张、连接数一多握手和断线重连就成了玄学。这时候 UDP 反而成了更务实的选择——无连接、开销小、设备端实现简单丢一两条心跳不影响业务交易流水靠重传和序号兜底就行。这份vb.net Socket Udp实时在线云消费机服务器端源码.rar就是干这个的一个用 VB.NET 写的 UDP 服务端示例核心是监听指定 UDP 端口、接收消费机上报的数据、向端口回发指令把网络通信这层骨架搭好。它不包含数据库增删查改作者在摘要里也明说了——你只要在这套通信框架上接上自己的数据库操作就能快速拼出一个实时在线的一卡通消费系统。适合谁做 VB.NET 网络编程、需要快速验证 UDP 端口监听和收发逻辑的从业者尤其是手上已经有消费机设备、缺一个服务端原型的团队。下面我按「这是什么 → 怎么用 → 坑在哪」的顺序把这包东西拆开讲透。2. 拆包看结构UDP 服务端骨架与注册脚本怎么配合2.1 从文件清单反推这套源码的组成拿到压缩包先别急着双击运行先看目录里有什么。从项目正文给出的文件清单能看出两类关键内容一类是32位系统注册控件.bat和64位系统注册控件.bat另一堆是DesignTimeResolveAssemblyReferences.cache和DesignTimeResolveAssemblyReferencesInput.cache。前者说明这套工程依赖某个 COM 控件或第三方组件需要按系统位数分别注册后者是 Visual Studio 设计器在解析程序集引用时生成的缓存文件属于 IDE 副产物不是业务代码。这里有个判断.cache文件是 VS 打开工程时自动生成的删掉不影响编译重新打开解决方案会再生成。真正要关注的是那两个.bat。VB.NET 工程里出现「注册控件」脚本通常意味着项目引用了 ActiveX/COM 组件比如某些厂商的加密狗、串口控件、或者老式的通信组件这类组件在 32 位和 64 位下的注册路径和regsvr32调用方式不一样所以作者才拆成两个脚本。文件/类型作用是否必须32位系统注册控件.bat在 32 位系统注册 COM 组件32 位环境必须64位系统注册控件.bat在 64 位系统注册 COM 组件64 位环境必须DesignTimeResolveAssemblyReferences.cacheVS 设计器程序集解析缓存否可删DesignTimeResolveAssemblyReferencesInput.cache同上输入侧缓存否可删2.2 注册脚本先跑再谈编译很多人拿到带.bat的源码直接开 VS 编译结果报「未注册的类」或者「ActiveX 组件无法创建实例」这就是没先跑注册脚本。正确顺序是先确认系统位数再以管理员身份运行对应的 bat。# 先看系统是 32 位还是 64 位 wmic os get osarchitecture # 64 位系统以管理员身份运行 # 右键 64位系统注册控件.bat - 以管理员身份运行 # 32 位系统以管理员身份运行 # 右键 32位系统注册控件.bat - 以管理员身份运行逻辑说明wmic os get osarchitecture返回64-bit或32-bit决定你跑哪个脚本。注册脚本内部一般是调用regsvr32注册某个.ocx或.dll必须以管理员权限运行否则会弹「模块已加载但找不到入口点」或者直接静默失败。参数上没什么可调的关键是权限和位数匹配——64 位系统上如果误跑了 32 位脚本组件会注册到 WOW6432Node 下64 位进程照样找不到。提示注册成功后建议重启一次 Visual Studio让设计器重新加载组件引用否则工具箱里可能还是看不到控件。2.3 UDP 监听端口这段代码在干什么通信骨架的核心就两件事绑定端口收数据、拿到远端地址回数据。VB.NET 里用UdpClient是最省事的写法比裸Socket少写一堆EndPoint转换。下面这段是我按这套源码的典型结构还原的监听循环参数和写法都贴近实际工程。Imports System.Net Imports System.Net.Sockets Imports System.Text Module UdpServer 监听端口消费机端要跟这里保持一致 Private Const ListenPort As Integer 8000 接收缓冲区大小UDP 单包别超过 1472 字节更稳 Private Const BufferSize As Integer 1024 Sub Main() Dim server As New UdpClient(ListenPort) Dim remoteEP As New IPEndPoint(IPAddress.Any, 0) Console.WriteLine(UDP 服务端已启动监听端口 ListenPort) While True Try Receive 会阻塞直到有数据到达 Dim data As Byte() server.Receive(remoteEP) Dim msg As String Encoding.ASCII.GetString(data) Console.WriteLine(来自 remoteEP.ToString() 的数据 msg) 回发应答消费机靠这个判断在线状态 Dim reply As Byte() Encoding.ASCII.GetBytes(ACK) server.Send(reply, reply.Length, remoteEP) Catch ex As Exception 单包异常不要退出循环否则一台设备发脏数据整个服务就挂了 Console.WriteLine(接收异常 ex.Message) End Try End While End Sub End Module逻辑说明UdpClient(ListenPort)构造时直接完成绑定等价于Bind加IPEndPoint。Receive(remoteEP)是阻塞调用remoteEP用ByRef传出拿到的是发送方的地址和端口回发时必须用这个地址不能自己拼。Encoding.ASCII适合纯文本协议如果消费机发的是二进制帧带包头、长度、CRC要换成按字节解析。参数说明ListenPort必须和消费机配置的目标端口一致常见是 8000、9000 这类BufferSize设 1024 够收心跳和短指令但 UDP 单包理论最大 65507 字节实际超过 1472 字节就可能被 IP 层分片丢一片整包就废所以协议设计上尽量让单包小。Catch里只打印不Exit While这是血泪经验——UDP 是无连接的任何一台设备发来畸形数据都可能触发异常循环一退服务就没了。3. 把通信骨架接上数据库从收包到落库的完整链路3.1 先定协议格式再写解析UDP 服务端最容易翻车的地方不是 Socket 本身而是协议没定清楚就开始写解析。消费机上报的数据一般包含设备号、卡号、金额、交易类型、时间戳、校验位。如果直接拿字符串Split设备号里带个分隔符就全乱了。常见做法是定长字段加分隔符或者干脆用二进制帧。 假设协议格式设备号(8)|卡号(10)|金额(8)|类型(2)|时间(14) 例DEV00001|CARD000123|00001000|01|20240517103000 Private Function ParseRecord(raw As String) As ConsumptionRecord Dim parts As String() raw.Split(|c) If parts.Length 5 Then Throw New FormatException(字段数不足原始数据 raw) End If Dim rec As New ConsumptionRecord() rec.DeviceId parts(0).Trim() rec.CardNo parts(1).Trim() 金额按分存储避免浮点误差 rec.Amount Integer.Parse(parts(2)) / 100.0 rec.TradeType parts(3).Trim() rec.TradeTime DateTime.ParseExact(parts(4), yyyyMMddHHmmss, Nothing) Return rec End Function逻辑说明先Split再逐字段校验字段数不够直接抛异常让上层决定是丢弃还是记录。金额用整数分存储再除 100这是消费系统的铁律——用Double存钱迟早对不上账。DateTime.ParseExact指定格式比DateTime.Parse更严格能挡住格式错误的脏数据。参数说明分隔符选|是因为它不容易出现在设备号和卡号里如果设备端能改协议建议加一个包头字节和长度字段解析时先校验长度再解析内容能挡掉大部分半包和粘包问题虽然 UDP 本身不粘包但设备端拼包发就可能超长。3.2 落库这段别写在接收循环里新手最容易犯的错是把数据库操作直接塞进While True的接收循环里。UDP 收包是高频的几十台设备每秒可能上百包每包都开一次数据库连接连接池瞬间打满服务直接卡死。正确做法是接收和落库解耦接收线程只管收收到就丢进队列后台线程从队列取数据批量写库。Imports System.Collections.Concurrent Imports System.Threading 线程安全队列接收线程写落库线程读 Private Shared ReadOnly Queue As New ConcurrentQueue(Of ConsumptionRecord)() 接收线程里解析完直接入队不做数据库操作 Queue.Enqueue(rec) 落库线程批量取批量提交 Private Sub DbWorker() Dim batch As New List(Of ConsumptionRecord)() While True Dim rec As ConsumptionRecord Nothing If Queue.TryDequeue(rec) Then batch.Add(rec) 攒够 50 条或超过 1 秒就提交 If batch.Count 50 Then BulkInsert(batch) batch.Clear() End If Else If batch.Count 0 Then BulkInsert(batch) batch.Clear() End If Thread.Sleep(200) End If End While End Sub逻辑说明ConcurrentQueue是 .NET 自带的线程安全队列接收线程Enqueue落库线程TryDequeue不用自己加锁。批量提交把 N 次数据库往返压成 1 次吞吐量能差一个数量级。Thread.Sleep(200)在队列空时让出 CPU避免空转。参数说明批量阈值 50 和休眠 200ms 是我一般会用的起点设备多、流水大就调大批量、缩短休眠设备少就调小保证实时性。BulkInsert里用事务包住整批任何一条失败整批回滚避免部分写入导致对账不平。3.3 回发指令与在线状态判定消费机判断自己是否在线靠的是服务端有没有回ACK。如果服务端只收不回设备端会一直重发或者标记离线。回发逻辑要跟接收在同一个循环里拿到remoteEP立刻回别绕到别的线程去否则地址对不上。 收到心跳包回发在线确认 If msg.StartsWith(HEARTBEAT) Then Dim ack As Byte() Encoding.ASCII.GetBytes(ONLINE) server.Send(ack, ack.Length, remoteEP) 记录设备最后在线时间用于超时判定 UpdateDeviceHeartbeat(remoteEP.Address.ToString(), DateTime.Now) End If逻辑说明心跳包单独识别回ONLINE而不是通用ACK方便设备端区分。UpdateDeviceHeartbeat把设备 IP 和最后在线时间写进内存字典或数据库后台再起一个定时器扫描超过阈值没心跳的设备标记离线。参数说明心跳间隔一般设备端设 5 到 10 秒服务端超时阈值设 3 倍间隔比如 30 秒没心跳判离线。阈值太短会误判网络抖动太长离线发现慢30 秒是常见折中。4. 避坑与排查UDP 服务端上线前必须过的五道坎4.1 端口被占用服务起不来现象程序一启动就抛SocketException提示「通常每个套接字地址只允许使用一次」。原因目标端口已经被别的进程占用或者上一次调试的程序没退干净还占着端口。解决先用netstat查谁占了端口杀掉或换端口。# Windows 下查端口占用 netstat -ano | findstr :8000 # 拿到 PID 后查进程 tasklist | findstr PID如果确认是自己的调试进程残留任务管理器结束掉如果是别的服务占用改ListenPort换一个。注意 UDP 端口和 TCP 端口是两套命名空间TCP 占了 8000 不影响 UDP 用 8000但两个 UDP 程序抢同一个端口就会报这个错。4.2 收不到数据防火墙背锅现象本机自测能收能发一放到服务器上就收不到任何包。原因Windows 防火墙默认拦入站 UDP或者云服务器安全组没放行对应端口。解决在防火墙入站规则里加一条 UDP 端口放行云服务器还要在控制台安全组里加规则。# 命令行加防火墙入站规则管理员权限 netsh advfirewall firewall add rule nameUDP8000 dirin actionallow protocolUDP localport8000这条命令加完立即生效不用重启。云服务器的话netsh只管系统防火墙安全组得去云控制台单独配两层都放行才通。排查时先用udp端口测试工具从外网发一个包看服务端有没有反应能快速定位是网络层还是代码层的问题。4.3 中文乱码编码没对齐现象收到的设备号或卡号是乱码。原因设备端用 GBK 编码发服务端用Encoding.ASCII或Encoding.UTF8解字节对不上。解决两端约定同一种编码VB.NET 里用Encoding.GetEncoding(GBK)显式指定。 设备端如果是 GBK服务端必须一致 Dim gbk As Encoding Encoding.GetEncoding(GBK) Dim msg As String gbk.GetString(data)Encoding.ASCII只能表示 128 个字符中文直接丢Encoding.UTF8和 GBK 对中文的字节序列不同混用必乱。最稳的办法是协议里全用数字和字母中文只存在数据库里传输层不碰中文。4.4 单包过大被分片丢一片整包废现象小数据包正常一发长数据就丢或者解析失败。原因UDP 单包超过 MTU以太网一般 1500 字节去掉 IP 和 UDP 头剩 1472会被 IP 层分片任何一片丢失整个包就废了而且分片重组失败时接收方根本收不到。解决协议设计上控制单包在 1472 字节以内超长数据拆成多个包自己加序号和重组逻辑。 发送前检查长度超长就拆包 If data.Length 1472 Then 拆成多个包每包带序号接收端按序号重组 SendFragmented(data, remoteEP) Else server.Send(data, data.Length, remoteEP) End If这条坑在局域网里不容易暴露一上广域网或者跨网段就频繁翻车。我的习惯是协议里直接规定单包上限 1024 字节留足余量。4.5 阻塞接收卡死界面无响应现象WinForm 程序里点「启动服务」后界面直接卡住按钮点不动。原因UdpClient.Receive是阻塞调用写在 UI 线程里会把消息循环堵死。解决把接收循环放到独立线程或Task里UI 线程只负责启停和显示。 用 Task 跑接收循环不阻塞 UI Private Sub StartServer() Task.Run(Sub() While _running Try Dim data As Byte() _server.Receive(_remoteEP) 处理数据... Catch ex As Exception 记录日志 End Try End While End Sub) End Sub_running是个布尔标志点「停止」时置False循环退出。注意Receive阻塞时置False不会立即退出得等下一次收包或者调用Close强制中断实际工程里我会在停止时直接_server.Close()让Receive抛异常跳出。5. 进阶用 CRC16 校验和序号机制把 UDP 做成「准可靠」UDP 本身不保证送达、不保证顺序、不保证不重复但消费系统的交易流水不能丢也不能重。纯靠 UDP 裸奔肯定不行得在应用层加一层轻量可靠性机制。这套源码给的是通信骨架真正上线前我建议补两样东西CRC16 校验和序号去重。先说 CRC16。设备端发数据时在包尾附两个字节的 CRC16 校验值服务端收到后先算一遍 CRC16跟包尾比对不一致直接丢弃。这样能挡掉传输过程中被篡改或损坏的包。VB.NET 里 CRC16 要自己实现网上有现成的查表法代码核心是按字节异或再查表。 CRC16-MODBUS 查表法多项式 0xA001 Private Shared ReadOnly CrcTable As UShort() BuildCrcTable() Private Shared Function BuildCrcTable() As UShort() Dim table(255) As UShort For i As Integer 0 To 255 Dim crc As UShort CType(i, UShort) For j As Integer 0 To 7 If (crc And 1) 0 Then crc CType((crc 1) Xor HA001, UShort) Else crc CType(crc 1, UShort) End If Next table(i) crc Next Return table End Function Private Shared Function ComputeCrc16(data As Byte()) As UShort Dim crc As UShort HFFFF For Each b As Byte In data crc CType((crc 8) Xor CrcTable((crc Xor b) And HFF), UShort) Next Return crc End Function逻辑说明BuildCrcTable预生成 256 项查表ComputeCrc16逐字节更新初始值0xFFFF这是 MODBUS 标准参数。收发两端必须用同一套多项式和初始值否则校验永远不过。参数上0xA001是0x8005的反转形式MODBUS 常用跟设备端确认清楚用哪个变种。再说序号去重。设备端每发一条交易流水带一个自增序号服务端维护每个设备的「已处理最大序号」收到序号小于等于已处理最大值的直接丢弃大于的才落库并更新。这样即使设备端因为没收到 ACK 而重发服务端也不会重复扣款。 设备序号去重字典 key 是设备号 Private Shared ReadOnly LastSeq As New ConcurrentDictionary(Of String, Long)() Private Function IsDuplicate(deviceId As String, seq As Long) As Boolean Dim last As Long LastSeq.GetOrAdd(deviceId, 0L) If seq last Then Return True End If LastSeq(deviceId) seq Return False End Function逻辑说明GetOrAdd拿当前设备已处理的最大序号新序号不大于它就判重。ConcurrentDictionary保证多线程下安全。参数上序号用Long防止溢出设备端重启后序号归零的问题要单独处理——常见做法是设备端重启后从服务端拉一次当前最大序号或者序号里带时间戳高位。验证方法本地起两个控制台一个模拟设备端按固定间隔发带 CRC 和序号的包故意发几个重复序号和错误 CRC 的包看服务端日志是不是正确丢弃。我一般会写个简单的测试脚本发 1000 个包其中 100 个重复、50 个 CRC 错误最后核对落库条数是不是 850。这个测试跑通基本就能上生产了。从那以后我每次接 UDP 类的服务端都强制先把 CRC 校验和序号去重这两层加上再联调不然等设备铺出去再回头改协议那才叫后悔药没处买。希望帮到你。本文还有配套的精品资源点击获取