C# MemoryStream的具体使用_Asp.net

前言

在.net开发中，流（stream）是一个用于处理输入和输出的抽象类，memorystream是流的一个具体实现，它允许我们在内存中读写数据，就像操作文件一样，而无需涉及磁盘 i/o 操作。尤其适合需要快速读写、转换或传输数据的场景。本文将详细讲解memorystream的使用。

一、什么是 memorystream？

1. 定义

memorystream 是 system.io 命名空间中的一个类，它允许我们在内存中创建可读写的流。与文件流或网络流不同，memorystream的数据存储在内存中，它不需要依赖物理文件，因此读写速度非常快，适合处理临时数据（如网络传输、临时缓存、序列化对象等）。但会占用一定的内存资源。

📌memorystream 是 system.io 命名空间中的一个类，它实现了 stream 抽象类，提供了一系列用于操作数据流的属性和方法。

2. 继承关系

2. 核心特性

内存高效：数据直接存储在内存中，无需磁盘 i/o，读写速度快。
灵活操作：支持读写、重置位置、转换为字节数组等数据处理操作。
轻量级：无需文件句柄，适合小到中等规模的数据。

3. 用途

处理大量数据，如图像、音频和视频文件等二进制数据。
临时存储数据，如网络传输过程中的数据缓冲。
实现自定义数据流逻辑，例如加密或压缩数据。

4. 为什么需要 memorystream？

在数据处理场景中，频繁的磁盘io操作（如读写文件）会显著降低程序性能，尤其是面对海量数据或高频读写需求时。memorystream作为c#中的内存流，将数据存储在内存而非硬盘中，避免了磁盘io瓶颈，读写速度更快。它适用于网络数据传输、临时缓存、二进制数据处理等场景，是实现高性能代码的利器！

二、基础用法

1. 创建 memorystream 对象

memorystream有多个构造函数，可以根据需要选择合适的构造函数来初始化memorystream。

1）无参构造函数

使用无参构造函数可以创建一个空白的 memorystream 对象，其初始容量为 0，随着数据写入自动扩展。

using system.io;

memorystream memorystream = new memorystream();

2）带参构造函数

使用带参构造函数可以根据指定的容量创建 memorystream 对象，或者从一个字节数组创建。

▶ 指定初始容量的构造函数

memorystream memorystream = new memorystream(1024);

创建一个初始容量为1024字节的memorystream。

▶ 使用字节数组初始化的构造函数

byte[] buffer = new byte[] { 72, 101, 108, 108, 111, 44, 32, 87, 111, 114, 108, 100, 33 };
memorystream ms = new memorystream(buffer);

使用现有的字节数组初始化memorystream。

2. 写入数据

memorystream 提供了多种方法来写入数据，最常用的是 write 方法和 writebyte 方法。

1）写入字节数组

使用 write 方法可以将一个字节数组写入 memorystream。

byte[] data = new byte[] { 72, 101, 108, 108, 111 }; 
memorystream.write(data, 0, data.length);

2）写入字符串

向 memorystream 写入一个字符串，需要将字符串转换为字节数组。

string text = "hello, world!";
byte[] data = system.text.encoding.utf8.getbytes(text);
memorystream.write(data, 0, data.length);

3）使用 writebyte 方法

writebyte 方法可以逐字节写入数据。

string text = "hello, world!";
byte[] data = system.text.encoding.utf8.getbytes(text);
foreach (byte b in data)
{
    memorystream.writebyte(b);
}

3. 读取数据

memorystream 提供了多种方法来读取数据，最常用的是 read 方法和 readbyte 方法。

1）读取字节数组

从 memorystream 读取一定数量的字节到字节数组中。

byte[] buffer = new byte[11];
int bytesread = memorystream.read(buffer, 0, buffer.length);

2）读取字符串

从 memorystream 读取一定数量的字节，然后将其转换为字符串。

byte[] buffer = new byte[11];
int bytesread = memorystream.read(buffer, 0, buffer.length);
string text = system.text.encoding.utf8.getstring(buffer, 0, bytesread);

3）使用 readbyte 方法

readbyte 方法可以逐字节读取数据。

list<byte> bytelist = new list<byte>();
while (memorystream.position < memorystream.length)
{
    bytelist.add((byte)memorystream.readbyte());
}
string text = system.text.encoding.utf8.getstring(bytelist.toarray());

4. 常用属性

1）capacity

获取或设置分配给memorystream 的字节数

memorystream memorystream = new memorystream(1024);
int capacity = memorystream.capacity;	// 输出：1024

2）length

获取memorystream中实际使用的数据长度。

memorystream memorystream = new memorystream(1024);
long length = memorystream.length;	// length = 0

3）position

获取或设置memorystream的当前读写位置。

memorystream.position = 0; // 定位到流的开头

4）canread、canwrite、canseek

bool canread = ms.canread;
bool canwrite = ms.canwrite;
bool canseek = ms.canseek;

表示memorystream是否支持读取、写入和定位操作。对于memorystream，这些属性通常返回true。

5. 常用辅助方法

1）setlength 设置长度

使用 setlength 方法可以设置 memorystream 的长度，如果新长度小于当前长度，数据将被截断；如果新长度大于当前长度，数据将被扩展。

memorystream.setlength(50);

2）seek 设置当前读写位置

ms.seek(0, seekorigin.begin);

移动memorystream的当前读写位置。

3）toarray 转换为字节数组

使用 toarray 方法可以将 memorystream 的内容转换为字节数组。

byte[] allbytes = memorystream.toarray();

4）getbuffer 获取底层缓冲区的字节数组

byte[] buffer = memorystream.getbuffer();

getbuffer方法返回底层缓冲区的完整字节数组（包含未使用的空间），toarray方法返回仅包含有效数据的数组（排除未使用的空间）。

关于 toarray 和 getbuffer 方法的区别，详见：c# memorystream 中 toarray 和 getbuffer 的区别

6. position 注意事项

1）写入数据后的 position 自动前进

// 创建空的 memorystream
using (memorystream ms = new memorystream())
{
    // 写入字符串
    byte[] data = system.text.encoding.utf8.getbytes("hello, memorystream!");
    ms.write(data, 0, data.length);
    
    // 写入后的位置自动前进
    console.writeline($"当前位置：{ms.position}"); // 输出：20（假设 utf-8 编码）
}

2）读取数据必须重置 position

using (memorystream ms = new memorystream())
{
    // 写入数据后重置位置到开头
    ms.write(data, 0, data.length);
    ms.position = 0; // 必须重置位置才能读取

    // 读取数据
    byte[] buffer = new byte[ms.length];
    ms.read(buffer, 0, (int)ms.length);
    string result = system.text.encoding.utf8.getstring(buffer);
    console.writeline(result); // 输出：hello, memorystream!
}

tips：
除了使用 position 属性重置位置外，读写前还可用seek()调整指针位置，如 stream.seek(0, seekorigin.begin)。

7. 示例代码

下面是一个完整的示例，演示了如何使用 memorystream：

public class program
{
    public static void main(string[] args)
    {
        // 创建 memorystream
        memorystream memorystream = new memorystream();

        // 获取当前读写的位置
        console.writeline($"memorystream position: {memorystream.position}");// 输出：memorystream position: 0


        string text = "hello, world!";
        byte[] data = system.text.encoding.utf8.getbytes(text);
        // 写入数据
        memorystream.write(data, 0, data.length);

        // 转换为字节数组
        console.writeline(bitconverter.tostring(memorystream.toarray()));   //输出：48-65-6c-6c-6f-2c-20-57-6f-72-6c-64-21

        // 设置长度
        memorystream.setlength(50);

        // 获取长度
        console.writeline($"memorystream length: {memorystream.length}"); // 输出：memorystream length: 50

        // 获取当前读写的位置
        console.writeline($"memorystream position: {memorystream.position}");// 输出：memorystream position: 13

        // 读取数据
        byte[] buffer = new byte[5];
        int bytesread = memorystream.read(buffer, 0, buffer.length);
        // 输出结果
        console.writeline(bitconverter.tostring(buffer)); // 输出：00-00-00-00-00

        // 定位
        memorystream.position = 0;

        // 再次读取数据
        bytesread = memorystream.read(buffer, 0, buffer.length);
        console.writeline(bitconverter.tostring(buffer)); // 输出：48 65 6c 6c 6f
        console.writeline(encoding.utf8.getstring(buffer)); //输出：hello

        // 清空 memorystream
        memorystream.setlength(0);
        memorystream.position = 0;

        // 检查是否清空
        console.writeline("memorystream length after clear: " + memorystream.length); // 输出：memorystream length after clear: 0
    }
}

通过这个示例，我们可以看到 memorystream 在处理内存中的数据流时是多么灵活和有用。它不仅可以用于临时存储数据，还可以用于实现复杂的数据处理逻辑。

三、memorystream的高级使用

1. 数据交互

1）与文本数据交互

使用 streamreader/streamwriter

public class program
{
    public static void main(string[] args)
    {
        using (memorystream ms = new memorystream())
        {
            // 创建一个streamwriter，用于向memorystream写入字符串
            using (streamwriter sw = new streamwriter(ms, encoding.utf8, 1024, leaveopen: true))
            {
                // leaveopen: true 的作用：
                // 防止 streamwriter 关闭时连带关闭底层的 memorystream，确保后续 streamreader 可正常操作流
                sw.writeline("hello, world!");
                sw.writeline("this is a test.");
            }
            // 将memorystream的位置重置到开头
            ms.seek(0, seekorigin.begin);

            // 创建一个streamreader，用于从memorystream读取字符串
            using (streamreader sr = new streamreader(ms, encoding.utf8))
            {
                string line;
                while ((line = sr.readline()) != null)
                {
                    console.writeline(line);
                }
            }
        }
    }
}

在这个例子中，我们首先创建了一个memorystream实例，然后使用streamwriter向memorystream写入了两行字符串。写入完成后，我们将memorystream的位置重置到开头，接着使用streamreader从memorystream读取字符串并打印到控制台。

2）与二进制数据交互

使用 binaryreader/binarywriter

public class program
{
    public static void main(string[] args)
    {
        using (memorystream ms = new memorystream())
        {
            // 创建一个binarywriter，用于向memorystream写入二进制数据
            using (binarywriter writer = new binarywriter(ms,encoding.utf8,leaveopen:true))
            {
                // leaveopen: true 的作用：
                // 防止 streamwriter 关闭时连带关闭底层的 memorystream，确保后续 streamreader 可正常操作流
                
                writer.write(32);// 写入整数
                writer.write(12.3f);// 写入单精度浮点数
                writer.write("this is a test.");// 写入字符串
            }

            // 将memorystream的位置重置到开头
            ms.seek(0, seekorigin.begin);

            // 创建一个 binaryreader，用于从memorystream读取二进制数据
            using (binaryreader reader = new binaryreader(ms, encoding.utf8))
            {
                console.writeline(reader.readint32());  //输出：32
                console.writeline(reader.readsingle()); //输出：12.3
                console.writeline(reader.readstring()); //输出：this is a test.
            }
        }
    }
}

3）与网络流交互

将内存流作为网络传输的缓冲区：

// 服务端接收数据
networkstream ns = client.getstream();
memorystream ms = new memorystream();
ns.copyto(ms); // 将网络流复制到内存流
byte[] buffer = ms.toarray();

2. 高级技巧

1）及时释放资源

使用using语句：确保流对象及时释放，避免内存泄漏。

using (memorystream stream = new memorystream()) { /*...*/ }

2）设置初始容量

预分配容量：若已知数据大小，初始化时指定capacity减少动态扩容开销。

频繁写入数据时，指定初始容量可避免内存频繁扩容：

// 预分配 1mb 内存
using (memorystream ms = new memorystream(1024 * 1024))
{
    // 写入大量数据
}

3）重置流以复用内存

通过 setlength(0) 和 seek 方法或设置position重置流：

using (memorystream ms = new memorystream())
{
    ms.write(data, 0, data.length);
    
    // 重置流并清空内容
    ms.setlength(0); 
    ms.position = 0; //或 ms.seek(0, seekorigin.begin);
    
    // 重新写入新数据
    ms.write(newdata, 0, newdata.length);
}

3. 实际应用示例

1）使用memorystream序列化和反序列化对象

using system;
using system.text;
using system.text.json;

public class person
{
    public string name { get; set; }
    public int age { get; set; }
}

class program
{
    static void main()
    {
        person person = new person { name = "john doe", age = 30 };
        // 序列化对象到memorystream
        using (memorystream ms = new memorystream())
        {
            jsonserializer.serialize(ms, person);
            // 将memorystream的位置重置到开头
            ms.seek(0, seekorigin.begin);
            // 反序列化对象从memorystream
            person deserializedperson = jsonserializer.deserialize<person>(ms);
            console.writeline("name: " + deserializedperson.name);  // 输出：name: john doe
            console.writeline("age: " + deserializedperson.age);    // 输出：age: 30
        }
    }
}

2）使用memorystream作为临时缓冲区

using system;
using system.io;
public class memorystreamexample
{
    public static void main()
    {
        // 创建一个memorystream作为临时缓冲区
        using (memorystream ms = new memorystream())
        {
            // 写入一些数据到memorystream
            byte[] data = new byte[] { 1, 2, 3, 4, 5 };
            ms.write(data, 0, data.length);
            // 将memorystream作为参数传递给其他方法
            processdata(ms);
        }
    }
    public static void processdata(memorystream ms)
    {
        // 将memorystream的位置重置到开头
        ms.seek(0, seekorigin.begin);
        // 读取数据 from memorystream
        byte[] buffer = new byte[ms.length];
        ms.read(buffer, 0, buffer.length);
        console.writeline("received data:");
        foreach (byte b in buffer)
        {
            console.write(b + " ");
        }
    }
}

3）高效处理复杂场景

案例：日志文件关键字筛选

假设需要从多个.log文件中提取含特定关键字的行，传统方法可能导致内存暴涨。

优化方案：

逐行读取文件：使用streamreader避免一次性加载大文件。
内存流缓存匹配行：将匹配的行暂存至memorystream，减少磁盘io次数。

批量写入结果：最后将内存流数据一次性写入目标文件。

list<string> matchedlines = new list<string>();
foreach (var file in directory.getfiles("logs", "*.log")) 
{
    using (var reader = new streamreader(file)) 
    {
        while (!reader.endofstream) 
        {
            string line = reader.readline();
            if (regex.ismatch(line, "keyword")) 
            {
                matchedlines.add(line);
            }
        }
    }
}
// 使用memorystream合并数据并写入文件
using (memorystream ms = new memorystream()) 
{
    byte[] buffer = encoding.utf8.getbytes(string.join("\n", matchedlines));
    ms.write(buffer, 0, buffer.length);
    file.writeallbytes("result.txt", ms.toarray());
}

实测性能提升显著

四、常见问题与解决方案

1. 读取时超出容量

// 错误示例：未重置位置导致读取失败
using (memorystream ms = new memorystream())
{
    ms.write(data, 0, data.length);
    byte[] buffer = new byte[ms.length];
    ms.read(buffer, 0, buffer.length); // 抛出异常，因为 position 已在末尾
}

// 正确做法：重置位置
ms.position = 0;
ms.read(buffer, 0, buffer.length);

2. 处理大文件时的内存问题

当数据量超过内存限制时，改用 filestream：

// 替代方案：使用文件流
using (filestream fs = new filestream("temp.bin", filemode.create))
{
    // 写入数据到文件流
}

3. 异步操作

通过 toarray() 获取字节数组后，可异步处理：

public async task processasync()
{
    using (memorystream ms = new memorystream())
    {
        // 写入数据
        byte[] data = ms.toarray();
        
        // 异步发送到网络
        await client.sendasync(data);
    }
}

五、memorystream的优缺点

优点

内存中操作速度快：由于数据存储在内存中，读写速度非常快。
容量灵活：memorystream的容量可以动态增长，以适应数据量的变化。
支持读写定位操作：支持canread、canwrite和canseek属性，便于灵活操作。

缺点

内存占用高：处理大量数据时，可能会占用大量的内存资源。
不适合持久化存储：数据存储在内存中，程序关闭后数据会丢失。

六、最佳实践总结

资源管理
始终使用 using 语句确保流正确释放：
```
using (memorystream ms = new memorystream()) { ... }
```
位置重置
写入后读取前必须重置 position 到 0。
性能优化
- 指定初始容量：在创建memorystream时，尽量指定初始容量，以减少动态增长的次数，提高性能。
- 处理大量数据时谨慎使用：处理大量数据时，考虑使用文件流或其他适合的流类型，避免内存占用过高。（对大文件使用 filestream 替代。）

参考资料

c# memorystream流的详解与示例
 c# stream 和 byte[] 之间的转换(文件流的应用)
c# stream篇（五） – memorystream

到此这篇关于c# memorystream 使用详解的文章就介绍到这了,更多相关c# memorystream 使用内容请搜索代码网以前的文章或继续浏览下面的相关文章希望大家以后多多支持代码网！


验证码：

C# MemoryStream的具体使用

2025年07月31日 • Asp.net •我要评论

前言