Java BufferedWriter BufferedReader 源码分析

一：bufferedwriter

 1、类功能简介：

        bufferedwriter、缓存字符输出流、他的功能是为传入的底层字符输出流提供缓存功能、同样当使用底层字符输出流向目的地中写入字符或者字符数组时、每写入一次就要打开一次到目的地的连接、这样频繁的访问不断效率底下、也有可能会对存储介质造成一定的破坏、比如当我们向磁盘中不断的写入字节时、夸张一点、将一个非常大单位是g的字节数据写入到磁盘的指定文件中的、没写入一个字节就要打开一次到这个磁盘的通道、这个结果无疑是恐怖的、而当我们使用bufferedwriter将底层字符输出流、比如filereader包装一下之后、我们可以在程序中先将要写入到文件中的字符写入到bufferedwriter的内置缓存空间中、然后当达到一定数量时、一次性写入filereader流中、此时、filereader就可以打开一次通道、将这个数据块写入到文件中、这样做虽然不可能达到一次访问就将所有数据写入磁盘中的效果、但也大大提高了效率和减少了磁盘的访问量！这就是其意义所在、 他的具体工作原理在这里简单提一下：这里可能说的比较乱、具体可以看源码、不懂再回头看看这里、当程序中每次将字符或者字符数组写入到bufferedwriter中时、都会检查bufferedwriter中的缓存字符数组buf（buf的大小是默认的或者在创建bw时指定的、一般使用默认的就好）是否存满、如果没有存满则将字符写入到buf中、如果存满、则调用底层的writer(char[] b, int off, int len)将buf中的所有字符一次性写入到底层out中、如果写入的是字符数组、如果buf中已满则同上面满的时候的处理、如果能够存下写入的字符数组、则存入buf中、如果存不下、并且要写入buf的字符个数小于buf的长度、则将buf中所有字符写入到out中、然后将要写入的字符存放到buf中（从下标0开始存放）、如果要写入out中的字符超过buf的长度、则直接写入out中、

2、bufferedwriter  api简介：

    a：关键字
  private writer out;		 底层字符输出流

  
  private char cb[];		 缓冲数组
  
  private int nchars, nextchar;		 nchars--cb的size，nextchar--cb中下一个字符的下标

  private static int defaultcharbuffersize = 8192;		 默认cb大小

  private string lineseparator;		换行符、用于newline方法。不同平台具有不同的值。

    b：构造方法

  bufferedwriter(writer out)		使用默认cb大小创建bufferedwriter bw。
  
  bufferedwriter(writer out, int sz)		使用默认cb大小创建bufferedwriter bw。

    c：一般方法

  void close()		关闭此流、释放与此流有关的资源。
  
  void flushbuffer()		将cb中缓存的字符flush到底层out中、
  
  void flush()	刷新此流、同时刷新底层out流
  
  void newline()		写入一个换行符。
  
  void write(int c)		将一个单个字符写入到cb中。
  
  void write(char cbuf[], int off, int len)	将一个从下标off开始长度为len个字符写入cb中
  
  void write(string s, int off, int len)		将一个字符串的一部分写入cb中

3、源码分析

package com.chy.io.original.code;

import java.io.ioexception;
import java.io.printwriter;


/**
 * 为字符输出流提供缓冲功能、提高效率。可以使用指定字符缓冲数组大小也可以使用默认字符缓冲数组大小。
 */

public class bufferedwriter extends writer {

	//底层字符输出流
  private writer out;

  //缓冲数组
  private char cb[];
  //nchars--cb中总的字符数，nextchar--cb中下一个字符的下标
  private int nchars, nextchar;

  //默认cb大小
  private static int defaultcharbuffersize = 8192;

  /**
   * line separator string. this is the value of the line.separator
   * property at the moment that the stream was created.
   * 换行符、用于newline方法。不同平台具有不同的值。
   */
  private string lineseparator;

  /**
   * 使用默认cb大小创建bufferedwriter bw。
   */
  public bufferedwriter(writer out) {
  	this(out, defaultcharbuffersize);
  }

  /**
   * 使用指定cb大小创建br、初始化相关字段
   */
  public bufferedwriter(writer out, int sz) {
		super(out);
			if (sz <= 0)
			  throw new illegalargumentexception("buffer size <= 0");
			this.out = out;
			cb = new char[sz];
			nchars = sz;
			nextchar = 0;
			//获取不同平台下的换行符表示方式。
			lineseparator =	(string) java.security.accesscontroller.doprivileged(
		        new sun.security.action.getpropertyaction("line.separator"));
  }

  /** 检测底层字符输出流是否关闭*/
  private void ensureopen() throws ioexception {
		if (out == null)
		  throw new ioexception("stream closed");
  }

  /**
   * 将cb中缓存的字符flush到底层out中、但是不flush底层out中的字符。
   * 并且将cb清空。
   */
  void flushbuffer() throws ioexception {
		synchronized (lock) {
		  ensureopen();
		  if (nextchar == 0)
		  	return;
		  out.write(cb, 0, nextchar);
		  nextchar = 0;
		}
  }

  /**
   * 将一个单个字符写入到cb中。
   */
  public void write(int c) throws ioexception {
		synchronized (lock) {
		  ensureopen();
		  if (nextchar >= nchars)
			flushbuffer();
		  cb[nextchar++] = (char) c;
		}
  }

  /**
   * our own little min method, to avoid loading java.lang.math if we've run
   * out of file descriptors and we're trying to print a stack trace.
   */
  private int min(int a, int b) {
	if (a < b) return a;
	return b;
  }

  /**
   * 将一个从下标off开始长度为len个字符写入cb中
   */
  public void write(char cbuf[], int off, int len) throws ioexception {
		synchronized (lock) {
		  ensureopen();
	      if ((off < 0) || (off > cbuf.length) || (len < 0) ||
	        ((off + len) > cbuf.length) || ((off + len) < 0)) {
	        throw new indexoutofboundsexception();
	      } else if (len == 0) {
	        return;
	      } 
	
		  if (len >= nchars) {
				/* 如果len大于cb的长度、那么就直接将cb中现有的字符和cbuf中的字符写入out中、
				 * 而不是写入cb、再写入out中 。
				 */
				flushbuffer();
				out.write(cbuf, off, len);
				return;
		  }
	
		  int b = off, t = off + len;
		  while (b < t) {
				int d = min(nchars - nextchar, t - b);
				system.arraycopy(cbuf, b, cb, nextchar, d);
				b += d;
				nextchar += d;
				if (nextchar >= nchars)
				  flushbuffer();
		  }
		}
  }

  /**
   * 将一个字符串的一部分写入cb中
   */
  public void write(string s, int off, int len) throws ioexception {
	synchronized (lock) {
	  ensureopen();

	  int b = off, t = off + len;
	  while (b < t) {
		int d = min(nchars - nextchar, t - b);
		s.getchars(b, b + d, cb, nextchar);
		b += d;
		nextchar += d;
		if (nextchar >= nchars)
		  flushbuffer();
	  }
	}
  }

  /**
   * 写入一个换行符。
   */
  public void newline() throws ioexception {
  	write(lineseparator);
  }

  /**
   * 刷新此流、同时刷新底层out流
   */
  public void flush() throws ioexception {
		synchronized (lock) {
		  flushbuffer();
		  out.flush();
		}
  }
  /**
   * 关闭此流、释放与此流有关的资源。
   */
  public void close() throws ioexception {
		synchronized (lock) {
		  if (out == null) {
			return;
		  }
		  try {
		    flushbuffer();
		  } finally {
		    out.close();
		    out = null;
		    cb = null;
		  }
		}
  }
}

 4、实例演示：与下面的bufferedreader结合使用实现字符类型的文件的拷贝。

二：bufferedreader

 1、类功能简介：

        缓冲字符输入流、他的功能是为传入的底层字符输入流提供缓冲功能、他会通过底层字符输入流（in）中的字符读取到自己的buffer中（内置缓存字符数组）、然后程序调用bufferedreader的read方法将buffer中的字符读取到程序中、当buffer中的字符被读取完之后、bufferedreader会从in中读取下一个数据块到buffer*程序读取、直到in中数据被读取完毕、这样做的好处一是提高了读取的效率、二是减少了打开存储介质的连接次数、详细的原因下面bufferedwriter有说到。其有个关键的方法fill()就是每当buffer中数据被读取完之后从in中将数据填充到buffer中、程序从内存中读取数据的速度是从磁盘中读取的十倍！这是一个很恐怖的效率的提升、同时我们也不能无禁止的指定bufferedreader的buffer大小、毕竟、一次性读取in中耗时较长、二是内存价格相对昂贵、我们能做的就是尽量在其中找到合理点。一般也不用我们费这个心、创建bufferedreader时使用buffer的默认大小就好。

2、bufferedreader  api简介：

 a：构造方法

  bufferedreader(reader in, int sz)		根据指定大小和底层字符输入流创建bufferedreader。br
  
  bufferedreader(reader in)		使用默认大小创建底层输出流的缓冲流
 

    b：一般方法

  void close()	关闭此流、释放与此流有关的所有资源
  
  void mark(int readaheadlimit)	标记此流此时的位置
  
  boolean marksupported()		判断此流是否支持标记
  
  void reset()	重置in被最后一次mark的位置
  
  boolean ready()		判断此流是否可以读取字符
  
  int read()		读取单个字符、以整数形式返回。如果读到in的结尾则返回-1。
  
  int read(char[] cbuf, int off, int len)	将in中len个字符读取到cbuf从下标off开始长度len中
  
  string readline()	读取一行
  
  long skip(long n)		丢弃in中n个字符

 3、源码分析

package com.chy.io.original.code;

import java.io.ioexception;

/**
 * 为底层字符输入流添加字符缓冲cb数组。提高效率
 * @version 	1.1, 13/11/17
 * @author		andychen
 */

public class bufferedreader extends reader {

  private reader in; 

  private char cb[];
  private int nchars, nextchar;

  private static final int invalidated = -2;
  private static final int unmarked = -1;
  private int markedchar = unmarked;
  private int readaheadlimit = 0; /* valid only when markedchar > 0 */

  /** if the next character is a line feed, skip it */
  private boolean skiplf = false;

  /** the skiplf flag when the mark was set */
  private boolean markedskiplf = false;

  private static int defaultcharbuffersize = 8192;
  private static int defaultexpectedlinelength = 80;

  /**
   * 根据指定大小和底层字符输入流创建bufferedreader。br
   */
  public bufferedreader(reader in, int sz) {
		super(in);
		if (sz <= 0)
		  throw new illegalargumentexception("buffer size <= 0");
		this.in = in;
		cb = new char[sz];
		nextchar = nchars = 0;
  }

  /**
   * 使用默认大小创建底层输出流的缓冲流
   */
  public bufferedreader(reader in) {
  	this(in, defaultcharbuffersize);
  }

  /** 检测底层字符输入流in是否关闭 */
  private void ensureopen() throws ioexception {
		if (in == null)
		  throw new ioexception("stream closed");
  }

  /**
   * 填充cb。
   */
  private void fill() throws ioexception {
		int dst;
		if (markedchar <= unmarked) {
		  /* no mark */
		  dst = 0;
		} else {
		  /* marked */
		  int delta = nextchar - markedchar;
		  if (delta >= readaheadlimit) {
			/* gone past read-ahead limit: invalidate mark */
			markedchar = invalidated;
			readaheadlimit = 0;
			dst = 0;
		  } else {
			if (readaheadlimit <= cb.length) {
			  /* shuffle in the current buffer */
			  system.arraycopy(cb, markedchar, cb, 0, delta);
			  markedchar = 0;
			  dst = delta;
			} else {
			  /* reallocate buffer to accommodate read-ahead limit */
			  char ncb[] = new char[readaheadlimit];
			  system.arraycopy(cb, markedchar, ncb, 0, delta);
			  cb = ncb;
			  markedchar = 0;
			  dst = delta;
			}
	        nextchar = nchars = delta;
		  }
		}
	
		int n;
		do {
		  n = in.read(cb, dst, cb.length - dst);
		} while (n == 0);
		if (n > 0) {
		  nchars = dst + n;
		  nextchar = dst;
		}
  }

  /**
   * 读取单个字符、以整数形式返回。如果读到in的结尾则返回-1。
   */
  public int read() throws ioexception {
		synchronized (lock) {
		  ensureopen();
		  for (;;) {
			if (nextchar >= nchars) {
			  fill();
			  if (nextchar >= nchars)
				return -1;
			}
			if (skiplf) {
			  skiplf = false;
			  if (cb[nextchar] == '\n') {
				nextchar++;
				continue;
			  }
			}
			return cb[nextchar++];
		  }
		}
  }

  /**
   * 将in中len个字符读取到cbuf从下标off开始长度len中
   */
  private int read1(char[] cbuf, int off, int len) throws ioexception {
		if (nextchar >= nchars) {
		  /* if the requested length is at least as large as the buffer, and
		    if there is no mark/reset activity, and if line feeds are not
		    being skipped, do not bother to copy the characters into the
		    local buffer. in this way buffered streams will cascade
		    harmlessly. */
		  if (len >= cb.length && markedchar <= unmarked && !skiplf) {
			return in.read(cbuf, off, len);
		  }
		  fill();
		}
		if (nextchar >= nchars) return -1;
		if (skiplf) {
		  skiplf = false;
		  if (cb[nextchar] == '\n') {
			nextchar++;
			if (nextchar >= nchars)
			  fill();
			if (nextchar >= nchars)
			  return -1;
		  }
		}
		int n = math.min(len, nchars - nextchar);
		system.arraycopy(cb, nextchar, cbuf, off, n);
		nextchar += n;
		return n;
  }

  /**
   * 将in中len个字符读取到cbuf从下标off开始长度len中
   */
  public int read(char cbuf[], int off, int len) throws ioexception {
    synchronized (lock) {
	  ensureopen();
      if ((off < 0) || (off > cbuf.length) || (len < 0) ||
        ((off + len) > cbuf.length) || ((off + len) < 0)) {
        throw new indexoutofboundsexception();
      } else if (len == 0) {
        return 0;
      }

	  int n = read1(cbuf, off, len);
	  if (n <= 0) return n;
	  while ((n < len) && in.ready()) {
		int n1 = read1(cbuf, off + n, len - n);
		if (n1 <= 0) break;
		n += n1;
	  }
	  return n;
	}
  }

  /**
   * 从in中读取一行、是否忽略换行符
   */
  string readline(boolean ignorelf) throws ioexception {
		stringbuffer s = null;
		int startchar;
	
    synchronized (lock) {
      ensureopen();
	  boolean omitlf = ignorelf || skiplf;
		bufferloop:
		for (;;) {
	
			if (nextchar >= nchars)
			  fill();
			if (nextchar >= nchars) { /* eof */
			  if (s != null && s.length() > 0)
				return s.tostring();
			  else
				return null;
			}
			boolean eol = false;
			char c = 0;
			int i;
	
	        /* skip a leftover '\n', if necessary */
			if (omitlf && (cb[nextchar] == '\n')) 
	          nextchar++;
			skiplf = false;
			omitlf = false;
	
		  charloop:
			for (i = nextchar; i < nchars; i++) {
			  c = cb[i];
			  if ((c == '\n') || (c == '\r')) {
				eol = true;
				break charloop;
			  }
			}
	
			startchar = nextchar;
			nextchar = i;
	
			if (eol) {
			  string str;
			  if (s == null) {
				str = new string(cb, startchar, i - startchar);
			  } else {
				s.append(cb, startchar, i - startchar);
				str = s.tostring();
			  }
			  nextchar++;
			  if (c == '\r') {
				skiplf = true;
			  }
			  return str;
			}
			
			if (s == null) 
			  s = new stringbuffer(defaultexpectedlinelength);
			s.append(cb, startchar, i - startchar);
		  }
    }
  }

  /**
   * 从in中读取一行、
   */
  public string readline() throws ioexception {
    return readline(false);
  }

  /**
   * 丢弃in中n个字符
   */
  public long skip(long n) throws ioexception {
		if (n < 0l) {
		  throw new illegalargumentexception("skip value is negative");
		}
		synchronized (lock) {
		  ensureopen();
		  long r = n;
		  while (r > 0) {
			if (nextchar >= nchars)
			  fill();
			if (nextchar >= nchars)	/* eof */
			  break;
			if (skiplf) {
			  skiplf = false;
			  if (cb[nextchar] == '\n') {
				nextchar++;
			  }
			}
			long d = nchars - nextchar;
			if (r <= d) {
			  nextchar += r;
			  r = 0;
			  break;
			}
			else {
			  r -= d;
			  nextchar = nchars;
			}
		  }
		  return n - r;
		}
  }

  /**
   * 判断cb中是否为空、或者底层in中是否有可读字符。
   */
  public boolean ready() throws ioexception {
		synchronized (lock) {
		  ensureopen();
	
		  /* 
		   * if newline needs to be skipped and the next char to be read
		   * is a newline character, then just skip it right away.
		   */
		  if (skiplf) {
			/* note that in.ready() will return true if and only if the next 
			 * read on the stream will not block.
			 */
			if (nextchar >= nchars && in.ready()) {
			  fill();
			}
			if (nextchar < nchars) {
			  if (cb[nextchar] == '\n') 
				nextchar++;
			  skiplf = false;
			} 
		  }
		  return (nextchar < nchars) || in.ready();
		}
  }

  /**
   * 判断此流是否支持标记
   */
  public boolean marksupported() {
  	return true;
  }

  /**
   * 标记此流此时的位置、当调用reset方法失效前最多允许读取readaheadlimit个字符。
   */
  public void mark(int readaheadlimit) throws ioexception {
		if (readaheadlimit < 0) {
		  throw new illegalargumentexception("read-ahead limit < 0");
		}
		synchronized (lock) {
		  ensureopen();
		  this.readaheadlimit = readaheadlimit;
		  markedchar = nextchar;
		  markedskiplf = skiplf;
		}
  }

  /**
   * 重置in被最后一次mark的位置。即下一个字符从被最后一次mark的位置开始读取。
   */
  public void reset() throws ioexception {
		synchronized (lock) {
		  ensureopen();
		  if (markedchar < 0)
			throw new ioexception((markedchar == invalidated)
					   ? "mark invalid"
					   : "stream not marked");
		  nextchar = markedchar;
		  skiplf = markedskiplf;
		}
  }

  //关闭此流、释放与此流有关的所有资源
  public void close() throws ioexception {
		synchronized (lock) {
		  if (in == null)
			return;
		  in.close();
		  in = null;
		  cb = null;
		}
  }
}

4、实例演示：

package com.chy.io.original.test;

import java.io.bufferedreader;
import java.io.bufferedwriter;
import java.io.file;
import java.io.filereader;
import java.io.filewriter;
import java.io.ioexception;

public class bufferedwriterandbufferedreadertest {
	/**
	 * 这里对这两个类的测试比较简单、就是对文件字符流进行包装、实现文件拷贝
	 * 有兴趣的可以测试一下效率、、偷个懒、、可无视
	 */
	public static void main(string[] args) throws ioexception{
		file resoucefile = new file("d:\\test.txt");
		file targetfile = new file("e:\\copyoftest.txt");
		
		bufferedreader br = new bufferedreader(new filereader(resoucefile));
		bufferedwriter bw = new bufferedwriter(new filewriter(targetfile));
		
		char[] cbuf = new char[1024];
		int n = 0;
		while((n = br.read(cbuf)) != -1){
			bw.write(cbuf, 0, n);
		}
		//不要忘记刷新和关闭流、否则一方面资源没有及时释放、另一方面有可能照成数据丢失
		br.close();
		bw.flush();
		bw.close();
	}
}

总结：

        对于bufferedreader、bufferedwriter、本质就是为底层字符输入输出流添加缓冲功能、先将底层流中的要读取或者要写入的数据先以一次读取一组的形式来讲数据读取或者写入到buffer中、再对buffer进行操作、这样不但效率、还能节省资源。最后、在程序中、出于效率的考虑、也应为低级流使用这两个类进行装饰一下、而不是直接拿着流直接上、觉得能实现就行。