c#软件开发学习笔记--TCP 粘包拆包、SqlSugar 框架-北京尧图网络

学习总结TCP 粘包拆包与 SqlSugar 框架一、TCP 粘包与拆包1.1 问题背景TCP 是面向字节流的协议发送方写入的数据在接收方看来是一条连续不断的字节流没有边界。因此会出现以下三种现象现象说明粘包多次发送的消息被合并成一次接收例如两条短消息挤在一个数据包中到达拆包一条消息被拆成多次接收例如大消息被网络层切成多个数据包混合既有粘包又有拆包同时发生注意粘包拆包不是 TCP 的 Bug而是字节流协议的固有特性。UDP 是面向报文的协议不存在此问题。1.2 常见解包方案消息定长每条消息固定长度不足补齐。特殊分隔符例如以\r\n结尾FTP、HTTP 头部采用此方式。头部长度字段本案例采用在消息体前加一个固定长度的头部记录消息体的字节长度。1.3 协议设计本案例本案例采用“4 字节头变长消息体”的方案------------------------------- | Header | Body | | 4 bytes | N bytes | | (body长度) | (UTF8 文本) | -------------------------------头部4 字节整数存储消息体的字节长度字节序网络字节序大端使用IPAddress.HostToNetworkOrder/NetworkToHostOrder转换消息体UTF-8 编码的字符串1.4 关键代码1.4.1 编码消息 → 字节流/// summary/// 将字符串编码为「4字节长度头消息体」的字节包/// /summaryprivatebyte[]EncodePackage(stringmsg){byte[]dataEncoding.UTF8.GetBytes(msg);// 将消息体长度转为网络字节序大端保证跨平台一致byte[]headLengthBitConverter.GetBytes(IPAddress.HostToNetworkOrder(data.Length));byte[]packagenewbyte[4data.Length];Array.Copy(headLength,package,headLength.Length);// 头部Array.Copy(data,0,package,4,data.Length);// 消息体returnpackage;}1.4.2 解码从字节流中循环抽取完整包/// summary/// 从缓冲区 bsList 中循环解析出完整消息/// 粘包一次能解析出多条拆包长度不足时跳出等待下次数据/// /summaryprivatevoidTryParsePackage(){while(bsList.Count4)// 至少要有 4 字节头部{byte[]headBytesbsList.GetRange(0,4).ToArray();intbodyLengthIPAddress.NetworkToHostOrder(BitConverter.ToInt32(headBytes,0));inttotalLength4bodyLength;if(bsList.CounttotalLength)break;// 拆包包不完整等下一次byte[]bodyDatabsList.GetRange(4,bodyLength).ToArray();stringmsgEncoding.UTF8.GetString(bodyData);AppendLog(收到消息msg);bsList.RemoveRange(0,totalLength);// 移除已解析部分继续解析下一个}}1.4.3 接收数据缓冲/// summary/// 异步循环读取网络流累积到 bsList 后尝试解析/// /summaryprivatevoidReceiveData(TcpClientclient){ctsnewCancellationTokenSource();Task.Run(async(){byte[]buffernewbyte[1024];while(!cts.IsCancellationRequested){NetworkStreamstreamclient.GetStream();intlenawaitstream.ReadAsync(buffer,cts.Token);if(len0){AppendLog(客户端断开连接);break;}byte[]realDatanewbyte[len];Array.Copy(buffer,realData,len);bsList.AddRange(realData);// 关键累积到缓冲区TryParsePackage();}},cts.Token);}1.5 流程示意发送端 msg ──EncodePackage── [4字节头][body] ── stream.Write 接收端 stream.Read ── bsList.AddRange ── TryParsePackage (while循环) │ ┌─────────────┴─────────────┐ │ bsList.Count 4 ? │ │ 取出头部 → bodyLength │ │ 总长 4bodyLength │ │ 不足 → break (拆包等待) │ │ 足够 → 取body → 处理 → 移除 │ └───────────────────────────┘1.6 要点小结✅ 用Listbyte作为接收缓冲区累积所有到达字节✅ 用while循环解析一次可拆出多个包解决粘包✅ 包不完整时break等待下次数据解决拆包✅ 头部使用网络字节序保证收发双方字节序一致✅ 解析完一个包后必须RemoveRange移除已处理部分二、SqlSugar 第三方 ORM 框架2.1 框架简介SqlSugar是一款老牌国产 .NET ORM 框架由果糖大数据科技团队维护开箱即用、易于上手。2.2 两种使用模式模式类特点原生模式SqlSugarClient高性能每次 new 新对象禁止单例单例模式SqlSugarScope对新手友好解决大部分线程安全问题必须单例2.3 核心配置本案例采用原生模式/// summary/// 窗体加载时初始化 SqlSugarClient/// /summaryprivatevoidForm1_Load(objectsender,EventArgse){dbnewSqlSugarClient(newConnectionConfig(){ConnectionStringserver localhost,64345; database sugarDemo.db; uid sa; pwd 123123;EncryptTrue;TrustServerCertificateTrue,DbTypeDbType.SqlServer,IsAutoCloseConnectiontrue,// 自动关闭连接省去手动 using},db{// AOP执行 SQL 时打印原生 SQL方便调试db.Aop.OnLogExecuting(sql,pars){Console.WriteLine(UtilMethods.GetNativeSql(sql,pars));};});}2.4 实体定义[SugarTable]// 标记为数据库表publicclassStudent{[SugarColumn(IsPrimaryKeytrue,IsIdentitytrue)]// 主键自增publicintId{get;set;}publicstringName{get;set;}publicint?Age{get;set;}// 可空类型对应数据库可空字段}2.5 数据库与表初始化// 创建数据库若不存在db.DbMaintenance.CreateDatabase();// CodeFirst根据实体类自动生成/同步表结构db.CodeFirst.InitTables(typeof(Student));2.6 核心 APICRUD操作API示例增db.InsertableT(entity).ExecuteCommand()db.Insertable(list).ExecuteCommand()删db.DeleteableT(entity).ExecuteCommand()db.DeleteableStudent(stu).ExecuteCommand()改db.UpdateableT(entity).ExecuteCommand()db.UpdateableStudent(stu).ExecuteCommand()查db.QueryableT()...ToList()db.QueryableStudent().Single(s s.Id id)2.6.1 批量插入ListStudentlistnewListStudent(){newStudent(){Name张三1,Age100},newStudent(){Name张三2,Age200},newStudent(){Name张三3,Age300},};introwdb.Insertable(list).ExecuteCommand();2.6.2 条件查询动态拼接使用ExpressionableT动态拼接 where 条件避免写大量 if-else 分支 SQL。/// summary/// 根据界面输入条件动态拼接查询条件并分页绑定 DataGridView/// /summaryprivatevoidBindView(){if(dbnull)return;varexpressExpressionable.CreateStudent();// AndIF仅当条件成立时追加 AND 过滤express.AndIF(!string.IsNullOrWhiteSpace(textBox1.Text),ss.Name.Contains(textBox1.Text));express.AndIF(!string.IsNullOrWhiteSpace(textBox2.Text),ss.Ageint.Parse(textBox2.Text));express.AndIF(!string.IsNullOrWhiteSpace(textBox3.Text),ss.Ageint.Parse(textBox3.Text));varlistdb.QueryableStudent().Where(express.ToExpression()).ToPageList(pageNumber,pageSize,reftotalCount,reftotalPages).ToList();dataGridView1.DataSourcelist;label2.Text${pageNumber}/{totalPages};}2.6.3 修改与删除按主键定位// 修改先查后改intidint.Parse(dataGridView1.SelectedRows[0].Cells[Id].Value!.ToString()!);Studentstudb.QueryableStudent().Single(ss.Idid);stu.Name三生三世;stu.Age100;db.UpdateableStudent(stu).ExecuteCommand();// 删除Studentstudb.QueryableStudent().Single(ss.Idid);db.DeleteableStudent(stu).ExecuteCommand();2.7 分页查询要点ToPageList(pageNumber, pageSize, ref totalCount, ref totalPages)一次返回当前页数据总数总页数翻页只需修改pageNumber后重新调用BindView()每页条数变更时应重置pageNumber 1避免越界2.8 要点小结✅IsAutoCloseConnection true让连接管理自动化避免资源泄漏✅Aop.OnLogExecuting是调试 SQL 的利器✅ExpressionableT适合动态条件查询场景✅CodeFirst.InitTables实现代码先行实体变更直接同步表结构✅ CRUD 全部链式调用统一以ExecuteCommand()增删改或ToList()/Single()查收尾三、关联知识点ADO.NET 五大对象SqlConnection、SqlCommand、SqlDataAdapter、SqlDataReader、DataSetSqlSugar 底层即基于此封装。IOC / DISqlSugarClient 推荐使用 Scope 或瞬发注入禁止单例。网络字节序TCP 自定义协议应统一使用大端序HostToNetworkOrder/NetworkToHostOrder。

c#软件开发学习笔记--TCP 粘包拆包、SqlSugar 框架

相关推荐

如何批量实现抖音视频下载无水印？我的实测记录与避坑指南

基于ESP32与FOC控制的自主越野载具：硬件架构与软件实现

【毕设作品】基于Flask的游戏推荐系统的设计与实现

更多资讯

Python机器学习人脸识别系统：从期末大作业到门禁机实战

基于Python的单通道脑电睡眠分期：从数据到模型全流程实战

Python机器学习实战：从环境配置到模型训练复现的完整流程

供应链断裂与重构测度：基于Python的级联失效与替代路径实现

Python车牌识别计费系统实战：从OCR识别到状态机与跨天计费

南开编译原理作业实战：简单C语言编译器源码解析与避坑指南

今日更新

Susi AI API实战指南：susi_alexa_skill如何用Node.js调用chat.json获取智能回答

换新电脑了？KeyStats 恢复码数据找回完全指南，端到端加密统计一键重建

重建二叉树：由前序与中序遍历序列还原二叉树的原理与 Java 实现（YCBlogs 剑指 Offer 精讲）

本周精选

交通拥堵预测毕设：基于Python+LSTM的车辆流量预测系统全流程解析

MATLAB/Simulink搭建10机39节点电力系统暂态稳定仿真实战

无人机航拍三维重建全流程：从SfM到网格生成的避坑指南

本月热门

我发现了一个新思路：用 Remotion + Claude Code 像写代码一样自动化生成短视频

Windows下 Codex 中 Chrome 和 Computer Use 插件不可用问题排查及解决参考方式：TaoToken 统一 Key 配置与验证

2026 大模型集体涨价：用 Python 做企业 Token 成本测算与选型避坑（附配置）

读完文章，想聊聊您的网站？