你的位置:首页 > Java教程

[Java教程]【JAVA I/O】字符输入流Reader简要概括


字符输入流Reader组成结构

本篇将对JAVA I/O流中的字符输入流Reader做个简单的概括,先看下Reader的组成结构,如下图,再对各个字符输入流做个详细介绍;

InputStreamReader

InputStreamReader继承字符流抽象类Reader,每个构造方法都包含一个字节流InputStream入参,功能显而易见,就是通过字节流InputStream得到字符流;

PS:无论是构造方法里对字节流的处理(StreamDecoder.forInputStreamReader),还是字符流的读取(StreamDecoder.read),底层都是通过StreamDecoder类实现的,有兴趣的可以深入了解~

 举个例子,如下,为方便阅读,不做异常处理:

package io;import java.io.IOException;import java.io.InputStreamReader;import java.io.Reader;public class IOTest {  public static void main(String[] args) throws IOException {    //通过“标准”字节输入流得到一个字符输入流    Reader reader = new InputStreamReader(System.in);    //读取一个字符并打印    System.out.println((char)reader.read());    //关闭流    reader.close();  }}//输出示例//键盘输入0//显示0

FileReader

FileReader继承字符流InputStreamReader,通过本地字符文件得到字符流,查看其构造方法,都是先根据传入的参数生成一个FileInputStream字节流对象,然后调用父类InputStreamReader的构造方法得到字符流;

举个简单的例子:

package io;import java.io.FileReader;import java.io.IOException;import java.io.Reader;public class IOTest {  public static void main(String[] args) throws IOException {    //读取本地文件,得到字符流    Reader reader = new FileReader("C:\\test.txt");    //读取一个字符并打印    System.out.println((char)reader.read());    //关闭流    reader.close();  }}

CharArrayReader

CharArrayReader可以让我们通过字符数组得到字符流,构造方法如下

查看源码,可以发现在CharArrayReader里面直接使用外部字符数组的引用,也就是说,即使得到字符流对象后,当改变外部数组时,通过流读取的字符也会改变,如下代码实例:

package io;import java.io.CharArrayReader;import java.io.IOException;import java.io.Reader;public class IOTest {  public static void main(String[] args) throws IOException {    //字符数组    char[] charArr = new char[]{'a', 'b', 'c'};    //通过内存中的字符数组,得到字符流    Reader reader = new CharArrayReader(charArr);    //改变数组charArr的元素值    charArr[0] = 'e';    //读取一个字符并打印    System.out.println((char)reader.read());//打印改变后的字符'e'    //关闭流    reader.close();  }}

PipedReader

可以通过PipedWriter和PipedReader创建字符流管道,线程间可以通过管道进行通信,注意:一定要同一个JVM中的两个线程;

PipedReader一般是要和PipedWriter配合使用的,其中一个线程通过PipedWriter往管道写数据,另一个线程通过管道读数据,注意读写都会阻塞线程,如下示例:

package io;import java.io.IOException;import java.io.PipedReader;import java.io.PipedWriter;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;public class IOTest {  public static void main(String[] args) throws IOException {    final PipedWriter pw = new PipedWriter();    final PipedReader pr = new PipedReader(pw);    ExecutorService es = Executors.newFixedThreadPool(2);    es.execute(new Runnable() {      @Override      public void run() {        try {          pw.write("hello~");        } catch (IOException e) {          e.printStackTrace();        }      }    });    es.execute(new Runnable() {      @Override      public void run() {        char[] cbuffer = new char[6];        try {          // 会导致线程阻塞          pr.read(cbuffer, 0, 6);        } catch (IOException e) {          e.printStackTrace();        }        System.out.println(cbuffer);      }    });  }}

BufferedReader

这个字符流可以用来装饰其它字符输入流,可以为其它字符输入流提供字符缓冲区,避免每次从外部媒体中读取数据,这里用到了设计模式里的装饰器模式,可以参考我之前写的,

http://www.cnblogs.com/chenpi/p/5173818.html

被装饰的字符流可以有更多的行为,比如readLine方法等;

举个使用的例子,读取外部文件:

package io;import java.io.BufferedReader;import java.io.FileReader;import java.io.IOException;public class IOTest {  public static void main(String[] args) throws IOException {    //读取本地文件,得到字符流,这里设定缓冲区大小为10k    BufferedReader reader = new BufferedReader(new FileReader("C:\\test.txt"), 10 * 1024);    //读取一行    System.out.println(reader.readLine());    System.out.println(reader.readLine());    System.out.println(reader.readLine());    //关闭流    reader.close();  }}

LineNumberReader

继承BufferedReader,除了BufferedReader提供的功能外,还多了获取行号信息,

注意,LineNumberReader的setLineNumber方法并不能实现流的跳跃读取

举个例子

package io;import java.io.FileReader;import java.io.IOException;import java.io.LineNumberReader;public class IOTest {  public static void main(String[] args) throws IOException {    //读取本地文件,得到字符流,这里设定缓冲区大小为10k    LineNumberReader reader = new LineNumberReader(new FileReader("C:\\test.txt"), 10 * 1024);        System.out.println(reader.getLineNumber());//打印当前行号    System.out.println(reader.readLine());//读取一行    System.out.println(reader.getLineNumber());    System.out.println(reader.readLine());//读取一行    //关闭流    reader.close();  }}

FilterReader

抽象类FilterReader是实现自定义过滤输入字符流的基类,从源码的实现上来看,仅仅只是简单覆盖了Reader中的所有方法,感觉没什么卵用,因为已经有一个抽象类Reader了;

PushbackReader

简单的说,PushbackReader字符流允许你在读取字符的过程中,通过调用unread方法往缓冲区插入字符,下次读取的时候,先从缓冲区读数据,缓冲区没数据再从流中读取;

该类同样使用了装饰器模式;

一般可以用PushbackReader完成读取回退功能,比如把之前读取的字符通过调用unread方法插入到缓冲区中,下次再读取的时候,就又可以读取到之前的数据了;

举个例子如下:

package io;import java.io.FileReader;import java.io.IOException;import java.io.PushbackReader;public class IOTest {  public static void main(String[] args) throws IOException {    // 读取本地文件,得到字符流,这里设定缓冲区大小为1024k    PushbackReader reader = new PushbackReader(new FileReader("C:\\test.txt"), 1024);    // 读取一个字符    char a = (char) reader.read();    System.out.println(a);    // 将读取的字符推回到流中    // 其实说的简单点,就是将字符a存到缓冲区中,下次读取的时候先从缓冲区读数据,缓冲区没数据再从流中读取    reader.unread(a);    // 重新读取之前的字(在缓冲区中)    System.out.println((char) reader.read());    // 从流中读取数据    System.out.println((char) reader.read());    // 关闭流    reader.close();  }}

StringReader

将字符串转为字符输入流,比较简单,看个使用例子如下:

package io;import java.io.IOException;import java.io.StringReader;public class IOTest {  public static void main(String[] args) throws IOException {    // 通过字符串,得到字符流    StringReader reader = new StringReader("hello~");    // 从流中读取数据    char[] cbuf = new char[6];    reader.read(cbuf, 0, 6);    System.out.println(cbuf);    // 关闭流    reader.close();  }}