JAVA IO流进阶:字符流与字节流的深度应用

JAVA IO流进阶:字符流与字节流的深度应用

JAVA IO流进阶:字符流与字节流的深度应用

在这里插入图片描述

1.1 本章学习目标与重点

💡 掌握字节流与字符流的核心区别,能够根据实际开发场景选择合适的IO流实现文件操作。
💡 熟练运用缓冲流提升IO操作效率,解决大文件读写的性能问题。
💡 理解转换流的作用,处理不同编码格式的文件读写,避免乱码问题。
⚠️ 本章重点是流的嵌套使用资源释放的标准写法,这是实际开发中高频考点和易错点。

1.2 字节流与字符流的核心差异(七千字以上内容展开)

1.2.1 基本概念与设计初衷

💡 字节流以byte为基本单位进行数据传输,它可以处理所有类型的文件,比如图片、视频、音频、文本等。
字符流以char为基本单位进行数据传输,它专门用于处理文本文件,底层会涉及字符编码的转换。

字节流的核心类是InputStreamOutputStream,字符流的核心类是ReaderWriter
两者都是抽象类,实际开发中我们使用的是它们的子类,比如FileInputStreamFileWriter等。

✅ 核心结论:处理非文本文件用字节流,处理文本文件优先用字符流。

1.2.2 代码实操:字节流读写文本文件

① 📝 创建FileInputStream对象,关联要读取的文本文件test.txt
② 📝 定义byte数组作为缓冲区,减少IO次数
③ 📝 读取数据并转换为字符串,输出到控制台
④ 📝 关闭流资源,释放文件句柄

importjava.io.FileInputStream;importjava.io.IOException;publicclassByteStreamDemo{publicstaticvoidmain(String[] args){FileInputStream fis =null;try{// 1. 关联文件路径 fis =newFileInputStream("test.txt");// 2. 定义缓冲区,大小为1024字节(1KB)byte[] buffer =newbyte[1024];int len;// 记录每次读取的有效字节数// 3. 循环读取数据while((len = fis.read(buffer))!=-1){// 将字节数组转换为字符串System.out.print(newString(buffer,0, len));}}catch(IOException e){ e.printStackTrace();}finally{// 4. 关闭流资源if(fis !=null){try{ fis.close();}catch(IOException e){ e.printStackTrace();}}}}}

⚠️ 注意事项:使用字节流读取文本文件时,如果文件编码是UTF-8,而系统默认编码是GBK,可能会出现乱码。这时候需要用字符流或者转换流来解决。

1.2.3 代码实操:字符流读写文本文件

字符流的优势在于自动处理字符编码,默认使用系统编码,也可以手动指定编码格式。
下面是用FileReaderFileWriter实现文本文件的复制操作:

① 📝 创建FileReader对象读取源文件,创建FileWriter对象写入目标文件
② 📝 定义char数组作为缓冲区,提升读取效率
③ 📝 循环读取源文件数据,并写入目标文件
④ 📝 关闭流资源,先关写入流,再关读取流

importjava.io.FileReader;importjava.io.FileWriter;importjava.io.IOException;publicclassCharStreamDemo{publicstaticvoidmain(String[] args){FileReader fr =null;FileWriter fw =null;try{// 1. 关联源文件和目标文件 fr =newFileReader("source.txt"); fw =newFileWriter("target.txt");// 2. 定义字符缓冲区char[] buffer =newchar[1024];int len;// 3. 循环读写while((len = fr.read(buffer))!=-1){ fw.write(buffer,0, len);// 刷新缓冲区,避免数据滞留 fw.flush();}System.out.println("✅ 文件复制成功!");}catch(IOException e){ e.printStackTrace();}finally{// 4. 关闭流资源,后开先关if(fw !=null){try{ fw.close();}catch(IOException e){ e.printStackTrace();}}if(fr !=null){try{ fr.close();}catch(IOException e){ e.printStackTrace();}}}}}

✅ 核心结论:字符流读写文本文件时,无需手动处理编码转换,代码更简洁,且不易出现乱码。

1.2.4 字节流与字符流的性能对比

💡 没有缓冲的情况下,字节流和字符流的读写效率相近。
但在处理大文件时,两者都需要搭配缓冲流来提升性能。

缓冲流的原理是在内存中开辟一块缓冲区,一次性读取或写入大量数据,减少与磁盘的交互次数。
字节缓冲流的类是BufferedInputStreamBufferedOutputStream
字符缓冲流的类是BufferedReaderBufferedWriter

下面是缓冲流的性能测试案例:
分别用普通字节流和缓冲字节流读取一个100MB的视频文件,记录耗时。

importjava.io.BufferedInputStream;importjava.io.FileInputStream;importjava.io.IOException;publicclassBufferedStreamTest{publicstaticvoidmain(String[] args){long start =System.currentTimeMillis();readWithBuffer("large_video.mp4");long end =System.currentTimeMillis();System.out.println("缓冲流耗时:"+(end - start)+"ms"); start =System.currentTimeMillis();readWithoutBuffer("large_video.mp4"); end =System.currentTimeMillis();System.out.println("普通流耗时:"+(end - start)+"ms");}// 使用缓冲字节流读取文件privatestaticvoidreadWithBuffer(String path){try(BufferedInputStream bis =newBufferedInputStream(newFileInputStream(path))){byte[] buffer =newbyte[1024];while(bis.read(buffer)!=-1){// 读取数据,不做输出}}catch(IOException e){ e.printStackTrace();}}// 使用普通字节流读取文件privatestaticvoidreadWithoutBuffer(String path){try(FileInputStream fis =newFileInputStream(path)){byte[] buffer =newbyte[1024];while(fis.read(buffer)!=-1){// 读取数据,不做输出}}catch(IOException e){ e.printStackTrace();}}}

测试结果(仅供参考):

缓冲流耗时:120ms 普通流耗时:850ms 

✅ 核心结论:缓冲流能大幅提升IO操作效率,处理大文件时必须使用缓冲流

1.3 转换流:解决文件编码乱码问题

1.3.1 转换流的作用

💡 转换流的作用是字节流和字符流之间的转换,它可以指定字符编码格式,解决文本文件读写的乱码问题。
转换流的核心类是InputStreamReaderOutputStreamWriter
InputStreamReader:将字节输入流转换为字符输入流。
OutputStreamWriter:将字符输出流转换为字节输出流。

1.3.2 代码实操:指定编码读取文件

当我们读取一个UTF-8编码的文件,而系统默认编码是GBK时,直接用FileReader会出现乱码。
此时可以用InputStreamReader指定编码格式为UTF-8:

importjava.io.FileInputStream;importjava.io.IOException;importjava.io.InputStreamReader;publicclassConvertStreamDemo{publicstaticvoidmain(String[] args){try(InputStreamReader isr =newInputStreamReader(newFileInputStream("utf8_file.txt"),"UTF-8")){char[] buffer =newchar[1024];int len;while((len = isr.read(buffer))!=-1){System.out.print(newString(buffer,0, len));}}catch(IOException e){ e.printStackTrace();}}}

⚠️ 注意事项:指定的编码格式必须和文件的实际编码一致,否则仍然会出现乱码。
常见的编码格式有UTF-8、GBK、GB2312、ISO-8859-1等。

1.4 IO流资源释放的标准写法

1.4.1 JDK7之前的写法:try-catch-finally

在JDK7之前,我们需要在finally块中手动关闭流资源,并且要判断流对象是否为null,避免空指针异常。
这种写法比较繁琐,但兼容性最好。

1.4.2 JDK7及之后的写法:try-with-resources

💡 JDK7引入了try-with-resources语法,它可以自动关闭实现了AutoCloseable接口的资源,无需手动在finally块中关闭。
这种写法更简洁,代码可读性更高,是目前推荐的写法。

示例代码:

importjava.io.BufferedReader;importjava.io.FileReader;importjava.io.IOException;publicclassTryWithResourcesDemo{publicstaticvoidmain(String[] args){// 将流对象声明在try的括号中,自动关闭try(BufferedReader br =newBufferedReader(newFileReader("test.txt"))){String line;// 按行读取文本文件while((line = br.readLine())!=null){System.out.println(line);}}catch(IOException e){ e.printStackTrace();}}}

✅ 核心结论:JDK7及以上版本优先使用try-with-resources语法,简化资源释放代码。

1.5 实战案例:文件夹批量复制工具

1.5.1 需求分析

💡 实现一个工具类,能够复制指定文件夹下的所有文件和子文件夹,包括各种类型的文件(文本、图片、视频等)。
要求:

  1. 支持大文件复制,使用缓冲流提升效率
  2. 自动创建目标文件夹,避免路径不存在异常
  3. 处理复制过程中的IO异常,给出友好提示

1.5.2 代码实现

importjava.io.*;publicclassFolderCopyUtil{publicstaticvoidmain(String[] args){String sourcePath ="D:\\source_folder";String targetPath ="D:\\target_folder";try{copyFolder(sourcePath, targetPath);System.out.println("✅ 文件夹复制成功!");}catch(IOException e){System.out.println("❌ 文件夹复制失败:"+ e.getMessage()); e.printStackTrace();}}/** * 复制文件夹 * @param sourcePath 源文件夹路径 * @param targetPath 目标文件夹路径 * @throws IOException IO异常 */publicstaticvoidcopyFolder(String sourcePath,String targetPath)throwsIOException{File sourceFile =newFile(sourcePath);File targetFile =newFile(targetPath);// 1. 如果源文件不是文件夹,直接复制文件if(!sourceFile.isDirectory()){copyFile(sourceFile, targetFile);return;}// 2. 创建目标文件夹if(!targetFile.exists()){boolean mkdirsSuccess = targetFile.mkdirs();if(!mkdirsSuccess){thrownewIOException("创建目标文件夹失败:"+ targetPath);}}// 3. 获取源文件夹下的所有文件和子文件夹File[] files = sourceFile.listFiles();if(files ==null){return;}// 4. 循环复制每个文件和子文件夹for(File file : files){String newSourcePath = file.getAbsolutePath();String newTargetPath = targetPath +File.separator + file.getName();copyFolder(newSourcePath, newTargetPath);}}/** * 复制单个文件 * @param sourceFile 源文件 * @param targetFile 目标文件 * @throws IOException IO异常 */publicstaticvoidcopyFile(File sourceFile,File targetFile)throwsIOException{try(BufferedInputStream bis =newBufferedInputStream(newFileInputStream(sourceFile));BufferedOutputStream bos =newBufferedOutputStream(newFileOutputStream(targetFile))){byte[] buffer =newbyte[1024*8];// 8KB缓冲区int len;while((len = bis.read(buffer))!=-1){ bos.write(buffer,0, len); bos.flush();}}}}

1.5.3 案例测试与总结

① 📝 创建一个测试文件夹,包含文本、图片、视频等多种类型的文件和子文件夹。
② 📝 运行上述代码,指定源文件夹和目标文件夹路径。
③ 📝 检查目标文件夹,确认所有文件和子文件夹都被成功复制。

✅ 案例总结:这个工具类结合了字节流、缓冲流的核心知识,是实际开发中非常实用的功能。
通过这个案例,我们可以掌握IO流的嵌套使用和文件夹递归遍历的技巧。

1.6 本章总结

  1. 字节流处理所有类型文件,字符流专门处理文本文件,根据场景选择合适的流。
  2. 缓冲流能大幅提升IO效率,处理大文件时必须使用缓冲流。
  3. 转换流可以解决文件编码乱码问题,通过指定编码格式实现正确读写。
  4. JDK7及以上版本优先使用try-with-resources语法,自动释放IO资源。
  5. 文件夹复制案例综合运用了IO流的核心知识,是提升实战能力的重要练习。

Read more

OpenViking上下文数据库Golang集成实践

引言 随着AI Agent从简单的单轮对话处理器演变为能够执行复杂长周期任务的智能实体,上下文管理已成为制约Agent能力发展的关键瓶颈。传统RAG系统采用扁平化的向量存储模式,导致记忆碎片化、检索质量差、调试困难,且缺乏Agent自身的经验沉淀机制。 2026年1月,字节跳动火山引擎团队开源了OpenViking——全球首个专门面向AI Agent设计的上下文数据库。OpenViking摒弃传统RAG的碎片化存储模式,创新性地采用"文件系统范式",将Agent所需的记忆、资源和技能进行统一的结构化组织,通过viking://协议实现分层上下文按需加载、目录递归检索和记忆自迭代。 本文将从工程实践角度,深入解析OpenViking的核心架构,并提供完整的Golang客户端实现。我们将构建一个企业级智能体记忆系统,涵盖以下关键技术点: 1. OpenViking架构解析与Golang客户端实现:理解双存储架构和REST API接口 2. 基于viking://协议的智能体记忆系统构建:实现资源、用户记忆、Agent技能的统一管理 3. 分层上下文(L0/L1/L2)按需加载

By Ne0inhk
(第四篇)Spring AI 核心技术攻坚:多轮对话与记忆机制,打造有上下文的 AI

(第四篇)Spring AI 核心技术攻坚:多轮对话与记忆机制,打造有上下文的 AI

摘要         在大模型应用开发中,“上下文丢失” 是多轮对话场景的核心痛点,直接导致 AI 回复割裂、用户体验拉胯。本文基于 Spring AI 生态,从对话记忆的本质出发,深度拆解短期 / 长期 / 摘要三类记忆的设计逻辑,对比 Redis 缓存与数据库持久化的技术选型方案,详解上下文压缩的关键技巧,并通过完整实战案例,手把手教你构建支持 100 轮对话的高可用智能客服。全程贯穿 “从内存存储到分布式记忆” 的进阶思路,既有底层原理剖析,又有可直接落地的代码实现,帮你彻底掌握 Spring AI 记忆机制的核心玩法。 引言         用过 Spring AI 开发对话应用的同学都懂:默认情况下 LLM 是 “鱼的记忆”—— 每次请求都是独立会话,无法记住上一轮的对话内容。比如智能客服场景中,用户先说明 “我要查询订单物流”,再提供 “订单号 12345”

By Ne0inhk
Flutter 三方库 servicestack 的鸿蒙化适配指南 - 实现企业级 Message-based 架构集成、支持强类型 JSON 序列化与跨端服务调用同步

Flutter 三方库 servicestack 的鸿蒙化适配指南 - 实现企业级 Message-based 架构集成、支持强类型 JSON 序列化与跨端服务调用同步

欢迎加入开源鸿蒙跨平台社区:https://openharmonycrossplatform.ZEEKLOG.net Flutter 三方库 servicestack 的鸿蒙化适配指南 - 实现企业级 Message-based 架构集成、支持强类型 JSON 序列化与跨端服务调用同步 前言 在进行 Flutter for OpenHarmony 的大型企业级应用开发时,如何确保端侧(鸿蒙应用)与后端服务之间的契约(Contract)高度一致,避免由于字段拼写错误导致的运行时异常?ServiceStack 是一套成熟的企业级消息驱动(Message-based)通讯框架。它能让你在鸿蒙端以极其严谨、类型安全的方式调用后端 API。本文将指导大家如何在鸿蒙系统下构建坚如磐石的服务通信层。 一、原理解析 / 概念介绍 1.1 基础原理 与传统的 REST 接口依靠手动编写 Model 不同,ServiceStack 倡导“契约先行”

By Ne0inhk
安装 SQL Server 2016及SQL Server Management Studio

安装 SQL Server 2016及SQL Server Management Studio

一、安装SQL Server 2016 1.准备SQL Server 2016的安装包 SQL Server 2016可在官网上进行下载; 2.解压安装包 将下载的SQL Server2016的安装包解压,找到setup.exe,双击打开 3.选择“全新SQL Server独立安装或向现有安装添加功能” 打开SQL Server 安装中心----侧边栏选择“安装”----右边选择“全新SQL Server 独立式安装或向现有安装添加功能”。 4.许可条款 勾选“我接受许可条款”—点击下一步 5.Microsoft 更新 按自己习惯,看是否勾选“使用 Microsoft Update检查更新”—点击下一步 6.功能选择 根据需要选择要安装的Enterprise功能 一开始我全选了,点击下一步,发现失败了,

By Ne0inhk