private static final String Pre_Path = "G:\\項目測試\\io流文件測試\\";

public static void main(String[] args) {
    pipedStreamTest();//進行兩個線程之間的通信
}

//管道--進行兩個線程之間的通信
private static void pipedStreamTest() {
    SendPipedThread sendThread = new SendPipedThread();
    sendThread.start();
    ReceivePipedThread receiveThread = new ReceivePipedThread();
    receiveThread.start();
    try {
        sendThread.outputStream.connect(receiveThread.inputStream);
        Thread.sleep(10000);//10S
        sendThread.stopThread();
        receiveThread.stopThread();
    } catch (Exception e) {
        e.printStackTrace();
    }
}

//管道--每隔500ms，輸出當前時間的字節(jié)數(shù)組
static class SendPipedThread extends Thread {
    PipedOutputStream outputStream = new PipedOutputStream();//輸出流

    @Override
    public void run() {
        try {
            while (outputStream != null) {
                String writeStr = "時間：" + DateUtils.nowDateStr("yyyy-MM-dd hh:mm:ss") + "  ";
                System.out.println("Send線程發(fā)送：" + writeStr);
                outputStream.write(writeStr.getBytes());
                Thread.sleep(500);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    void stopThread() {
        try {
            if (outputStream != null) {
                outputStream.close();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

//管道--獲取連接管道的字節(jié)數(shù)組
static class ReceivePipedThread extends Thread {
    PipedInputStream inputStream = new PipedInputStream();//輸入流

    @Override
    public void run() {
        try {
            while (inputStream != null) {
                byte[] readBytes = new byte[1024];
                int len;
                while ((len = inputStream.read(readBytes)) != -1) {
                    String readStr = new String(readBytes);
                    System.out.println("Receive線程接收：" + readStr);
                }
                Thread.sleep(10);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    void stopThread() {
        try {
            if (inputStream != null) {
                inputStream.close();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

private static final String Pre_Path = "G:\\項目測試\\io流文件測試\\";

public static void main(String[] args) {
    sequenceStreamTest();//將多個文件復制到同一個文件中
}

//將多個文件復制到同一個文件中
private static void sequenceStreamTest() {
    InputStream inputStream = null;//輸入流
    OutputStream outputStream = null;//輸出流
    try {
        outputStream = new FileOutputStream(Pre_Path + "sequenceStream\\輸出文件.txt");//輸出流
        Vector<InputStream> vector = new Vector<>();
        vector.add(new FileInputStream(Pre_Path + "sequenceStream\\a.txt"));
        vector.add(new FileInputStream(Pre_Path + "sequenceStream\\b.txt"));
        vector.add(new FileInputStream(Pre_Path + "sequenceStream\\c.txt"));
        inputStream = new SequenceInputStream(vector.elements());
        //從輸入流讀取0 到 255數(shù)量的字節(jié),并寫入輸出流中
        int readByte;
        while ((readByte = inputStream.read()) != -1) {
            outputStream.write(readByte);
        }
    } catch (Exception e) {
        e.printStackTrace();
    } finally {
        try {
            if (inputStream != null) {
                inputStream.close();//SequenceInputStream的close，會將里面的各個流全部關閉
            }
            if (outputStream != null) {
                outputStream.close();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

private static final String Pre_Path = "G:\\項目測試\\io流文件測試\\";

public static void main(String[] args) {
    bufferedStreamTest();//文件的復制（字節(jié)緩沖流）
}

//文件的復制（字節(jié)緩沖流）
private static void bufferedStreamTest() {
    InputStream inputStream = null;//輸入流
    OutputStream outputStream = null;//輸出流
    try {
        inputStream = new BufferedInputStream(new FileInputStream(Pre_Path + "bufferStream\\test1.txt"));
        outputStream = new BufferedOutputStream(new FileOutputStream(Pre_Path + "bufferStream\\test2.txt"));
        //從輸入流讀取0 到 255數(shù)量的字節(jié),并寫入輸出流中
        byte[] readBytes = new byte[1024];
        int len;
        while ((len = inputStream.read(readBytes)) != -1) {
            System.out.println("讀取到的字符：\n" + new String(readBytes));
            outputStream.write(readBytes, 0, len);
        }
    } catch (Exception e) {
        e.printStackTrace();
    } finally {
        try {
            if (inputStream != null) {
                inputStream.close();
            }
            if (outputStream != null) {
                outputStream.close();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}