Stream篇(1)

最近在看一个写的很好的博客,为了加深记忆,把自认为重要的东西,一边看,一边记在这里

一、什么是流、字节序列、字节

一条河中有一条鱼游过,这条鱼就是一个字节,这个字节包括眼睛、嘴巴等8组成8个二进制的位,而这条河就是流。

字节按照一定的顺序进行排序组成了字节序列。

二、Stream

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

Stream stream=new Stream();

重要的属性:

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

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

3、CanWrite:只读,判断该流是否可写

4、Length:流的长度

5、Position:非常重要,在文件或图片上传中,可能会遇到这样的事:Stream对象被缓存了,导致了Position属性在流中无法找到正确的位置。一种方法是每次使用流前将该属性设置为0.但如果想从根本解决这个问题,最好的方法是用Using语句将流对象包裹起来,用完后关闭回收即可。

重要方法:

1、void Flush():

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

2、abstract int Read(byte[] buffer, int offset,int count)

缓冲字节数组,位偏移量,读取的字节个数

返回一个缓冲区中的总字节数,int类型。

3、abstract long Seek(long offset,SeekOrigin origin)

定位流中的一个位置

SeekOrigin.Begin/Current/End

offset可为负0正

4、abstract int Write(byte[] buffer, int offset,int count)

5、virtual void Close()

如果不用using,那记得使用这个方法

三、例子

非原创,呵呵

 1 static void Main(string[] args)
 2         {
 3             byte[] buffer = null;
 4 
 5             string testString = "Stream!Hello world";
 6             char[] readCharArray = null;
 7             byte[] readBuffer = null;
 8             string readString = string.Empty;
 9             //关于MemoryStream 我会在后续章节详细阐述
10             using (MemoryStream stream = new MemoryStream()) 
11             {
12                 Console.WriteLine("初始字符串为:{0}", testString);
13                 //如果该流可写
14                 if (stream.CanWrite)
15                 {
16                     //首先我们尝试将testString写入流中
17                     //关于Encoding我会在另一篇文章中详细说明,暂且通过它实现string->byte[]的转换
18                     buffer = Encoding.Default.GetBytes(testString);
19                     //我们从该数组的第一个位置开始写,长度为3,写完之后 stream中便有了数据
20                     //对于新手来说很难理解的就是数据是什么时候写入到流中,在冗长的项目代码面前,我碰见过很
21                     //多新手都会有这种经历,我希望能够用如此简单的代码让新手或者老手们在温故下基础
22                     stream.Write(buffer, 0,3);
23 
24                     Console.WriteLine("现在Stream.Postion在第{0}位置",stream.Position+1);
25 
26                     //从刚才结束的位置(当前位置)往后移3位,到第7位
27                     long newPositionInStream =stream.CanSeek? stream.Seek(3, SeekOrigin.Current):0;
28 
29                     Console.WriteLine("重新定位后Stream.Postion在第{0}位置", newPositionInStream+1);
30                     if (newPositionInStream < buffer.Length)
31                     {
32                         //将从新位置(第7位)一直写到buffer的末尾,注意下stream已经写入了3个数据“Str”
33                         stream.Write(buffer, (int)newPositionInStream, buffer.Length - (int)newPositionInStream);
34                     }
35 
36                     
37                     //写完后将stream的Position属性设置成0,开始读流中的数据
38                     stream.Position = 0;
39 
40                     // 设置一个空的盒子来接收流中的数据,长度根据stream的长度来决定
41                     readBuffer = new byte[stream.Length];
42 
43 
44                     //设置stream总的读取数量 ,
45                     //注意!这时候流已经把数据读到了readBuffer中
46                     int count = stream.CanRead?stream.Read(readBuffer, 0, readBuffer.Length):0;
47          
48 
49                     //由于刚开始时我们使用加密Encoding的方式,所以我们必须解密将readBuffer转化成Char数组,这样才能重新拼接成string
50 
51                     //首先通过流读出的readBuffer的数据求出从相应Char的数量
52                     int charCount = Encoding.Default.GetCharCount(readBuffer, 0, count);
53                     //通过该Char的数量 设定一个新的readCharArray数组
54                     readCharArray = new char[charCount];
55                     //Encoding 类的强悍之处就是不仅包含加密的方法,甚至将解密者都能创建出来(GetDecoder()),
56                     //解密者便会将readCharArray填充(通过GetChars方法,把readBuffer 逐个转化将byte转化成char,并且按一致顺序填充到readCharArray中)
57                     Encoding.Default.GetDecoder().GetChars(readBuffer, 0, count, readCharArray, 0);
58                     for (int i = 0; i < readCharArray.Length; i++)
59                     {
60                         readString += readCharArray[i];
61                     }
62                     Console.WriteLine("读取的字符串为:{0}", readString);
63                 }
64 
65                 stream.Close();
66             }
67 
68             Console.ReadLine();
69 
70         }

四、实现异步

几个关键方法:

异步读取
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 )

在复杂的情况下,避免类似于阻塞问题的出现。 感谢该博主的辛勤劳动,受益匪浅了。

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏MasiMaro 的技术博文

windows 纤程

纤程本质上也是线程,是多任务系统的一部分,纤程为一个线程准并行方式调用多个不同函数提供了一种可能,它本身可以作为一种轻量级的线程使用。它与线程在本质上没有区别,...

1712
来自专栏程序员的SOD蜜

左求值表达式,堆栈,调试陷阱与ORM查询语言的设计

1,表达式的求值顺序与堆栈结构 “表达式” 是程序语言一个很重要的术语,也是大家天天写的程序中很常见的东西,但是表达式的求值顺序一定是从左到右么? C/C++语...

3296
来自专栏冰霜之地

神经病院 Objective-C Runtime 出院第三天——如何正确使用 Runtime

到了今天终于要"出院"了,要总结一下住院几天的收获,谈谈Runtime到底能为我们开发带来些什么好处。当然它也是把双刃剑,使用不当的话,也会成为开发路上的一个大...

1292
来自专栏流媒体

resources.arsc解析

示例apk 示例代码 binary view二进制文件查看工具: android 6.0系统源码(网上搜索下载,这里暂不提供资源)

1672
来自专栏我叫刘半仙

原自己手写一个Mybatis框架(简化)

       继上一篇手写SpringMVC之后,我最近趁热打铁,研究了一下Mybatis。MyBatis框架的核心功能其实不难,无非就是动态代理和jdbc的操...

2K6
来自专栏GreenLeaves

EF基础知识小记六(使用Code First建模自引用关系,常用于系统菜单、文件目录等有层级之分的实体)

日常开发中,经常会碰到一些自引用的实体,比如系统菜单、目录实体,这类实体往往自己引用自己,所以我们必须学会使用Code First来建立这一类的模型. 以下是自...

2246
来自专栏木宛城主

SharePoint CAML In Action——Part II

在SharePoint中,相对于Linq to SharePoint而言,CAML是轻量化的。当然缺点也是显而易见的,"Hard Code"有时会让你抓狂。在实...

1995
来自专栏积累沉淀

干货--Hadoop自定义数据类型和自定义输入输出格式整合项目案例

正文开始前 ,先介绍几个概念 序列化 所谓序列化,是指将结构化对象转化为字节流,以便在网络上传输或写到磁盘进行永久存储。 反序列化 是指将字节流转回到结构化...

6506
来自专栏IMWeb前端团队

Redux源码解析系列(四)-- combineReducers

本文作者:IMWeb 黄qiong 原文出处:IMWeb社区 未经同意,禁止转载 combindeReducer 字面意思就是用来合并reducer的...

2007
来自专栏GreenLeaves

EF 约定介绍

当前环境为EF Code First开发模式中 一、EF默认约定 1、常用约定 (1)、当没有显示指定实体主键的时候,EF会默认将长得最像Id的属性(且类型为G...

22310

扫码关注云+社区

领取腾讯云代金券