【转】C# 温故而知新:Stream篇(—)

  目录:

什么是Stream?

什么是字节序列?

Stream的构造函数

Stream的重要属性及方法

Stream的示例

Stream异步读写

Stream 和其子类的类图

本章总结

 

 

 

什么是Stream?

MSDN 中的解释太简洁了: 提供字节序列的一般视图

(我可不想这么理解,这必定让我抓狂,我理解的流是向自然界的河流那样清澈而又美丽,c#中的流也是一样,许多技术或者说核心技术都需要流的帮忙)

那什么是字节序列呢?

其实简单的来理解的话字节序列指的是:

字节对象都被存储为连续的字节序列,字节按照一定的顺序进行排序组成了字节序列

那什么关于流的解释可以抽象为下列情况:

打个比方:一条河中有一条鱼游过,这个鱼就是一个字节,这个字节包括鱼的眼睛,嘴巴,等组成8个二进制,显然这条河就是我们的核心对象:流

马上进入正题,让我们来解释下c#的 Stream 是如何使用的

让我们直接温故或学习下Stream类的结构,属性和相关方法

首先是构造函数

Stream 类有一个protected 类型的构造函数, 但是它是个抽象类,无法直接如下使用

   Stream stream = new Stream();

所以我们自定义一个流继承自Stream 看看哪些属性必须重写或自定义:

复制代码

public class MyStreamExample : Stream {public override bool CanRead{get { throw new NotImplementedException(); }}public override bool CanSeek{get { throw new NotImplementedException(); }}public override bool CanWrite{get { throw new NotImplementedException(); }}public override void Flush(){throw new NotImplementedException();}public override long Length{get { throw new NotImplementedException(); }}public override long Position{get{throw new NotImplementedException();}set{throw new NotImplementedException();}}public override int Read(byte[] buffer, int offset, int count){throw new NotImplementedException();}public override long Seek(long offset, SeekOrigin origin){throw new NotImplementedException();}public override void SetLength(long value){throw new NotImplementedException();}public override void Write(byte[] buffer, int offset, int count){throw new NotImplementedException();}}

复制代码

可以看出系统自动帮我们实现了Stream 的抽象属性和属性方法

   1:  CanRead: 只读属性,判断该流是否能够读取:

   2:  CanSeek: 只读属性,判断该流是否支持跟踪查找

   3:  CanWrite: 只读属性,判断当前流是否可写

*4: void Flush():这点必须说得仔细些:

    当我们使用流写文件时,数据流会先进入到缓冲区中,而不会立刻写入文件,当执行这个方法后,缓冲区的数据流会立即注入基础流

     MSDN中的描述:使用此方法将所有信息从基础缓冲区移动到其目标或清除缓冲区,或者同时执行这两种操作。根据对象的状态,可能需要修

     改流内的当前位置(例如,在基础流支持查找的情况下即如此)当使用 StreamWriter 或 BinaryWriter 类时,不要刷新 Stream 基对象。

     而应使用该类的 Flush 或 Close 方法,此方法确保首先将该数据刷新至基础流,然后再将其写入文件。

(红色部分为关键请大家务必能够理解,今后会在相应的章节中介绍)

  5: Length:表示流的长度

*6: Position属性:(非常重要)

虽然从字面中可以看出这个Position属性只是标示了流中的一个位置而已,可是我们在实际开发中会发现这个想法会非常的幼稚,

很多asp.net项目中文件或图片上传中很多朋友会经历过这样一个痛苦:Stream对象被缓存了,导致了Position属性在流中无法

找到正确的位置,这点会让人抓狂,其实解决这个问题很简单,聪明的你肯定想到了,其实我们每次使用流前必须将Stream.Position

设置成0就行了,但是这还不能根本上解决问题,最好的方法就是用Using语句将流对象包裹起来,用完后关闭回收即可。

*7: abstract int Read(byte[] buffer, int offset, int count)

这个方法包含了3个关键的参数:缓冲字节数组,位移偏量和读取字节个数,每次读取一个字节后会返回一个缓冲区中的总字节数

第一个参数:这个数组相当于一个空盒子,Read()方法每次读取流中的一个字节将其放进这个空盒子中。(全部读完后便可使用buffer字节数组了)

第二个参数:表示位移偏量,指定数据从buffer的什么位置开始存放

最后一个参数:就是读取多少字节数。

返回值便是总共读取了多少字节数.

*8: abstract long Seek(long offset, SeekOrigin origin)

    大家还记得Position属性么?其实Seek方法就是重新设定流中的一个位置,在说明offset参数作用之前大家先来了解下SeekOrigin这个枚举:

如果 offset 为负,则要求新位置位于 origin 指定的位置之前,其间隔相差 offset 指定的字节数。如果 offset 为零 (0),则要求新位置位于由 origin 指定的位置处。

如果 offset 为正,则要求新位置位于 origin 指定的位置之后,其间隔相差 offset 指定的字节数.

Stream. Seek(-3,Origin.End);  表示在流末端往前数第3个位置

Stream. Seek(0,Origin.Begin); 表示在流的开头位置

Stream. Seek(3,Orig`in.Current); 表示在流的当前位置往后数第三个位置

查找之后会返回一个流中的一个新位置。其实说道这大家就能理解Seek方法的精妙之处了吧

*9: abstract void Write(byte[] buffer,int offset,int count)

这个方法包含了3个关键的参数:缓冲字节数组,位移偏量和读取字节个数

和read方法不同的是 write方法中的第一个参数buffer已经有了许多byte类型

的数据,我们只需通过设置 offset和count来将buffer中的数据写入流中

*10: virtual void Close()

关闭流并释放资源,在实际操作中,如果不用using的话,别忘了使用完流之后将其关闭

这个方法特别重要,使用完当前流千万别忘记关闭!

 

为了让大家能够快速理解和消化上述属性和方法我会写个示例并且关键部分会详细说明

复制代码

    static void Main(string[] args){byte[] buffer = null;string testString = "Stream!Hello world";char[] readCharArray = null;byte[] readBuffer = null;string readString = string.Empty;//关于MemoryStream 我会在后续章节详细阐述using (MemoryStream stream = new MemoryStream()) {Console.WriteLine("初始字符串为:{0}", testString);//如果该流可写if (stream.CanWrite){//首先我们尝试将testString写入流中//关于Encoding我会在另一篇文章中详细说明,暂且通过它实现string->byte[]的转换buffer = Encoding.Default.GetBytes(testString);//我们从该数组的第一个位置开始写,长度为3,写完之后 stream中便有了数据//对于新手来说很难理解的就是数据是什么时候写入到流中,在冗长的项目代码面前,我碰见过很//多新手都会有这种经历,我希望能够用如此简单的代码让新手或者老手们在温故下基础stream.Write(buffer, 0,3);Console.WriteLine("现在Stream.Postion在第{0}位置",stream.Position+1);//从刚才结束的位置(当前位置)往后移3位,到第7位long newPositionInStream =stream.CanSeek? stream.Seek(3, SeekOrigin.Current):0;Console.WriteLine("重新定位后Stream.Postion在第{0}位置", newPositionInStream+1);if (newPositionInStream < buffer.Length){//将从新位置(第7位)一直写到buffer的末尾,注意下stream已经写入了3个数据“Str”stream.Write(buffer, (int)newPositionInStream, buffer.Length - (int)newPositionInStream);}//写完后将stream的Position属性设置成0,开始读流中的数据stream.Position = 0;// 设置一个空的盒子来接收流中的数据,长度根据stream的长度来决定readBuffer = new byte[stream.Length];//设置stream总的读取数量 ,//注意!这时候流已经把数据读到了readBuffer中int count = stream.CanRead?stream.Read(readBuffer, 0, readBuffer.Length):0;//由于刚开始时我们使用加密Encoding的方式,所以我们必须解密将readBuffer转化成Char数组,这样才能重新拼接成string//首先通过流读出的readBuffer的数据求出从相应Char的数量int charCount = Encoding.Default.GetCharCount(readBuffer, 0, count);//通过该Char的数量 设定一个新的readCharArray数组readCharArray = new char[charCount];//Encoding 类的强悍之处就是不仅包含加密的方法,甚至将解密者都能创建出来(GetDecoder()),//解密者便会将readCharArray填充(通过GetChars方法,把readBuffer 逐个转化将byte转化成char,并且按一致顺序填充到readCharArray中)Encoding.Default.GetDecoder().GetChars(readBuffer, 0, count, readCharArray, 0);for (int i = 0; i < readCharArray.Length; i++){readString += readCharArray[i];}Console.WriteLine("读取的字符串为:{0}", readString);}stream.Close();}Console.ReadLine();}

复制代码


显示结果:

大家需要特别注意的是stream.Positon这个很神奇的属性,在复杂的程序中,往往流对象操作也会很复杂,

一定要切记将stream.Positon设置在你所需要的正确位置,还有就是 using语句的使用,它会自动销毁stream对象,

当然Stream.Close()大家都懂的

 

接着让我们来说下关于流中怎么实现异步操作

在Stream基类中还有几个关键方法,它们能够很好实现异步的读写,

复制代码

异步读取
public virtual IAsyncResult BeginRead(byte[] buffer,int offset,int count,AsyncCallback callback,Object state)
异步写
public virtual IAsyncResult BeginWrite( byte[] buffer, int offset, int count, AsyncCallback callback, Object state )
结束异步读取
public virtual int EndRead( IAsyncResult asyncResult ) 
结束异步写
public virtual void EndWrite( IAsyncResult asyncResult )  

复制代码

大家很容易的就能发现前两个方法实现了IAsyncResult接口,后2个end方法也顺应带上了一个IAsyncResult参数,

其实并不复杂,(必须说明下 每次调用 Begin方法时都必须调用一次 相对应的end方法)

和一般同步read或write方法一致的是,他们可以当做同步方法使用,但是在复杂的情况下可能也难逃阻塞崩溃等等,但是一旦启用了

异步之后,这些类似于阻塞问题会不复存在,可见微软对于异步的支持正在加大。

 

 最后是有关c#中Stream类和其子类的类图

  类图呢?大家肯定会这么想把 ^^

   为什么这个在目录中是灰色的?其实我个人觉得这个类图不应该放在这篇博文中,原因是我们真正理解并熟练操作了Stream的所有子类?(大牛除外)

  (这也是我写后续文章的动力之一,写博能很好的提升知识点的吸收,不仅能帮助别人,也能提高自己的对于知识点的理解),所以我想把类图放在这

   个系类的总结篇中

 

本章总结:

本章介绍了流的基本概念和c#中关于流的基类Stream所包含的一些重要的属性和方法,关键是一些方法和属性的细节和我们操作流对象时必须注意的事项,

文中很多知识点都是自身感悟学习而来,深夜写文不容易,请大家多多关注下,下一章将会介绍操作流类的工具:StreamReader 和StreamWriter

敬请期待!

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

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

相关文章

python 画树 递归_数据结构 - python如何递归生成树?

问 题 class Tree: def __init__(self, label): self.root label self.child {} def set_child(self, label, relate): self.child[label] relate def get_root(self): return self.root def get_child(self): return self.child 这么一颗树结构&#xff0c;该如何写 def cr…

java integer valueof_一文读懂什么是Java中的自动拆装箱

本文主要介绍Java中的自动拆箱与自动装箱的有关知识。基本数据类型基本类型&#xff0c;或者叫做内置类型&#xff0c;是Java中不同于类(Class)的特殊类型。它们是我们编程中使用最频繁的类型。Java是一种强类型语言&#xff0c;第一次申明变量必须说明数据类型&#xff0c;第一…

【转】面试:一个单例模式,足以把你秒成渣

去面试&#xff08;对&#xff0c;又去面试&#xff09; 问&#xff1a;单例模式了解吧&#xff0c;来&#xff0c;拿纸和笔写一下单例模式。 我心想&#xff0c;这TM不是瞧不起人吗&#xff1f;我编程十年&#xff0c;能不知道单例模式。 答&#xff1a;&#xff08;.net 平…

【转】SQL 语句执行顺序

From&#xff1a;http://www.jellythink.com/archives/924 Oracle-SQL语句执行原理和完整过程详解&#xff1a;https://wenku.baidu.com/view/398bc427964bcf84b8d57b00.html 详解一条 SQL 语句的执行过程&#xff1a;http://www.cnblogs.com/cdf-opensource-007/p/6502556.h…

堆和栈的概念和区别 python_堆和栈的概念和区别

在说堆和栈之前&#xff0c;我们先说一下JVM&#xff08;虚拟机&#xff09;内存的划分&#xff1a; Java程序在运行时都要开辟空间&#xff0c;任何软件在运行时都要在内存中开辟空间&#xff0c;Java虚拟机运行时也是要开辟空间的。JVM运行时在内存中开辟一片内存区域&#x…

【手算】哈夫曼编码—树形倒置快速画法

哈夫曼编码的原理 参考文章&#xff1a;哈夫曼编码详解——图解真能看了秒懂 简单总结其原理&#xff1a; 需求&#xff1a;对重复出现的元素进行二进制编码&#xff0c;最高效的编码方式是哈夫曼编码。 方法&#xff1a;按照元素出现的频率大小构造一棵树&#xff0c;出现次…

【转】Web API项目中使用Area对业务进行分类管理

在之前开发的很多Web API项目中&#xff0c;为了方便以及快速开发&#xff0c;往往把整个Web API的控制器放在基目录的Controllers目录中&#xff0c;但随着业务越来越复杂&#xff0c;这样Controllers目录中的文件就增加很快&#xff0c;难以管理&#xff0c;而且如果有不同业…

centos部署python flask_用Dockerfile部署你的Flask Web应用

背景故事话说去年年底给另外一个组的同事写了一个简单的工单查询系统&#xff0c;用flask写的&#xff0c;当时是部署在我们组的一台测试物理机上&#xff0c;操作系统是Redhat 7。后来我们组的这台测试物理机要做其它用途&#xff0c;领导给两天时间让把应用迁走&#xff0c;问…

centos7安装flink集群_《从0到1学习Flink》—— Flink 写入数据到 Kafka

前言之前文章 《从0到1学习Flink》—— Flink 写入数据到 ElasticSearch 写了如何将 Kafka 中的数据存储到 ElasticSearch 中&#xff0c;里面其实就已经用到了 Flink 自带的 Kafka source connector&#xff08;FlinkKafkaConsumer&#xff09;。存入到 ES 只是其中一种情况&a…

Qt中的私有信号

一、什么是Qt私有信号&#xff1f; 直接引用Qt文档中的描述&#xff1a; 二、私有信号的作用 私有信号只能被响应&#xff0c;不能被用户代码来发射&#xff08;emit&#xff09;。这是一种对某些信号的权限控制&#xff0c;也就是用户代码没有权力“发号施令”&#xff0c;只…

opencv获取图片像素坐标_利用OpenCV从图片中提取矩形并标注坐标(室内平面地图)(一)

​某城市会展中心室内地图背景一名室内设计师的日常工作从设计一张会展地图开始。常常有这样的场景&#xff1a;划分除规范的展位后&#xff0c;进入销售阶段&#xff0c;频繁的需要修改这张地图&#xff0c;如展示拆分、合并、换位置、标记已交易。问题从上图中标记色块的是有…

【转】C#中ToString()格式详解

以下内容均摘自博客园&#xff0c;仅供资料查询。 ToString格式化 在很多对象显示为字符串的时候都会使用到ToString中的格式化&#xff0c;由于以前没怎么注意到这个问题&#xff0c;想总结一下各个基础结构对象的格式化&#xff0c;以便后备之用&#xff01;&#xff01;&am…

【编译原理】入门总结

教程资源 入门教程在&#xff1a;手把手教你做一个 C 语言编译器 学习过程 19年尝试学了一下&#xff0c;中途看不懂放弃了。20年底从头再看一遍&#xff0c;经过一年的知识积累&#xff0c;在仔细研读之下&#xff0c;终于算是学懂了。此文中记录了我在最初学习时遇到的问题…

Qt添加翻译文件

以在Qt Creator中开发为例&#xff1a; 第一步 在.pro文件中添加一行 TRANSLATIONS projectName_zh.ts 保存&#xff0c;执行一次qmake。 注&#xff1a;ts文件是xml文件保存了需要翻译的信息。 第二步 选择菜单&#xff1a;工具->外部->Qt预言家->更新翻译。 可…

应用程序标准输入输出、Shell、程序界面的关系

发展史 计算机在发展初期&#xff0c;电脑上的软件是没有窗口的&#xff0c;只有一个命令行&#xff0c;这个软件叫Shell&#xff0c;中文的意思是外壳。Shell是一个统一的叫法&#xff0c;实际在不同的系统中&#xff0c;又有很多种Shell软件&#xff0c;如下表所示&#xff…

安卓简单天气预报app源码_七个个小众但实用的APP,效率翻倍~

推荐7个小众但实用的APP1、PDF处理助手下面就是软件的启动图&#xff0c;没有任何广告。并且直接标明了这个软件的三大特点&#xff1a;简单、免费、快捷下面就是软件的启动图&#xff0c;没有任何广告。而且免注册登录即可使用&#xff0c;简直是一款良心软件了。2、菜鸟教程菜…

【转】Jenkins详细教程

最近花了一段时间研究jenkins这个工具。所以写下这篇文章&#xff0c;算是当做记录吧&#xff01; 一、jenkins是什么&#xff1f; Jenkins是一个开源的、提供友好操作界面的持续集成(CI)工具&#xff0c;起源于Hudson&#xff08;Hudson是商用的&#xff09;&#xff0c;主要…

拼接符 防注入正则校验_Apache Kylin 命令注入漏洞调试分析(CVE-2020-1956)

1、前言Apache Kylin是一个开源的、分布式的分析型数据仓库&#xff0c;提供Hadoop/Spark 之上的 SQL 查询接口及多维分析(OLAP)能力以支持超大规模数据。近日&#xff0c;百度云安全团队监测到Apache官方发出了一个漏洞通告&#xff0c;披露了Apache kylin多版本存在命令注入漏…

can使能上拉 gpio_IMX6ULL 的 GPIO 操作方法

来源&#xff1a;百问网作者&#xff1a;韦东山本文字数&#xff1a;1652&#xff0c;阅读时长&#xff1a;4分钟CCM: Clock Controller Module (时钟控制模块) IOMUXC : IOMUX Controller&#xff0c;IO 复用控制器 GPIO: General-purpose input/output&#xff0c;通用的输入…

【转】.NET 的 WebSocket 开发包比较

转载于http://www.oschina.net/translate/websocket-libraries-comparison-2 编者按 本文出现在第三方产品评论部分中。在这一部分的文章只提供给会员&#xff0c;不允许工具供应商用来以任何方式和形式来促销或宣传产品。请会员报告任何垃圾信息或广告。 Web项目常常需要将数…