Java:IO流之字符流缓冲区详解

简介:
字符流缓冲区:
1、缓冲区的出现提高了对数据的读写效率;
2、对应类:BufferedWriter、BufferedReader;
3、缓冲区要结合流才可以使用;
4、在流的基础上对流的功能进行了增强。
 
注意:缓冲区的出现是为了提高流的操作效率而出现的,所以在创建缓冲区之前必须现有流对象。
 
java.io 
类 BufferedReader:读入缓冲区
 
构造方法摘要 
BufferedReader(Reader in)  创建一个使用默认大小输入缓冲区的缓冲字符输入流。 
BufferedReader(Reader in, int sz)  创建一个使用指定大小输入缓冲区的缓冲字符输入流。 
主要方法摘要 
 void close()  关闭该流并释放与之关联的所有资源。  
 int read() 作为一个整数(其范围从0到65535(0x00-0xffff)读入的字符,如果已到达流末尾,则返回 -1, 读取单个字符。 
 int read(char[] cbuf, int off, int len)  将字符读入数组的某一部分。 
 String readLine() //包含该行内容的字符串,不包含任何行终止符,如果已到达流末尾,则返回 null , 读取一个文本行。 

 //例子1:

复制代码
import java.io.*;
class BufferedReaderDemo
{
    public static void main(String[] args) throws IOException
    {
        //创建一个字符读入流对象,和目的地文件相关联.
        FileReader fr = new FileReader("F:\\myfile\\buf.txt");
        
        //为了提高字符读入流效率,加入了缓冲技术,只需要将被提高效率的流对象作为参数
        //传递给缓冲区的构造函数即可。此时,缓冲区和流相关联.
        BufferedReader buf = new BufferedReader(fr);
        int num = 0;
        String line = null;
        
        /*
        while((line = buf.readLine())!=null) //此过程中,读入缓冲区一行一行的读取数据,效率高
        {
            System.out.println(line);
        }
        */
        
        while((num = buf.read())!=-1)
        {
         System.out.print((char)num);        
        }

       //其实关闭缓冲区,就是关闭缓冲区中的流对象
        buf.close();
    }
}
复制代码

 

readLine方法的原理:尽管是读取一行获取多个字符,其实最终都是在硬盘上一个一个地读取字符。所以最终使用的还是read方法一次读一个的方法。
明白了BufferedReader类中特有方法readLine的原理后,
可以自定义一个类中包含一个功能和readLine一致的方法,
来模拟一个BufferedReader
(该代码中的思想体现了装饰设计模式)
//例子2:
复制代码
import java.io.*;
class MyBufferedReader extends Reader
{
    private Reader r;
    MyBufferedReader(Reader r)
    {
        this.r = r;
    } 
    //可以一次读一行的方法
    public String MyreadLine() throws IOException
    {
     //定义一个临时容器。原BufferedReader封装的是字符数组。
     //为了演示方便,定义一个StringBuilder容器,因为最终还是要将数据变为字符串
      StringBuilder sb = new StringBuilder();
      int ch = 0;
      while((ch=r.read())!=-1)
      {
        if(ch=='\r')  
            continue;
        if(ch=='\n')
            return sb.toString();
        else
            sb.append((char)ch);    
      }    
      if(sb.length()!=0)   //出现读取一行数据到了缓冲区,但是该字符串后面没有'\n',可是仍要把它读取出来。
            return sb.toString();
      return null;      
    }
    //覆盖Reader中的抽象方法
    public int read(char[] cbuf, int off, int len) throws IOException
    {
        return r.(cbuf,off,len);
    }
    public void close()throws IOException
    {
        r.close();
    }

    public void Myclose()throws IOException
    {
        r.close();
    }
}
//测试类
class MyBufferedReaderTest { public static void main(String[] args) { FileReader fr = null; MyBufferedReader mybuf = null; String line = null; try { mybuf = new MyBufferedReader(new FileReader("F:\\myfile\\buf.txt")); while((line = mybuf.MyreadLine())!=null) { System.out.println(line); } } catch(IOException e) { throw new RuntimeException("读入流异常"); } finally { try { mybuf.Myclose(); } catch(IOException e) { throw new RuntimeException("关闭流异常"); } } } }
复制代码

自定义一个统计行号的类:MyLineNumberReader,可以设置复制得到的文件内容的行号

//例子3:
复制代码
import java.io.*;
/*
class MyLineNumberReader extends MyBufferedReader
{
    private int linenumber;
    MyLineNumberReader(Reader r)
    {
        super(r);
    }
    public void setLineNumber(int linenumber)
    {
        this.linenumber = linenumber;
    }
    public int getLineNumber()
    {
        return linenumber;
    }
    public String MyreadLine() throws IOException
    {   
        linenumber++;//每读一行,行数就自加一次
        return super.MyreadLine();
    }
}
*/
class MyLineNumberReader
{
    private Reader r;
    private int linenumber;
    MyLineNumberReader(Reader r)
    {
        this.r = r;
    }
    public void setLineNumber(int linenumber)
    {
        this.linenumber = linenumber;
    }
    public int getLineNumber()
    {
        return linenumber;
    }
    public String MyreadLine() throws IOException
    {   
        linenumber++;//每读一行,行数就自加一次
        StringBuilder sb = new StringBuilder();
        int ch = 0;
        while((ch = r.read())!=-1)
        {
            if(ch=='\r')
                continue;
            if(ch=='\n')
                return sb.toString();
            else
                sb.append((char)ch);
        }
        if(sb.length()!=0)
            return sb.toString();
        return null;
    }
    public void Myclose() throws IOException
    {
        r.close();
    }
}
class MyLineNumberReaderDemo
{
    public static void main(String[] args)
    {
        FileReader fr = null;
        MyLineNumberReader myl = null;
        String str = null;
        try
        {
          fr  = new FileReader("MyBufferedReaderTest.java");
          myl = new MyLineNumberReader(fr);
          //myl.setLineNumber(100);  //设置第一行从101行开始
          while((str = myl.MyreadLine())!=null)
           {
             System.out.println(myl.getLineNumber()+":"+str);
           }              
        }
        catch(IOException e)
        {
            System.out.println("流读入异常!");
        }
        finally
        {
            try
            {
                myl.Myclose();
            }
            catch(IOException e)
            {
                System.out.println("流关闭异常!");
            }
        
        }        
    }
}
复制代码

 

java.io 
类 BufferedWriter:写入缓冲区

构造方法摘要 

BufferedWriter(Writer out) 创建一个使用默认大小输出缓冲区的缓冲字符输出流。 

BufferedWriter(Writer out, int sz) 创建一个使用给定大小输出缓冲区的新缓冲字符输出流。 

方法摘要 

void close() 关闭此流,但要先刷新它。 

void flush() 刷新该流的缓冲。 

void newLine() 写入一个行分隔符。具有跨平台性,相当于windows系统的"\r\n"和linux系统的"\n";

void write(char[] cbuf, int off, int len) 写入字符数组的某一部分。 

void write(int c) 写入单个字符。 

void write(String s, int off, int len) 写入字符串的某一部分。 

//例子4:
复制代码
import java.io.*;
class BufferedWriterDemo
{
    public static void main(String[] args) throws IOException
    {
        //创建一个字符写入流对象,和目的地文件相关联.
        FileWriter fw = new FileWriter("F:\\myfile\\buf.txt");
        
        //为了提高字符写入流效率,加入了缓冲技术,只需要将被提高效率的流对象作为参数
        //传递给缓冲区的构造函数即可。此时,缓冲区和流相关联.
        BufferedWriter buf = new BufferedWriter(fw);
        
        buf.write("abcdefg");
        for(int i=0;i<3;i++)
        {
        buf.newLine();//换行
        buf.write("changjiang"+i);
        //记住,只要用到缓冲区,必须要刷新
        buf.flush();        
        }
        //其实关闭缓冲区,就是关闭缓冲区中的流对象
        buf.close();
    }
}
复制代码

 

使用字符流缓冲的一个综合实例如下:
要求:通过一个缓冲区复制一个.java文件
注意:readLine()方法返回的时候只返回回车符之前的数据内容,并不返回回车符。
//例子5: 没有异常处理时:
复制代码
import java.io.*;
class BufferedCopyTest
{
    public static void main(String[] args)throws IOException
    {
        //创建一个读入流对象,与要被复制的文件相关联
        FileReader fr = new FileReader("BufferedReaderDemo.java");
        //创建一个写入流对象,与目的文件相关联
        FileWriter fw = new FileWriter("BufferedReaderDemo_Copy.txt");
        
        //创建一个读入缓冲区,与流对象相关联
        BufferedReader bufr = new BufferedReader(fr);
        //创建一个写入缓冲区,与流对象相关联
        BufferedWriter bufw = new BufferedWriter(fw);        
        
        //读取数据存入缓冲区中
        String line;
        while((line = bufr.readLine())!=null)
        {
            bufw.write(line);
            bufw.newLine();
            bufw.flush();
        }
        bufw.close();
        bufr.close();
    }
}
复制代码
//例子6: 有异常的处理时:
复制代码
import java.io.*;
class BufferedCopyTest2
{
    public static void main(String[] args)
    {
        BufferedReader bufr = null;
        BufferedWriter bufw = null;
        try
        {
         bufr = new BufferedReader(new FileReader("BufferedReaderDemo.java"));
         bufw = new BufferedWriter(new FileWriter("BufferedReader_Copy.txt"));                
         String line;
          while((line = bufr.readLine())!=null)
          {
            System.out.println(line);  
            bufw.write(line);
            bufw.newLine();
            bufw.flush();
          }
        }
        catch(IOException e)
        {
            throw new RuntimeException("读写入异常");
        }
        finally
        {
          try
          { 
            if(bufr!=null)
               bufr.close();                  
          }    
          catch(IOException e)
          {
            throw new RuntimeException("关闭流异常");  
          }
          try
          { 
            if(bufw!=null)
               bufw.close();                  
          }    
          catch(IOException e)
          {
            throw new RuntimeException("关闭流异常");  
          }
        }
    }
}
复制代码

 

 

 

程序猿神奇的手,每时每刻,这双手都在改变着世界的交互方式!
本文转自当天真遇到现实博客园博客,原文链接:http://www.cnblogs.com/XYQ-208910/p/4917994.html ,如需转载请自行联系原作者
相关文章
|
8月前
|
监控 Java API
现代 Java IO 高性能实践从原理到落地的高效实现路径与实战指南
本文深入解析现代Java高性能IO实践,涵盖异步非阻塞IO、操作系统优化、大文件处理、响应式网络编程与数据库访问,结合Netty、Reactor等技术落地高并发应用,助力构建高效可扩展的IO系统。
233 0
|
5月前
|
Java Unix Go
【Java】(8)Stream流、文件File相关操作,IO的含义与运用
Java 为 I/O 提供了强大的而灵活的支持,使其更广泛地应用到文件传输和网络编程中。!但本节讲述最基本的和流与 I/O 相关的功能。我们将通过一个个例子来学习这些功能。
242 1
|
7月前
|
Java 测试技术 API
Java IO流(二):文件操作与NIO入门
本文详解Java NIO与传统IO的区别与优势,涵盖Path、Files类、Channel、Buffer、Selector等核心概念,深入讲解文件操作、目录遍历、NIO实战及性能优化技巧,适合处理大文件与高并发场景,助力高效IO编程与面试准备。
|
8月前
|
存储 Java Linux
操作系统层面视角下 Java IO 的演进路径及核心技术变革解析
本文从操作系统层面深入解析Java IO的演进历程,涵盖BIO、NIO、多路复用器及Netty等核心技术。分析各阶段IO模型的原理、优缺点及系统调用机制,探讨Java如何通过底层优化提升并发性能与数据处理效率,全面呈现IO技术的变革路径与发展趋势。
171 2
|
7月前
|
SQL Java 数据库连接
Java IO流(一):字节流与字符流基础
本文全面解析Java IO流,涵盖字节流、字符流及其使用场景,帮助开发者理解IO流分类与用途,掌握文件读写、编码转换、异常处理等核心技术,通过实战案例提升IO编程能力。
|
12月前
|
存储 网络协议 安全
Java网络编程,多线程,IO流综合小项目一一ChatBoxes
**项目介绍**:本项目实现了一个基于TCP协议的C/S架构控制台聊天室,支持局域网内多客户端同时聊天。用户需注册并登录,用户名唯一,密码格式为字母开头加纯数字。登录后可实时聊天,服务端负责验证用户信息并转发消息。 **项目亮点**: - **C/S架构**:客户端与服务端通过TCP连接通信。 - **多线程**:采用多线程处理多个客户端的并发请求,确保实时交互。 - **IO流**:使用BufferedReader和BufferedWriter进行数据传输,确保高效稳定的通信。 - **线程安全**:通过同步代码块和锁机制保证共享数据的安全性。
519 23
|
12月前
|
存储 缓存 安全
Java字符串缓冲区
字符串缓冲区是用于处理可变字符串的容器,Java中提供了`StringBuffer`和`StringBuilder`两种实现。由于`String`类不可变,当需要频繁修改字符串时,使用缓冲区更高效。`StringBuffer`是一个线程安全的容器,支持动态扩展、任意类型数据转为字符串存储,并提供多种操作方法(如`append`、`insert`、`delete`等)。通过这些方法,可以方便地对字符串进行添加、插入、删除等操作,最终将结果转换为字符串。示例代码展示了如何创建缓冲区对象并调用相关方法完成字符串操作。
314 13
|
缓存 网络协议 Java
JAVA网络IO之NIO/BIO
本文介绍了Java网络编程的基础与历史演进,重点阐述了IO和Socket的概念。Java的IO分为设备和接口两部分,通过流、字节、字符等方式实现与外部的交互。
433 0
|
Java
java 中 IO 流
Java中的IO流是用于处理输入输出操作的机制,主要包括字节流和字符流两大类。字节流以8位字节为单位处理数据,如FileInputStream和FileOutputStream;字符流以16位Unicode字符为单位,如FileReader和FileWriter。这些流提供了读写文件、网络传输等基本功能。
262 10