C# 使用Pipelines处理Socket数据包

2023-12-27 15:52

本文主要是介绍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();}
}

调用示例

这篇关于C# 使用Pipelines处理Socket数据包的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



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

相关文章

中文分词jieba库的使用与实景应用(一)

知识星球:https://articles.zsxq.com/id_fxvgc803qmr2.html 目录 一.定义: 精确模式(默认模式): 全模式: 搜索引擎模式: paddle 模式(基于深度学习的分词模式): 二 自定义词典 三.文本解析   调整词出现的频率 四. 关键词提取 A. 基于TF-IDF算法的关键词提取 B. 基于TextRank算法的关键词提取

无人叉车3d激光slam多房间建图定位异常处理方案-墙体画线地图切分方案

墙体画线地图切分方案 针对问题:墙体两侧特征混淆误匹配,导致建图和定位偏差,表现为过门跳变、外月台走歪等 ·解决思路:预期的根治方案IGICP需要较长时间完成上线,先使用切分地图的工程化方案,即墙体两侧切分为不同地图,在某一侧只使用该侧地图进行定位 方案思路 切分原理:切分地图基于关键帧位置,而非点云。 理论基础:光照是直线的,一帧点云必定只能照射到墙的一侧,无法同时照到两侧实践考虑:关

使用SecondaryNameNode恢复NameNode的数据

1)需求: NameNode进程挂了并且存储的数据也丢失了,如何恢复NameNode 此种方式恢复的数据可能存在小部分数据的丢失。 2)故障模拟 (1)kill -9 NameNode进程 [lytfly@hadoop102 current]$ kill -9 19886 (2)删除NameNode存储的数据(/opt/module/hadoop-3.1.4/data/tmp/dfs/na

Hadoop数据压缩使用介绍

一、压缩原则 (1)运算密集型的Job,少用压缩 (2)IO密集型的Job,多用压缩 二、压缩算法比较 三、压缩位置选择 四、压缩参数配置 1)为了支持多种压缩/解压缩算法,Hadoop引入了编码/解码器 2)要在Hadoop中启用压缩,可以配置如下参数

Makefile简明使用教程

文章目录 规则makefile文件的基本语法:加在命令前的特殊符号:.PHONY伪目标: Makefilev1 直观写法v2 加上中间过程v3 伪目标v4 变量 make 选项-f-n-C Make 是一种流行的构建工具,常用于将源代码转换成可执行文件或者其他形式的输出文件(如库文件、文档等)。Make 可以自动化地执行编译、链接等一系列操作。 规则 makefile文件

使用opencv优化图片(画面变清晰)

文章目录 需求影响照片清晰度的因素 实现降噪测试代码 锐化空间锐化Unsharp Masking频率域锐化对比测试 对比度增强常用算法对比测试 需求 对图像进行优化,使其看起来更清晰,同时保持尺寸不变,通常涉及到图像处理技术如锐化、降噪、对比度增强等 影响照片清晰度的因素 影响照片清晰度的因素有很多,主要可以从以下几个方面来分析 1. 拍摄设备 相机传感器:相机传

2. c#从不同cs的文件调用函数

1.文件目录如下: 2. Program.cs文件的主函数如下 using System;using System.Collections.Generic;using System.Linq;using System.Threading.Tasks;using System.Windows.Forms;namespace datasAnalysis{internal static

pdfmake生成pdf的使用

实际项目中有时会有根据填写的表单数据或者其他格式的数据,将数据自动填充到pdf文件中根据固定模板生成pdf文件的需求 文章目录 利用pdfmake生成pdf文件1.下载安装pdfmake第三方包2.封装生成pdf文件的共用配置3.生成pdf文件的文件模板内容4.调用方法生成pdf 利用pdfmake生成pdf文件 1.下载安装pdfmake第三方包 npm i pdfma

C#实战|大乐透选号器[6]:实现实时显示已选择的红蓝球数量

哈喽,你好啊,我是雷工。 关于大乐透选号器在前面已经记录了5篇笔记,这是第6篇; 接下来实现实时显示当前选中红球数量,蓝球数量; 以下为练习笔记。 01 效果演示 当选择和取消选择红球或蓝球时,在对应的位置显示实时已选择的红球、蓝球的数量; 02 标签名称 分别设置Label标签名称为:lblRedCount、lblBlueCount

零基础学习Redis(10) -- zset类型命令使用

zset是有序集合,内部除了存储元素外,还会存储一个score,存储在zset中的元素会按照score的大小升序排列,不同元素的score可以重复,score相同的元素会按照元素的字典序排列。 1. zset常用命令 1.1 zadd  zadd key [NX | XX] [GT | LT]   [CH] [INCR] score member [score member ...]