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”写回文件中。
     */
 
}
用户注册

用户登录

发表随想

该用户最新代码

编程随想

[java]代码库

网友评论 (发表评论)

发表评论：

评论须知：

扫码下载

输入口令后可复制整站源码
