C# 使用Pipelines处理Socket数据包

写在前面

在上一篇中对Pipelines进行简单的了解,同时也留下了未解的问题,如何将Pipelines类库运用到Socket通讯过程中来解决粘包和分包。链接地址如下: 初识System.IO.Pipelines icon-default.png?t=N7T8https://rjcql.blog.csdn.net/article/details/135211047

这一篇做了一个完整的demo,使用Pipelines接收和处理来自多个客户端发出的消息;相对于以往在报文包头放包体长度再结合结束符来判断的方式,确实要简洁了许多。

代码实现

服务端实现

using System.Net.Sockets;
using System.Net;
using System.Text;class Program
{static async Task Main(){SocketServerForPiplines();}static async void SocketServerForPiplines(){Console.WriteLine("Socket Server");// 创建服务端Socket对象var serverSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);serverSocket.Bind(new IPEndPoint(IPAddress.Parse("127.0.0.1"), 9090));serverSocket.ReceiveTimeout = 1000;serverSocket.SendTimeout = 1000;serverSocket.Listen(1000);Console.WriteLine("服务端启动监听");while (true){var clientSocket = serverSocket.Accept();Console.WriteLine("有客户端连上了");var handler = new PiplinesHandler(clientSocket);await handler.StartReceiveAsync();}Console.ReadLine();}
}

 PiplinesHandler 类:

using System;
using System.Buffers;
using System.Collections.Generic;
using System.IO.Pipelines;
using System.Linq;
using System.Net.Sockets;
using System.Text;
using System.Threading.Tasks;namespace PipelinesTester
{public class PiplinesHandler{private const int _minimumBufferSize = 512;private Socket _socket;private Pipe _pipe;public PiplinesHandler(Socket socket){_socket = socket;var options = new PipeOptions(pauseWriterThreshold: 4096, resumeWriterThreshold: 1024);_pipe = new Pipe(options);}public async Task StartReceiveAsync(){Task receiveTask = ReceiveMessageAsync();Task processTask = ProcessMessageAsync();await Task.WhenAll(receiveTask, processTask);}private async Task ReceiveMessageAsync(){PipeWriter writer = _pipe.Writer;while (true){try{//从writer申请缓冲区Memory<byte> memory = writer.GetMemory(_minimumBufferSize);//从socket读取数据,直接写入到缓冲区中,即直接写入了PipeWriter中        int bytesRead = await _socket.ReceiveAsync(memory, SocketFlags.None);if (bytesRead == 0){break;}//前移写标志位writer.Advance(bytesRead);//通知Reader,可以读取了var result = await writer.FlushAsync();if (result.IsCompleted)break;}catch (Exception e){Console.WriteLine(e);break;}}await writer.CompleteAsync();try{_socket.Shutdown(SocketShutdown.Both);_socket.Close();}catch (Exception e){Console.WriteLine(e);}}private async Task ProcessMessageAsync(){PipeReader _pipeReader = _pipe.Reader;while (true){//读取消息var result = await _pipeReader.ReadAsync();var buffer = result.Buffer;//查找结束符            SequencePosition? position = buffer.PositionOf((byte)'\n');if (position == null){continue;}// 处理消息var line = buffer.Slice(0, position.Value);string msg = Encoding.UTF8.GetString(line);Console.WriteLine(msg);// 前移PipeReaderbuffer = buffer.Slice(buffer.GetPosition(1, position.Value));_pipeReader.AdvanceTo(buffer.Start, buffer.End);// Stop reading if there's no more data coming.if (result.IsCompleted){break;}}await _pipeReader.CompleteAsync();}}
}

客户端实现

using System;
using System.Net;
using System.Net.Sockets;
using System.Text;class Program
{static void Main(string[] args){TcpClientTest();}static void TcpClientTest(){Console.WriteLine("TcpClient");var msg = $"这是来自客户端的消息{DateTime.Now.ToString("yyyy-MM-dd:HH:mm:ss")}\n";var client = new TcpClient("127.0.0.1", 9090);var sendStream = client.GetStream();var sendBytes = Encoding.Default.GetBytes(msg);sendStream.Write(sendBytes, 0, sendBytes.Length);sendStream.Flush();sendStream.Close();//关闭网络流  client.Close();//关闭客户端  Console.WriteLine(msg);Console.ReadLine();}
}

调用示例

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/580010.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

hasOwnProperty() 方法详解

hasOwnProperty() 方法详解 大家好&#xff0c;我是免费搭建查券返利机器人赚佣金就用微赚淘客系统3.0的小编&#xff0c;也是冬天不穿秋裤&#xff0c;天冷也要风度的程序猿&#xff01;今天&#xff0c;我们将深入研究JavaScript中的hasOwnProperty()方法&#xff0c;这是一…

Hive安装笔记——备赛笔记——2024全国职业院校技能大赛“大数据应用开发”赛项——任务2:离线数据处理

将下发的ds_db01.sql数据库文件放置mysql中 12、编写Scala代码&#xff0c;使用Spark将MySQL的ds_db01库中表user_info的全量数据抽取到Hive的ods库中表user_info。字段名称、类型不变&#xff0c;同时添加静态分区&#xff0c;分区字段为etl_date&#xff0c;类型为String&am…

前端开发之通过vue-office组件实现文件预览

前端开发之通过vue-office组件实现文件预览 前言效果图docx文件xlsx文件pdf文件 vue中简单案例1、安装组件2、vue中代码 前言 在实现文件预览的时候我们可以通过vue-office组件来实现文件的预览效果 效果图 docx文件 xlsx文件 pdf文件 vue中简单案例 1、安装组件 整体安装…

进行菜单程序分支,判断奇偶数,闰年,质数,完全平方数,回文数,素数,大小写字母等等

一、主要目的 通过编写一个简单的Java程序&#xff0c;加深对于条件语句和循环语句的理解&#xff0c;并练习使用Scanner类获取用户输入 二、主要内容 编写一个程序&#xff0c;根据用户输入的选项&#xff0c;执行相应的操作。用户可以选择判断一个整数是否为奇数、判断一个…

RabbitMQ入门指南(九):消费者可靠性

专栏导航 RabbitMQ入门指南 从零开始了解大数据 目录 专栏导航 前言 一、消费者确认机制 二、失败重试机制 三、失败处理策略 四、业务幂等性 1.通过唯一标识符保证操作的幂等性 2.通过业务判断保证操作的幂等性 总结 前言 RabbitMQ是一个高效、可靠的开源消息队列系…

词表示:语言与计算的桥梁

目录 前言1 什么是词表示2 独热表示3 上下文表示4 分布式表示结语 前言 在自然语言处理领域&#xff0c;词语的表示是一个基本挑战。将词语转换为计算机可以理解的符号&#xff0c;衡量词语之间的相似度&#xff0c;捕捉它们之间复杂的关系&#xff0c;是使机器能够理解和处理…

Bluetooth Mesh 入门学习干货,参考Nordic资料(更新中)

蓝牙网状网络&#xff08;Bluetooth mesh&#xff09;概念 概述 蓝牙Mesh Profile | Bluetooth Technology Website规范&#xff08;Mesh v1.1 后改名Mesh ProtocolMesh Protocol | Bluetooth Technology WebsiteMesh Protocol&#xff09;是由蓝牙技术联盟(Bluetooth SIG)开…

mysql的统计数据count

1、count原理 count()方法的目的是计算当前sql语句查询得到的非NULL的行数。 count方法的大原则是server层会从innodb存储引擎里读来一行行数据&#xff0c;并且只累计非null的值。但这个过程&#xff0c;根据count()方法括号内的传参&#xff0c;有略有不同。 2、count使用…

EasyExcel实现动态表头(注解实现)

要实现上述动态头&#xff0c;按每日统计&#xff0c;每月统计&#xff0c;每年统计。而时间是一直变化&#xff0c;所以我们需要表头也一直动态生成。 首先&#xff0c;我们需要定义所需要实体类 public class CountDayData {ExcelProperty(value "业务员姓名")p…

css 设置字体渐变色和阴影

一、需求 我们平时写样式的时候可能遇到需要将字体设置成渐变色&#xff0c;这样能使界面整体美化提升&#xff0c;那么css怎么去实现这个功能呢&#xff1f;下面我介绍一种常用的方法&#xff0c;欢迎大家补充 二、渐变实现 先看效果图&#xff1a; 直接上代码&#xff1a; /…

Seem环境安装

创建虚拟环境 conda create -n seem python3.8 conda activate seem 安装相关依赖&#xff1a;&#xff08;不按照的话会报错&#xff09; sudo apt-get install openmpi-bin libopenmpi-devconda install gcc_linux-64pip install mpi4py 导入环境 export PYTHONPATH$(pwd…

开发效率之把握需求、减少返工

前言 当年初入软件开发行业的我&#xff0c;拿到需求就莽&#xff0c;要设计没设计&#xff0c;要分析没分析&#xff0c;结果就是没理清楚需求&#xff0c;致使频频返工。 需求没理解对&#xff0c;做得再多再好也白搭。 估算需求把握程度 假如每个IF分支的“是”加一分&…

【VS】如何把wpf项目打包成exe文件

要将WPF项目打包为.exe文件&#xff0c;您可以使用Visual Studio的发布功能。以下是一些简单的步骤&#xff1a; 打开您的WPF项目。在Visual Studio的顶部菜单栏中&#xff0c;选择“生成”&#xff08;Build&#xff09;选项&#xff0c;然后选择“发布”&#xff08;Publish…

2024 年全球顶级的 3 款 桌面 PDF 转换工具

桌面 PDF 转换器工具是一种软件应用程序&#xff0c;使用户能够将 PDF 文件与不同的文件格式相互转换。奇客PDF转换、Nitro Pro 和 Foxit PhantomPDF 是市场上最好的桌面 PDF 转换工具。 在选择最好的 PDF 转换器软件时&#xff0c;需要考虑的一个重要因素是它与其他软件的集成…

使用栈求表达式的值【数据结构】

中缀表达式转后缀表达式 转换流程&#xff1a; 初始化一个运算符栈。自左向右扫描中缀表达式&#xff0c;当扫描到操作数时直接连接到后缀表达式上。当扫描到操作符时&#xff0c;和运算符栈栈顶的操作符进行比较。如果比栈顶运算符高&#xff0c;则入栈。如果比栈顶运算符低…

nvm 的安装及使用 (Node版本管理器)

目录 1、nvm 介绍 2、nvm安装 3、nvm 使用 4、node官网可以查看node和npm对应版本 5、nvm安装指定版本node 6、安装cli脚手架 1、nvm 介绍 NVM 全称 node.js version management &#xff0c;专门针对 node 版本进行管理的工具&#xff0c;通过它可以安装和切换不同版本的…

React使用 useImperativeHandle 自定义暴露给父组件的实例方法(包括依赖)

关键词 React useImperativeHandle 摘要 useImperativeHandle 是 React 提供的一个自定义 Hook&#xff0c;用于在函数组件中显式地暴露给父组件特定实例的方法。本文将介绍 useImperativeHandle 的基本用法、常见应用场景&#xff0c;以及如何处理其依赖项&#xff0c;以帮…

JavaScript函数表达式

JavaScript函数表达式是一种将函数赋值给变量的方式。函数表达式可以以匿名形式或具名形式存在。 匿名函数表达式&#xff1a; var func function() {// 函数的逻辑 }在上面的例子中&#xff0c;将一个匿名函数赋值给变量func。 具名函数表达式&#xff1a; var func fun…

数据链路层解读

基本介绍 概述 数据链路层使用的信道主要有两种类型 点对点信道。使用一对一的点对点通信方式的信道。广播信道。使用一对多的广播通信方式的信道。由于广播信道上连接的主机很多&#xff0c;必须使用专用的共享信道协议来协调这些主机的数据发送&#xff0c;因此通信过程比较…

【Windows】共享文件夹拍照还原防火墙设置(入站,出站设置)---图文并茂详细讲解

目录 一 共享文件夹(两种形式) 1.1 普通共享与高级共享区别 1.2 使用 二 拍照还原 2.1 是什么 2.2 使用 三 防火墙设置&#xff08;入栈&#xff0c;出站设置&#xff09; 3.1 引入 3.2 入站出站设置 3.2.1入站出站含义 3.3入站设置 3.4安装jdk 3.5使用tomcat进行访…