I/O复习 二 （过滤字节流 FileteInputStream/FilterOutputStream）

 java.io包中提供了FilterInputStream和FilterOutputStream类分别对其他输入输出流进行特殊的处理，它们在
  * 读/写数据的同时还能够对数据进行特殊的处理。另外它们还提供了同步机制，是的某一时刻之后一个线程可以访问输入/输出流。
  * FilterInputStream/FilterOutputStream都是抽象类。
  * FilterInputStream有三个子类：BufferedInputStream、DataInputStream、PushbackInputStream
  * FilterOutputStream也有三个子类：BufferedOutputStream、DataOutoutStream、PrintStream
  *
  * 使用过滤字节流的时候，必须先制定节点流对象处理底层的数据，然后把节点流对象作为过滤流对象的实参使用。即把过滤流对象连接到某个输入/输出节点流对象上如下：
  * FileInputStream fis = new FileInputStream(new File("c:/abc.txt"));
  * DataInputSream dis = new DataInputStream(fis);

一、BufferedInputStream/BufferedOutputStream

  * BufferedInputStream/BufferedOutputStream 是缓冲字节流，它引入了针对内存缓冲区的操作，从而提高了读写数据的效率。
  * 缓冲区的默认大小为32字节，也可以指定缓冲区的大小。
  * 相应的构造的方法
  * BufferedInputStream(InputStream in) 这里的in只要是继承自InputSream的对象都可以作为参数
  * BufferedInputStream(InputStream in,int size)
  * BufferedOutputStream与上面的对应。

Demo:使用BufferedInputStream/BufferdeOutputStream完成文件的复制。

package com.tai.io;

import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;

public class BufferedInputStreamDemo
{
    /**
     * java.io包中提供了FilterInputStream和FilterOutputStream类分别对其他输入输出流进行特殊的处理，它们在
     * 读/写数据的同时还能够对数据进行特殊的处理。另外它们还提供了同步机制，是的某一时刻之后一个线程可以访问输入/输出流。
     * FilterInputStream/FilterOutputStream都是抽象类。
     * FilterInputStream有三个子类：BufferedInputStream、DataInputStream、PushbackInputStream
     * FilterOutputStream也有三个子类：BufferedOutputStream、DataOutoutStream、PrintStream
     * 
     * 使用过滤字节流的时候，必须先制定节点流对象处理底层的数据，然后把节点流对象作为过滤流对象的实参使用。即把过滤流对象连接到某个输入/输出节点流对象上
     * 
     * FileInputStream fis = new FileInputStream(new File("c:/abc.txt"));
     * DataInputSream dis = new DataInputStream(fis);
     * BufferedInputStream/BufferedOutputStream 是缓冲字节流，它引入了针对内存缓冲区的操作，从而提高了读写数据的效率。
     * 缓冲区的默认大小为32字节，也可以指定缓冲区的大小。
     * 相应的构造的方法
     * BufferedInputStream(InputStream in) 这里的in只要是继承自InputSream的对象都可以作为参数
     * BufferedInputStream(InputStream in,int size)
     * BufferedOutputStream与上面的对应。
     */
    public static void main(String[] args) throws IOException
    {
        FileInputStream fis = new FileInputStream(new File("c:/曲婉婷 - 没有什么不同 [mqms].mp3"));
        BufferedInputStream bis = new BufferedInputStream(fis,1024);
        FileOutputStream fos = new FileOutputStream(new File("c:/没有什么不同.mp3"));
        BufferedOutputStream bos = new BufferedOutputStream(fos,1024);
        
        byte[] buffer = new byte[1024];
        int len =0;
        while(-1!=(len=bis.read(buffer,0,1024)))
        {
            //将buffer中从fis读取来的数据写入到bos中
            bos.write(buffer,0,len);
        }
        bos.flush();//最近一次读取的数据可能达不到1024字节，这里强制清空缓冲区
        System.out.println("已经将c:/曲婉婷 - 没有什么不同 [mqms].mp3复制到c:/没有什么不同.mp3");
        bos.close();
        fos.close();
    }
}

运行结果：

已经将c:/曲婉婷 - 没有什么不同 [mqms].mp3复制到c:/没有什么不同.mp3

二、DataInputStream和DataOutputStream

 * java.io包中还有连个接口DataInput和DataOutput,这两个接口设计了较高级的数据输入输出方式，除了可以处理字节个字节数组外
  * 还可以处理  int、float、boolean等基本的数据类型，这些数据在文件中的表示方式和它们在内存中的方式一样，无序转换，它们相应的提供了
  * 很多处理基本数据类型的方法，如：DataInput提供了read()、readInt()、readByte()等DataOutput提供了write()、writeInt()、
  * writeFloat()、writeChar()等 ....
  *
  * 而数据流类 DataInputStream和DataOutputStream分别实现了DataInput和DataOutput接口。它们以统一的方式向输入流中写入boolean、int、long
  * double等基本的数据类型，并且还可以把基本的数据类型取出来，同时它们也有针对字符串的读写方法

Demo:

package com.tai.io;

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.util.Scanner;

public class DataInputStreamDemo
{
    /**
     * java.io包中还有连个接口DataInput和DataOutput,这两个接口设计了较高级的数据输入输出方式，除了可以处理字节个字节数组外
     * 还可以处理  int、float、boolean等基本的数据类型，这些数据在文件中的表示方式和它们在内存中的方式一样，无序转换，它们相应的提供了
     * 很多处理基本数据类型的方法，如：DataInput提供了read()、readInt()、readByte()等DataOutput提供了write()、writeInt()、
     * writeFloat()、writeChar()等 ....
     * 
     * 而数据流类 DataInputStream和DataOutputStream分别实现了DataInput和DataOutput接口。它们以统一的方式向输入流中写入boolean、int、long
     * double等基本的数据类型，并且还可以把基本的数据类型取出来，同时它们也有针对字符串的读写方法
     * @throws IOException 
     */
    public static void main(String[] args) throws IOException
    {
        FileOutputStream fos = new FileOutputStream(new File("C:/abc/a.txt"));
        DataOutputStream dos = new DataOutputStream(fos);
        Scanner scan = new Scanner(System.in);
        System.out.println("请输入数据： ");
        
        dos.writeBoolean(scan.nextBoolean());
        dos.writeByte(scan.nextInt());
        dos.writeFloat(scan.nextFloat());
        dos.writeShort(scan.nextInt());
        dos.writeChar('A');
        dos.close();
        
        FileInputStream fis = new FileInputStream(new File("C:/abc/a.txt"));
        DataInputStream dis = new DataInputStream(fis);
        System.out.println("读取Boolean数据 	" + dis.readBoolean());
        System.out.println("读取Byte数据 	" + dis.readByte());
        System.out.println("读取Float数据 	" + dis.readFloat());
        System.out.println("读取Short数据 	" + dis.readShort());
        System.out.println("读取Char数据 	" + dis.readChar());
        dis.close();
        
    }
}

运行结果：
　　

请输入数据： 
true
65
63.25
56
读取Boolean数据     true
读取Byte数据     65
读取Float数据     63.25
读取Short数据     56
读取Char数据     A

三、管道字节流

 * 管道用来把程序、线程或程序块的输出连接到另一个程序、线程或者程序块作为它的输入。
 * java.io提供了类PipedInputSteramh和PipedOutputStream 作为管道的输入/输出流。
 * 管道输入流作为一个通信管道接收端，管道输出流作为发送端。管道流必须是输入流输出流同时并用，即在使用管道前，两者必须进行连接。
 * 无论PipedInputStream还是PipdeOutputStream类都提供了connect()方法可以使用connect()方法建立一个管道进行数据传输。
 * 管道输入/输出流可以用两种方式进行连接，一种方式是使用connect()方法：
 *   PipedInputStream pis  = new PipedInputStream();
 *  PipedOutputStream pos = new PipedOutputStream();
 *  pis.connect(pos);
 *  pos.connect(pis);
 *  另外一种是直接使用构造方法进行连接：
 *  PipedInputStream pis = new PipedInputStream();
 *  PipedOutputStream pos = new PipedOutputStream(pis);
 *   
 *  除了connect()方法PipedInputStream类还继承了InputStream类的read()方法。另外又增加了receive()方法
 *  PipedOutputStream类也继承自OutputStream类的write()方法。

Demo1：

package com.tai.io;

import java.io.IOException;
import java.io.PipedInputStream;
import java.io.PipedOutputStream;

public class PipedStreamDemo
{
/**
 * 管道字节流
 * 管道用来把程序、线程或程序块的输出连接到另一个程序、线程或者程序块作为它的输入。
 * java.io提供了类PipedInputSteramh和PipedOutputStream 作为管道的输入/输出流。
 * 管道输入流作为一个通信管道接收端，管道输出流作为发送端。管道流必须是输入流输出流同时并用，即在使用管道前，两者必须进行连接。
 * 无论PipedInputStream还是PipdeOutputStream类都提供了connect()方法可以使用connect()方法建立一个管道进行数据传输。
 * 管道输入/输出流可以用两种方式进行连接，一种方式是使用connect()方法：
 *         PipedInputStream pis  = new PipedInputStream();
 *        PipedOutputStream pos = new PipedOutputStream();
 *        pis.connect(pos);
 *        pos.connect(pis);
 *        另外一种是直接使用构造方法进行连接：
 *        PipedInputStream pis = new PipedInputStream();
 *        PipedOutputStream pos = new PipedOutputStream(pis);
 *         
 *     除了connect()方法PipedInputStream类还继承了InputStream类的read()方法。另外又增加了receive()方法
 *     PipedOutputStream类也继承自OutputStream类的write()方法。    
 * @throws IOException 
 */
    
    public static void main(String[] args) throws IOException
    {
        int ch1 = 0;
        PipedInputStream pis = new PipedInputStream();
        PipedOutputStream pos = new PipedOutputStream(pis);
        //也可以使用connect()方法
         //    PipedOutputStream pos = new PipedOutputStream();
         //        pos.connect(pis);
        System.out.println("请输入一个字符，按#结束程序！");
        while((ch1 = System.in.read())!='#')
        {
            pos.write(ch1);
            System.out.println((char)pis.read());
        }
    }
}

运行结果：

请输入一个字符，按#结束程序！
A
A

A
A

c
c

#

PipedInputStream 和PipedOutStream常与线程连用，已达到在不同线程间的通讯：

Demo2:

package com.tai.io;

import java.io.IOException;
import java.io.PipedInputStream;
import java.io.PipedOutputStream;

public class PipedStreamDemo2
{
    public static void main(String[] args) throws IOException
    {
        PipedInputStream pis = new PipedInputStream();
        //实例管道输出流并与上面的管道输入流连接
        PipedOutputStream pos = new PipedOutputStream(pis);
        
        new Thread(new InputThread(pis)).start();
        new Thread(new OutputThread(pos)).start();
    }
}

class InputThread implements Runnable
{

    private PipedInputStream pis;
    public InputThread(PipedInputStream in)
    {
        this.pis = in;
    }
    
    @Override
    public void run()
    {
        byte[] buffer = new byte[1024];
        int len = 0;
        try
        {
            len = pis.read(buffer);
            
            String str = new String(buffer,0,len);
            
            System.out.println("管道输入流作为接收端，接受来自管道输出流发送的内容。  内容是：    "+ str);
            pis.close();
        }
        catch (IOException e)
        {
            e.printStackTrace();
        }
        
    }
}

class OutputThread implements Runnable
{
    private PipedOutputStream pos;
    public OutputThread (PipedOutputStream out)
    {
        this.pos = out;
    }
    @Override
    public void run()
    {
        try
        {
            pos.write("管道输出流作为发送端向管道输入流发送内容".getBytes());
            pos.close();
        }
        catch (IOException e)
        {
            e.printStackTrace();
        }
    }
    
}

运行结果：

管道输入流作为接收端，接受来自管道输出流发送的内容。  内容是：    管道输出流作为发送端向管道输入流发送内容