java 过滤流

[java]代码库

import java.io.*;

/*
 * FilterStream.java
 *
 * Created on 2006年8月23日, 上午9:40
 *
 * 过滤流
 *
 * 过滤流在读/写数据的同时可以对数据进行处理，并提供了同步机制，
 * 这样在同一时刻只有一个线程可以访问一个I/O流。在java.io包中，
 * FilterInputStream和FilterOutputStream类是所有过滤输入流和
 * 输出流的父类，它们是抽象类，本身不能生成任何实例，在这两上类
 * 之下，分别实现了几物特殊的过滤输入流和输出流，利用这些特殊输
 * 入流和输出流的实例可以进行流处理。
 *
 * 下面介绍几个过滤输入流和输出流的子类：
 *
 * BufferedInputStream 和 BufferedOutputStream
 * 这两个类实现了带缓冲的过滤流，将任意的输入流和输出流绑定到缓
 * 冲流上就会提高性能。
 * 对于BufferedInputStream类，当系统读取数据时，数据按块读入缓
 * 冲区，随后读操作直接访问缓冲区。使用BufferedOutputStream进行
 * 输出时，数据首先写入缓冲区，当缓冲区满时，缓冲区中的数据写入
 * 连接的输出流，BufferedOutputStream类提供的方法flush()可以强
 * 制将缓冲区的内容全部写入输出流。
 *
 * DataInputStream 和 DataOutputStream
 * 这两个类不仅能读写数据流，而且能读写各种各样的Java语言本身固
 * 有的数据类型，如int、float等。
 *
 * PushbackInputStream
 * PushbackInputStream类提供了方法将刚读过的字节退回到输入流中，
 * 后面的内容就可以用到该字节。
 */
public class FilterStream {
	public static void main(String[] args) {
		try {
			FileInputStream inStream;
			FileOutputStream outStream;
			BufferedInputStream bufInObj;
			BufferedOutputStream bufOutObj;
			DataInputStream dataInObj;
			PushbackInputStream pushObj;
			byte[] tempBuf = new byte[1024];
			int copyLen;
			inStream = new FileInputStream("d:\\mydir\\secondFile.txt");
			outStream = new FileOutputStream("d:\\mydir\\thirdFile.txt");
			bufInObj = new BufferedInputStream(inStream);
			bufOutObj = new BufferedOutputStream(outStream);
			dataInObj = new DataInputStream(inStream);
			System.out.println(dataInObj.readBoolean());
			while ((copyLen = bufInObj.read(tempBuf, 0, 1024)) != -1) {
				String copyStr = new String(tempBuf);
				System.out.println(copyStr);
				bufOutObj.write(tempBuf, 0, copyLen);
				bufOutObj.flush();
			}
			int pushData;
			byte[] pushByte = { 'o', 'k' };
			pushObj = new PushbackInputStream(new FileInputStream(
					"d:\\mydir\\thirdFile.txt"), 1000);
			while ((pushData = pushObj.read()) != -1) {
				if (Character.isLetter((char) pushData)) {
					System.out.print((char) pushData);
				} else {
					System.out.println();
					pushObj.unread(pushByte);
				}
			}
		} catch (FileNotFoundException e) {
			System.out.println("File not found or persission denied.");
		} catch (IOException e) {
			System.out.println("error:" + e);
		}
	}
	/*
	 * 在上面的程序中，我们首先声明了FileInputStream类对象inStream和
	 * FileOutputStream类的对象outStream，接着声明了BufferInputStream
	 * 类对象bufObj、BufferedOutputStream类对象bufOutObj、
	 * DataInputStream类对象dataInObj以及PushbackInputStream类对象pushObj，
	 * 在try代码块中对上面这些对象进行初始化，程序的目的是通过BufferedInputStream
	 * 类对象bufInObj和BufferedOutputStream类对象bufOutObj将secondFile.txt
	 * 文件中内容输出到屏幕，并将该文件的内容写入thirdFile.txt文件中，值得注意的是，
	 * 将secondFile.txt文件中的内容输出之前，程序中使用
	 * "System.out.println(dataInObj.readBoolean());" 语句根据readBoolean()结果
	 * 输出了true，而secondFile.txt文件开始内容为“Modify”，和一个字符为M，
	 * 因此输出的文件内容没有“M”字符，thirdFile.txt文件中也比secondFile.txt
	 * 文件少第一个字符“M”。随后，通过PushbackInputStream类对象pushObj读取
	 * thirdFile.txt文件中的内容，输出读到的字符，当读到的不是字符，输出回车，将字符
	 * 数组pushByte写回到thirdFile.txt文件中，也就是“ok”写回文件中。
	 */

}