当前位置: 代码迷 >> Java相关 >> StringReader
  详细解决方案

StringReader

热度:592   发布时间:2016-04-22 19:09:09.0
【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();    }}