tcp 客户端进行拆包

2024-06-21 16:04
文章标签 进行 客户端 tcp 拆包

本文主要是介绍tcp 客户端进行拆包,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

心跳机制服务器

Server
 TcpListener listen;public Server(IPAddress ip,int port) {listen = new TcpListener(ip, port);} public void Start(){listen.Start(100);StartConnect();  }Dictionary<string,TcpClient> clientDic = new Dictionary<string,TcpClient>();public event Action<TcpClient> 有客户端连入的事件; void StartConnect(){Task.Run(() =>{while (true) {TcpClient client = listen.AcceptTcpClient();string ip = client.Client.RemoteEndPoint.ToString(); clientDic.Add(ip, client);有客户端连入的事件?.Invoke(client);startRead(client);//读取粘包的数据,在这个方法进行拆包处理}});}//拆包public void startRead(TcpClient t1){//接受客户端发来的数据NetworkStream stream = t1.GetStream();string ip = t1.Client.RemoteEndPoint.ToString();byte[] bs = new byte[1024 * 1024];Task.Run(() =>{try{while (true){int count=  stream.Read(bs, 0, bs.Length);if (count== 0){throw new Exception("客户端断了");}//接受数据byte[] body = bs.Take(count).ToArray();string s = Encoding.UTF8.GetString(body);Console.WriteLine("-------------------------------");Console.WriteLine("接收到消息为:"+s);Console.WriteLine("-------------------------------");Send(s);// 群发}}catch (Exception ex){clientDic.Remove(ip);}});}public event Action<string> 客户端断开事件; public event Action<TcpClient, byte[]> 接受到消息的事件;public Server(){}//群发方法 向所有的客户端发消息public void Send(string content){byte[] bs = Encoding.UTF8.GetBytes(content);foreach (var item in clientDic) //遍历所有的客户端{item.Value.GetStream().Write(bs, 0, bs.Length);}}//指定给谁发public void Send(string content,string ip) {byte[] bs = Encoding.UTF8.GetBytes(content);//根据ip取出客户端,从字典取clientDic[ip].GetStream().Write(bs, 0, bs.Length);}//指定给哪些客户端发//send("你好", ["192.","127"])public void Send(string content, string[] ips){byte[] bs = Encoding.UTF8.GetBytes(content);foreach (var item in clientDic) //所有客户端{//item.key 键 ip字符串//item.value 值 客户端对象if (ips.Contains(item.Key)){//如果ips数组包含目标客户端item.Value.GetStream().Write(bs, 0, bs.Length);}}}

Program

static Server s;static void Main(string[] args){s = new Server(IPAddress.Any,8080);s.有客户端连入的事件 += f1;s.接受到消息的事件 += f2;s.Start();Console.ReadKey();}public static void f1(TcpClient t1){Console.WriteLine(t1.Client.RemoteEndPoint.ToString()+"连接到服务器");}public static void f2(TcpClient t2, byte[] bs){Console.WriteLine(t2.Client.RemoteEndPoint.ToString()+"发来的消息为+++++++++++:"+ Encoding.UTF8.GetString(bs,0,bs.Length));}

客户端

TcpClient client;public Form1(){InitializeComponent();client = new TcpClient();client.Connect("192.168.107.60",8080);// 开始接收数据startReceive(client);}void startReceive(TcpClient t1){byte[] bs = new byte[1024]; // 缓存区Task.Run(() =>{try{while (true){int count = t1.GetStream().Read(bs, 0, bs.Length);if(count == 0){Console.WriteLine("服务器断开");break;}// 去掉数据最后一位占位0byte[] data = bs.Take(count).ToArray();// 需不需要拆包Console.WriteLine(Encoding.UTF8.GetString(data));if(lastPack != null){data = lastPack.Concat(data).ToArray();lastPack = null;}ChaiBao(data, 0, t1);}}catch (Exception ex){Console.WriteLine("客户端断开");}});}byte[] lastPack = null;// 上一个半包public void ChaiBao(byte[] bs,int startIndex,TcpClient t1){if (startIndex + 4 > bs.Length){lastPack = bs.Skip(startIndex).ToArray(); // 跳过开始位置取出后面的return;}// 记录第一个包的长度int len = BitConverter.ToInt32(bs, startIndex);// 取出之前所有包的长度int abc = len + startIndex + 4;Console.WriteLine(abc + "?????" + bs.Length);if(abc == bs.Length){byte[] bs1 = bs.Skip(startIndex + 4).ToArray();richTextBox1.Invoke((Action)(() =>{richTextBox1.AppendText(Encoding.UTF8.GetString(bs1) + "\n");}));}else if (abc < bs.Length){byte[] bs2 = bs.Skip(startIndex + 4).Take(len).ToArray();richTextBox1.Invoke((Action)(() =>{richTextBox1.AppendText(Encoding.UTF8.GetString(bs2) + "\n");richTextBox1.SelectionStart = richTextBox1.Text.Length;richTextBox1.ScrollToCaret();}));// 继续拆包ChaiBao(bs, abc, t1);}else{lastPack = bs.Skip(startIndex).ToArray();}}

直接发消息

调用MemoryStream进行添加数据长度的方法

Send(client.GetStream(), "大帅的几种形态");
Send(client.GetStream(), "精致大帅");
Send(client.GetStream(), "油腻大帅");
Send(client.GetStream(), "虚币大帅");
Send(client.GetStream(), "变态大帅");
Send(client.GetStream(), "人妻大帅");

没有使用MemoryStream进行添加数据长度

 Send("罗罗诺亚·索隆");Send("蒙奇·D·路飞");Send("文斯莫克·山治");Send("托尼托尼·乔巴");Send("妮可·罗宾");

MemoeySteream内存流把数据长度和数据内容写在一个包里

void Send(NetworkStream stream, string msg)
{byte[] bs = Encoding.UTF8.GetBytes(msg); // 先转成字符节数组MemoryStream ms = new MemoryStream();// 创建内存流BinaryWriter bw = new BinaryWriter(ms); // 创建内存流bw.Write(bs.Length);// 写入长度bw.Write(bs);// 写入内容stream.Write(ms.ToArray(), 0, ms.ToArray().Length);// 发送内容流bw.Close();// 关闭写入对象ms.Close();// 关闭内存流
}void Send(string msg)
{byte[] bs = Encoding.UTF8.GetBytes(msg); // 把发的消息转成字节数组// BitConverter 转成位数据// 把字节数组长度转成位格式数据byte[] len = BitConverter.GetBytes(bs.Length);byte[] body = len.Concat(bs).ToArray(); // 把数据长度和内容存在一个包里面    client.GetStream().Write(body, 0, body.Length);}

这篇关于tcp 客户端进行拆包的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1081674

相关文章

Pandas使用AdaBoost进行分类的实现

《Pandas使用AdaBoost进行分类的实现》Pandas和AdaBoost分类算法,可以高效地进行数据预处理和分类任务,本文主要介绍了Pandas使用AdaBoost进行分类的实现,具有一定的参... 目录什么是 AdaBoost?使用 AdaBoost 的步骤安装必要的库步骤一:数据准备步骤二:模型

使用Pandas进行均值填充的实现

《使用Pandas进行均值填充的实现》缺失数据(NaN值)是一个常见的问题,我们可以通过多种方法来处理缺失数据,其中一种常用的方法是均值填充,本文主要介绍了使用Pandas进行均值填充的实现,感兴趣的... 目录什么是均值填充?为什么选择均值填充?均值填充的步骤实际代码示例总结在数据分析和处理过程中,缺失数

QT进行CSV文件初始化与读写操作

《QT进行CSV文件初始化与读写操作》这篇文章主要为大家详细介绍了在QT环境中如何进行CSV文件的初始化、写入和读取操作,本文为大家整理了相关的操作的多种方法,希望对大家有所帮助... 目录前言一、CSV文件初始化二、CSV写入三、CSV读取四、QT 逐行读取csv文件五、Qt如何将数据保存成CSV文件前言

通过Spring层面进行事务回滚的实现

《通过Spring层面进行事务回滚的实现》本文主要介绍了通过Spring层面进行事务回滚的实现,包括声明式事务和编程式事务,具有一定的参考价值,感兴趣的可以了解一下... 目录声明式事务回滚:1. 基础注解配置2. 指定回滚异常类型3. ​不回滚特殊场景编程式事务回滚:1. ​使用 TransactionT

Java中使用Hutool进行AES加密解密的方法举例

《Java中使用Hutool进行AES加密解密的方法举例》AES是一种对称加密,所谓对称加密就是加密与解密使用的秘钥是一个,下面:本文主要介绍Java中使用Hutool进行AES加密解密的相关资料... 目录前言一、Hutool简介与引入1.1 Hutool简介1.2 引入Hutool二、AES加密解密基础

SpringSecurity6.0 如何通过JWTtoken进行认证授权

《SpringSecurity6.0如何通过JWTtoken进行认证授权》:本文主要介绍SpringSecurity6.0通过JWTtoken进行认证授权的过程,本文给大家介绍的非常详细,感兴趣... 目录项目依赖认证UserDetailService生成JWT token权限控制小结之前写过一个文章,从S

使用Jackson进行JSON生成与解析的新手指南

《使用Jackson进行JSON生成与解析的新手指南》这篇文章主要为大家详细介绍了如何使用Jackson进行JSON生成与解析处理,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录1. 核心依赖2. 基础用法2.1 对象转 jsON(序列化)2.2 JSON 转对象(反序列化)3.

C#使用SQLite进行大数据量高效处理的代码示例

《C#使用SQLite进行大数据量高效处理的代码示例》在软件开发中,高效处理大数据量是一个常见且具有挑战性的任务,SQLite因其零配置、嵌入式、跨平台的特性,成为许多开发者的首选数据库,本文将深入探... 目录前言准备工作数据实体核心技术批量插入:从乌龟到猎豹的蜕变分页查询:加载百万数据异步处理:拒绝界面

Python使用自带的base64库进行base64编码和解码

《Python使用自带的base64库进行base64编码和解码》在Python中,处理数据的编码和解码是数据传输和存储中非常普遍的需求,其中,Base64是一种常用的编码方案,本文我将详细介绍如何使... 目录引言使用python的base64库进行编码和解码编码函数解码函数Base64编码的应用场景注意

Java进行文件格式校验的方案详解

《Java进行文件格式校验的方案详解》这篇文章主要为大家详细介绍了Java中进行文件格式校验的相关方案,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录一、背景异常现象原因排查用户的无心之过二、解决方案Magandroidic Number判断主流检测库对比Tika的使用区分zip