C# StreamReader/StreamWriter 使用详解
总目录
前言
在 C# 开发中,StreamReader 和 StreamWriter 是处理文本文件的核心类,属于 System.IO 命名空间。它们基于流(Stream)操作文本数据,支持读写、编码设置、异步操作等,适用于日志记录、配置文件处理、数据导出等场景。本文将从基础到高级用法,结合代码示例,全面解析其核心功能、性能优化及常见问题解决方案。
一、什么是 StreamReader 和 StreamWriter?
1. 定义
- StreamReader:用于从流(如文件、网络流)中读取文本数据,支持逐行读取、读取指定长度数据或一次性读取全部内容。
- StreamWriter:用于向流中写入文本数据,支持追加模式、格式化输出及自定义编码。
StreamReader 和 StreamWriter 是 System.IO 命名空间中的两个类,它们分别用于读取和写入文本数据。两者均继承自 TextReader 和 TextWriter 抽象类,通常与 FileStream、MemoryStream 等流结合使用。
2. 特点
- 提供了方便的方法来读取和写入文本数据,支持多种编码格式。
- 可以处理大文件,通过流的方式逐步读取或写入数据,节省内存。
- 支持异步操作,提高程序的响应性和性能。
3. 用途
- 文本文件读写:
- 替代
FileStream直接操作字节的复杂性,自动处理编码和换行符。如日志文件、配置文件等。
- 替代
- 网络流解析:
- 与
NetworkStream结合,实现 HTTP 响应内容的高效解码。
- 与
- 内存流操作:
- 配合
MemoryStream处理内存中的文本缓存,如 JSON/XML 序列化。
- 配合
- 日志与数据记录:
- 支持追加模式写入,避免频繁覆盖文件内容。
适用于以下场景:
- 日志记录:将日志追加到文件。
- 配置文件操作:读取
.ini、.json等文本配置。 - 数据导出:将数据写入 CSV、TXT 文件。
4. 为什么需要 StreamReader/StreamWriter?
在C#中处理文本文件时,直接使用 FileStream 操作字节数组不仅繁琐,还需手动处理编码、换行符等问题。StreamReader 和 StreamWriter 提供了更高级的文本流操作接口,支持自动编码检测、换行符处理及便捷的读写方法,大幅简化开发流程。
二、基础用法
1. 创建 StreamReader 和 StreamWriter 对象
在 C# 中,有多种方式可以创建 StreamReader 和 StreamWriter 对象:
1)从文件路径创建
使用文件路径创建 StreamReader 和 StreamWriter 对象是最常见的方法。
自动处理编码(默认UTF-8)
using System.IO;// 创建 StreamReader
using (StreamReader reader = new StreamReader("example.txt"))
{// 读取操作
}// 创建 StreamWriter
using (StreamWriter writer = new StreamWriter("example.txt"))
{// 写入操作
}
2)从流创建
也可以从现有的流 Stream对象创建 StreamReader 和 StreamWriter,例如从 MemoryStream 或网络流、 FileStream,适合复杂场景。
using System.IO;// 从 MemoryStream 创建
MemoryStream memoryStream = new MemoryStream();
StreamReader reader = new StreamReader(memoryStream);
StreamWriter writer = new StreamWriter(memoryStream);// 从 FileStream 创建
FileStream fs = new FileStream("data.bin", FileMode.Open);
using (StreamReader sr = new StreamReader(fs)) { /*...*/ }
3)编码与格式设置
▶ 指定编码
默认编码为 UTF-8,但可通过构造函数指定其他编码(如 UTF-16、ASCII):
// 使用 UTF-16 编码
using (StreamWriter writer = new StreamWriter("data.txt", false, Encoding.Unicode))
{writer.WriteLine("Hello, Unicode!");
}
▶ 追加写入模式
通过指定StreamWriter 的 append参数为true 设置为 追加写入(append: true)。
StreamWriter sw = new StreamWriter("log.txt", true, Encoding.UTF8); // 追加模式
▶ 控制底层流是否关闭
leaveOpen:控制底层流是否随读写器关闭(默认 false)。
MemoryStream ms= new MemoryStream();
StreamReader streamReader = new StreamReader(ms, Encoding.Unicode, leaveOpen: true);
▶ 自动检测编码
通过 StreamReader 的 DetectEncodingFromByteOrderMarks 属性,自动识别 BOM 标记:
using (StreamReader reader = new StreamReader("data.txt", Encoding.UTF8, detectEncodingFromByteOrderMarks:true))
{// 如果文件开头有 BOM,会自动检测编码string content = reader.ReadToEnd();
}
2. 使用 StreamWriter 写入数据
StreamWriter 提供了多种方法来写入文本数据,最常用的是 Write 和 WriteLine 方法。
1)写入数据
使用 Write 方法可以写入数据到文件中。支持字符串、数值等类型。
using (StreamWriter writer = new StreamWriter("example.txt"))
{// 写入不同类型的数据writer.Write(1.1f);writer.Write(42);writer.Write(new byte[] { 1, 2, 3 });writer.Write("Hello, World!");
}
2)写入带换行符的数据
使用 WriteLine 方法可以写入一个带换行符的数据。支持字符串、数值等类型。
using (StreamWriter writer = new StreamWriter("example.txt"))
{// 写入不同类型的数据writer.WriteLine(1.1f);writer.WriteLine(42);writer.WriteLine(new byte[] { 1, 2, 3 });writer.WriteLine("Hello, World!");
}
3. 使用 StreamReader 读取数据
StreamReader 提供了多种方法来读取文本数据,最常用的是 Read、ReadLine 和 ReadToEnd 方法。
1)读取字符
使用 Read 方法可以读取一个字符。
using (StreamReader reader = new StreamReader("example.txt"))
{int character;while ((character = reader.Read()) != -1){Console.Write((char)character);}
}
2)读取一行
使用 ReadLine 方法可以读取一行文本。
using (StreamReader reader = new StreamReader("example.txt"))
{string line;while ((line = reader.ReadLine()) != null){Console.WriteLine(line);}
}
3)读取所有文本
使用 ReadToEnd 方法可以读取整个文件的内容。
using (StreamReader reader = new StreamReader("example.txt"))
{string content = reader.ReadToEnd();Console.WriteLine(content);
}
批量操作:
ReadToEnd()一次性读取全文,Write()支持字符数组写入。
4. StreamReader 和 StreamWriter 的常用属性和方法
1)StreamReader的常用属性和方法
BaseStream:获取StreamReader所使用的基础流。CurrentEncoding:获取当前使用的字符编码。EndOfStream:指示是否已到达流的末尾。Peek:查看下一个字符而不读取它。Read:读取单个字符或字符数组。ReadBlock:读取指定数量的字符。ReadLine:读取一行文本。ReadToEnd:读取流中的所有文本。
2)StreamWriter的常用属性和方法
BaseStream:获取StreamWriter所使用的基础流。AutoFlush:获取或设置一个值,该值指示是否在写入数据后自动刷新流。Encoding:获取当前使用的字符编码。Write:写入指定的数据。WriteLine:写入指定的数据,并添加换行符。Flush:将所有缓冲的字符写入基础流。Close:关闭流并释放所有相关资源。
3)使用示例
▶ 获取当前编码
可以使用 CurrentEncoding 属性获取当前使用的编码。
using (StreamReader reader = new StreamReader("example.txt"))
{Encoding encoding = reader.CurrentEncoding;Console.WriteLine("Encoding: " + encoding.EncodingName);
}
▶ 获取基础流对象
使用 BaseStream 属性可以获取基础流对象。
using (StreamReader reader = new StreamReader("example.txt"))
{Stream stream = reader.BaseStream;// 操作流
}
▶ 指示是否已到达流的末尾
while (!sr.EndOfStream) {string line = sr.ReadLine();Console.WriteLine(line);}
5. 示例代码
下面是一个完整的示例,演示了如何使用 StreamReader 和 StreamWriter:
class Program
{static void Main(){string filePath = "example.txt";// 使用 StreamWriter 写入数据using (StreamWriter writer = new StreamWriter(filePath)){writer.WriteLine("Hello, World!");writer.WriteLine("This is a new line.");writer.WriteLine("The answer is: 42");}// 使用 StreamReader 读取数据using (StreamReader reader = new StreamReader(filePath)){string line;while ((line = reader.ReadLine()) != null){Console.WriteLine(line);}}// 使用 StreamReader 读取数据 + EndOfStream 属性判断using (StreamReader reader = new StreamReader(filePath)){while (!reader.EndOfStream){Console.WriteLine(reader.ReadLine());}}// 读取整个文件内容using (StreamReader reader = new StreamReader(filePath)){Console.WriteLine(reader.ReadToEnd());}string content = File.ReadAllText(filePath);Console.WriteLine("File content:");Console.WriteLine(content);// 读取字符using (StreamReader reader = new StreamReader(filePath)){int character;while ((character = reader.Read()) != -1){Console.Write((char)character);}}}
}
通过这个示例,我们可以看到 StreamReader 和 StreamWriter 在处理文本文件时是多么方便和高效。它们提供了丰富的功能,满足了多种文本处理需求。
三、高级用法
1. 高级技巧
1)异步操作
使用 ReadAsync、WriteAsync 实现异步读写,避免阻塞主线程,提升I/O性能
public async Task WriteAsync()
{using (StreamWriter writer = new StreamWriter("data.txt")){await writer.WriteLineAsync("异步写入");}
}public async Task ReadAsync()
{using (StreamReader reader = new StreamReader("data.txt")){string content = await reader.ReadToEndAsync();}
}
2)缓冲区优化
预分配容量:若已知文件大小,初始化时指定 bufferSize 减少扩容开销。 平衡性能与内存占用
// 创建带自定义缓冲区的流
using (StreamReader reader = new StreamReader("data.txt", Encoding.UTF8, true, 8192))
{// 缓冲区大小为 8KB
}
3)大文件处理
逐行读取大文件以避免内存溢出:
using (StreamReader reader = new StreamReader("large_file.txt"))
{string line;while ((line = await reader.ReadLineAsync()) != null){// 处理每一行}
}
4)显式刷新缓冲区
- 显式刷新缓冲区:高频写入时调用
Flush()避免内存堆积。 - 延迟写入与批量提交:
sw.AutoFlush = false; // 关闭自动刷新 for (int i = 0; i < 1000; i++) {sw.Write($"Data {i}"); } sw.Flush(); // 手动批量提交
2. 高级应用示例
1)案例1:CSV文件解析
假设需读取包含逗号分隔的CSV文件并提取数据:
using (StreamReader sr = new StreamReader("data.csv"))
{while (!sr.EndOfStream) {string line = sr.ReadLine();string[] fields = line.Split(',').Select(f => f.Trim()).ToArray();// 处理字段数据...}
}
优势:自动处理编码与换行符,简化字符串分割逻辑。
2)案例2:大文件逐行处理与内存优化
当处理 GB 级日志文件时,需避免一次性加载全部数据导致内存溢出:
using (var sr = new StreamReader("large.log", Encoding.UTF8, bufferSize: 8192))
{while (!sr.EndOfStream) {string line = sr.ReadLine();if (line.Contains("ERROR")) {// 实时处理错误行}}
}
优化点:
- 设置
bufferSize为 8KB(默认 1KB),减少磁盘读取次数。 - 逐行释放内存,避免
ReadToEnd()的全量加载风险。
3)案例3:日志记录系统
public static void Log(string message)
{using var writer = new StreamWriter("app.log", true);writer.WriteLine($"[{DateTime.Now:yyyy-MM-dd HH:mm:ss}] {message}");
}
4)案例4:配置文件读写
var config = new Dictionary<string, string>();
using var reader = new StreamReader("config.ini");
while ((line = reader.ReadLine()) != null)
{var parts = line.Split('=');if (parts.Length == 2){config[parts[0]] = parts[1];}
}
四、常见问题与最佳实践
1. 常见问题
1)文件不存在时的异常
try
{using (StreamReader reader = new StreamReader("non_existent.txt")){// 处理文件}
}
catch (FileNotFoundException ex)
{Console.WriteLine("文件不存在:" + ex.Message);
}
2)编码不匹配导致乱码
确保读写时编码一致:
// 写入时使用 UTF-8
using (StreamWriter writer = new StreamWriter("data.txt", false, Encoding.UTF8)) { ... }// 读取时指定相同编码
using (StreamReader reader = new StreamReader("data.txt", Encoding.UTF8)) { ... }
3)资源未释放
始终使用 using 语句确保流正确关闭:
// 错误示例:未使用 using
StreamReader reader = new StreamReader("data.txt");
// ... 处理后未关闭,可能导致文件被锁定
reader.Close(); // 需手动调用// 正确做法:使用 using 自动释放资源
using (StreamReader reader = new StreamReader("data.txt")) { ... }// C# 8+简化写法
using var writer = new StreamWriter("output.txt");
4)编码问题
若文件包含BOM(字节顺序标记),可通过 detectEncodingFromByteOrderMarks: true 自动识别。
处理含 BOM 头的多编码文件时,自动适配编码:
using (FileStream fs = File.OpenRead("mixed_encoding.txt"))
{using (StreamReader sr = new StreamReader(fs, Encoding.Default, detectEncodingFromByteOrderMarks: true)) {Console.WriteLine($"检测到编码:{sr.CurrentEncoding}");// 按正确编码解析内容}
}
技巧:通过 CurrentEncoding 属性获取实际使用的编码。
5)流位置重置
写入后需调用 Seek(0, SeekOrigin.Begin) 重置位置,否则后续读取会从末尾开始。
6)避免嵌套流生命周期
避免嵌套流生命周期:确保底层流与读写器释放顺序一致(先关读写器,再关流)。
2. 最佳实践总结
- 资源管理:必须使用using语句
- 编码明确:尽量指定确定编码
- 异常处理:全面捕获IO异常
- 性能考量:大文件使用缓冲读取
- 模式选择:追加模式注意参数设置
结语
回到目录页:C#/.NET 知识汇总
希望以上内容可以帮助到大家,如文中有不对之处,还请批评指正。
相关文章:
C# StreamReader/StreamWriter 使用详解
总目录 前言 在 C# 开发中,StreamReader 和 StreamWriter 是处理文本文件的核心类,属于 System.IO 命名空间。它们基于流(Stream)操作文本数据,支持读写、编码设置、异步操作等,适用于日志记录、配置文件处…...
如何备份你的 Postman 所有 Collection?
团队合作需要、备份,还是迁移到其他平台,我们都需要在 Postman 中将这些珍贵的集合数据导出。 如何从 Postman 中导出所有集合(Collection)教程...
SQL IF(xxx, 1, 0) 窗口函数
IF(xxx, 1, 0)是SQL中的条件表达式函数,它的工作原理如下: 功能:如果条件xxx为真(TRUE),则返回1;如果条件xxx为假(FALSE),则返回0 参数: 第一个参数(xxx):要评估的条件表达式 第二…...
【Qt】三种操作sqlite3的方式及其三种多表连接
一、sqlite3与MySQL数据库区别: 1. 数据库类型 SQLite3:是嵌入式数据库,它将整个数据库存储在单个文件中,不需要独立的服务器进程。这意味着它可以很方便地集成到各种应用程序中,如移动应用、桌面应用等。MySQL&…...
MinGW下编译ffmpeg源码时生成compile_commands.json
在前面的博文MinGW下编译nginx源码中,有介绍到使用compiledb工具在MinGW环境中生成compile_commands.json,以为compiledb是捕获的make时的输出,而nginx生成时控制台是有输出编译时的命令行信息的,笔者之前编译过ffmpeg的源码&…...
【数据结构】树与森林
目录 树的存储方法 双亲表示法 孩子表示法 孩子兄弟表示法 树、森林与二叉树的转换 树转换成二叉树 森林转换成二叉树 二叉树转换成森林 树与森林的遍历 树的遍历 森林的遍历 树的存储方法 双亲表示法 这种存储结构采用一组连续空间来存储每个结点,同时…...
跟着StatQuest学知识08-RNN与LSTM
一、RNN (一)简介 整个过程权重和偏置共享。 (二)梯度爆炸问题 在这个例子中w2大于1,会出现梯度爆炸问题。 当我们循环的次数越来越多的时候,这个巨大的数字会进入某些梯度,步长就会大幅增加&…...
【SpringCloud】Eureka的使用
3. Eureka 3.1 Eureka 介绍 Eureka主要分为两个部分: EurekaServer: 作为注册中心Server端,向微服务应用程序提供服务注册,发现,健康检查等能力。 EurekaClient: 服务提供者,服务启动时,会向 EurekaS…...
nuxt3 seo优化
在 Nuxt3 中,通过 nuxtjs/seo、nuxtjs/sitemap 和 nuxtjs/robots 模块可以生成包含动态链接的站点地图(sitemap.xml),但具体是“实时生成”还是“部署时生成”,取决于你的配置方式和数据更新频率。以下是具体分析&…...
初识MySQL · 数据类型
目录 前言: 数值类型 文本、二进制数据类型 时间类型 String类型 前言: 对于MySQL来说,是一门编程语言,可能定义不是那么的严格,但是对于MySQL来说也是拥有自己的数据类型的,比如tinyint,…...
【Go】数组
数组Array 重点: 数组是值类型 注意点: 1. 数组:是同一种数据类型的固定长度的序列。2. 数组定义:var a [len]int,比如:var a [5]int,数组长度必须是常量,且是类型的组成部分。一旦定义&…...
QT图片轮播器(QT实操学习2)
1.项目架构 1.UI界面 2.widget.h #ifndef WIDGET_H #define WIDGET_H#include <QWidget>#define TIMEOUT 1 * 1000 QT_BEGIN_NAMESPACE namespace Ui { class Widget; } QT_END_NAMESPACEclass Widget : public QWidget {Q_OBJECTpublic:Widget(QWidget *parent n…...
深度解析衡石科技HENGSHI SENSE嵌入式分析能力:如何实现3天快速集成
嵌入式分析成为现代SaaS的核心竞争力 在当今SaaS市场竞争中,数据分析能力已成为产品差异化的关键因素。根据Bessemer Venture Partners的最新调研,拥有深度嵌入式分析功能的SaaS产品,其客户留存率比行业平均水平高出23%,ARR增长速…...
杂草YOLO系列数据集4000张
一份开源数据集——杂草YOLO数据集,该数据集适用于农业智能化、植物识别等计算机视觉应用场景。 数据集详情 训练集:3,664张高清标注图像测试集:180张多样性场景样本验证集:359张严格筛选数据 下载链接 杂草YOLO数据集分…...
Mybatis_Plus中常用的IService方法
查询 方法名 查询记录总数 /*** 查询总记录数** see Wrappers#emptyWrapper()*/default long count() {return count(Wrappers.emptyWrapper());} 方法实现 Testpublic void testGetCount(){long count userService.count();System.out.println("总记录数:&…...
Flink/Kafka在python中的用处
一、基础概念 1. Apache Kafka 是什么? 核心功能:Kafka 是一个分布式流处理平台,主要用于构建实时数据管道和流式应用程序。核心概念: 生产者(Producer):向 Kafka 发送数据的程序。…...
Vue 2 探秘:visible 和 append-to-body 是谁的小秘密?
🚀 Vue 2 探秘:visible 和 append-to-body 是谁的小秘密?🤔 父组件:identify-list.vue子组件:fake-clue-list.vue 嘿,各位前端探险家!👋 今天我们要在 Vue 2 的代码丛林…...
机器学习的一百个概念(1)单位归一化
前言 本文隶属于专栏《机器学习的一百个概念》,该专栏为笔者原创,引用请注明来源,不足和错误之处请在评论区帮忙指出,谢谢! 本专栏目录结构和参考文献请见[《机器学习的一百个概念》 ima 知识库 知识库广场搜索&…...
SpringCould微服务架构之Docker(5)
Docker的基本操作: 镜像相关命令: 1.镜像名称一般分两部分组成:[repository]:[tag]。 2. 在没有指定tag时,默认是latest,代表着最新版本的镜像。 镜像命令的案例: 镜像操作常用的命令: dock…...
JVM 如何打破双亲委派模型?
虽然双亲委派模型是 Java 类加载机制的推荐实现方式,但在某些情况下,为了实现特定的功能,可能需要打破双亲委派模型。以下是一些常见的打破双亲委派模型的方法和场景: 1. 重写 loadClass 方法 (不推荐): 原理: java.l…...
DeepSeek结合MCP Server与Cursor,实现服务器资源的自动化管理
MCP Server是最近AI圈子中又一个新的热门话题。很多用户都通过结合大语言模型、MCP Server,实现了一些工具流的自动化,例如,你只需要给出文字指令,就可以让Blender自动化完成建模的工作。你有没有想过,利用MCP来让AI A…...
SpringAI与JBoltAI深度对比:从工具集到企业级AI开发范式的跃迁
一、Java生态下大模型开发的困境与需求 技术公司的能力断层 多数企业缺乏将Java与大模型结合的标准开发范式,停留在碎片化工具使用阶段。 大模型应用需要全生命周期管理能力,而不仅仅是API调用。 工具集的局限性 SpringAI作为工具集的定位࿱…...
后端返回了 xlsx 文件流,前端怎么下载处理
当后端返回一个 .xlsx 文件流时,前端可以通过 JavaScript 处理这个文件流并触发浏览器下载。 实现步骤 发送请求获取文件流: 使用 fetch 或 axios 等工具向后端发送请求,确保响应类型设置为 blob(二进制数据流)。 创建…...
一文读懂Python之json模块(33)
一、json模块介绍 json模块的功能是将序列化的json数据从文件里读取出来或者存入文件。json是一种轻量级的数据交换格式,在大部分语言中,它被理解为数组(array)。 json模块序列化与反序列化的过程分别是 encoding和 decoding。e…...
Python中multiprocessing的使用详解
1.实现多进程 代码实现: from multiprocessing import Process import datetime import timedef task01(name):current_timedatetime.datetime.now()start_timecurrent_time.strftime(%Y-%m-%d %H:%M:%S). "{:03d}".format(current_time.microsecond //…...
强化学习与神经网络结合(以 DQN 展开)
目录 基于 PyTorch 实现简单 DQN double DQN dueling DQN Noisy DQN:通过噪声层实现探索,替代 ε- 贪心策略 Rainbow_DQN如何计算连续型的Actions 强化学习中,智能体(Agent)通过与环境交互学习最优策略。当状态空间或动…...
函数式组件中的渲染函数 JSX
在 Vue.js 和 React 等现代前端框架中,函数式组件已成为一种非常流行的设计模式。函数式组件是一种没有内部状态和生命周期方法的组件,其主要功能是接受 props 并渲染 UI。随着这些框架的演进,渲染函数和 JSX(JavaScript XML&…...
北斗导航 | 基于因子图优化的GNSS/INS组合导航完好性监测算法研究,附matlab代码
以下是一篇基于因子图优化(FGO)的GNSS/INS组合导航完好性监测算法的论文框架及核心内容,包含数学模型、完整Matlab代码及仿真分析基于因子图优化的GNSS/INS组合导航完好性监测算法研究 摘要 针对传统卡尔曼滤波在组合导航完好性监测中对非线性与非高斯噪声敏感的问题,本文…...
飞书电子表格自建应用
背景 coze官方的插件不支持更多的飞书电子表格操作,因为需要自建应用 飞书创建文件夹 创建应用 开发者后台 - 飞书开放平台 添加机器人 添加权限 创建群 添加刚刚创建的机器人到群里 文件夹邀请群 创建好后,就可以拿到id和key 参考教程: 创…...
深度学习四大核心架构:神经网络(NN)、卷积神经网络(CNN)、循环神经网络(RNN)与Transformer全概述
目录 📂 深度学习四大核心架构 🌰 知识点概述 🧠 核心区别对比表 ⚡ 生活化案例理解 🔑 选型指南 📂 深度学习四大核心架构 第一篇: 神经网络基础(NN) 🌰 知识点概述…...
