SequenceInputStream (序列流) :
可以把多個輸入流串聯(lián)起來讀取,先從第一個開始i讀取寞秃,然后再下一個....
序列流是沒有讀取文件的能力斟叼。
需求:把day01 與 day02的文件合并成一個. -----> 總結(jié).txt
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.SequenceInputStream;
import java.util.ArrayList;
import java.util.Enumeration;
import java.util.Iterator;
import java.util.Vector;
public class Demo1 {
public static void main(String[] args) throws IOException {
merge4();
}
public static void merge4() throws IOException{
//找到目標(biāo)文件對象
File inFile1 = new File("F:\\day01.txt");
File inFile2 = new File("f:\\day02.txt");
File inFile3 = new File("f:\\day03.txt");
File outFile = new File("f:\\總結(jié).txt");
//建立數(shù)據(jù)的輸入輸出通道
FileOutputStream fileOutputStream = new FileOutputStream(outFile);
FileInputStream fileInputStream1 = new FileInputStream(inFile1);
FileInputStream fileInputStream2 = new FileInputStream(inFile2);
FileInputStream fileInputStream3 = new FileInputStream(inFile3);
//
ArrayList<FileInputStream> list = new ArrayList<FileInputStream>();
list.add(fileInputStream1);
list.add(fileInputStream2);
list.add(fileInputStream3);
final Iterator<FileInputStream> it = list.iterator();
//創(chuàng)建一個序列流對象
SequenceInputStream inputStream = new SequenceInputStream(new Enumeration<FileInputStream>() {
@Override
public boolean hasMoreElements() {
return it.hasNext();
}
@Override
public FileInputStream nextElement() {
return it.next();
}
});
//創(chuàng)建緩沖數(shù)組,邊讀邊寫
byte[] buf = new byte[1024];
int length = 0;
while((length = inputStream.read(buf))!=-1){
fileOutputStream.write(buf,0,length);
}
//關(guān)閉資源
inputStream.close();
fileOutputStream.close();
}
//把三個文件合并成一個春寿。
public static void merge3() throws IOException{
//找到目標(biāo)文件對象
File inFile1 = new File("F:\\day01.txt");
File inFile2 = new File("f:\\day02.txt");
File inFile3 = new File("f:\\day03.txt");
File outFile = new File("f:\\總結(jié).txt");
//建立數(shù)據(jù)的輸入輸出通道
FileOutputStream fileOutputStream = new FileOutputStream(outFile);
FileInputStream fileInputStream1 = new FileInputStream(inFile1);
FileInputStream fileInputStream2 = new FileInputStream(inFile2);
FileInputStream fileInputStream3 = new FileInputStream(inFile3);
Vector<FileInputStream> v = new Vector<FileInputStream>(); //Vector 是一個線程安全的類谢床,操作效率低识腿。 我想使用ArrayList
v.add(fileInputStream1);
v.add(fileInputStream2);
v.add(fileInputStream3);
Enumeration<FileInputStream> e = v.elements(); //通過Vector得到一個迭代器渡讼。
//創(chuàng)建一個序列流對象
SequenceInputStream inputStream = new SequenceInputStream(e);
//創(chuàng)建緩沖數(shù)組成箫,邊讀邊寫
byte[] buf = new byte[1024];
int length = 0;
while((length = inputStream.read(buf))!=-1){
fileOutputStream.write(buf,0,length);
}
//關(guān)閉資源
inputStream.close();
fileOutputStream.close();
}
//使用SequenceInputStream完成合并文件的需求
public static void merge2() throws IOException{
//找到目標(biāo)文件對象
File inFile1 = new File("F:\\day01.txt");
File inFile2 = new File("f:\\day02.txt");
File outFile = new File("f:\\總結(jié).txt");
//第二步:建立數(shù)據(jù)的輸入輸出通道
FileOutputStream fileOutputStream = new FileOutputStream(outFile);
//建立數(shù)據(jù)的輸入輸出通道
FileInputStream fileInputStream1 = new FileInputStream(inFile1);
FileInputStream fileInputStream2= new FileInputStream(inFile2);
//創(chuàng)建序列流對象
SequenceInputStream sequenceInputStream = new SequenceInputStream(fileInputStream1, fileInputStream2);
//邊讀邊寫
byte[] buf = new byte[1024];
int length = 0 ;
while((length = sequenceInputStream.read(buf))!=-1){
fileOutputStream.write(buf,0,length);
}
//關(guān)閉資源
sequenceInputStream.close();
fileOutputStream.close();
}
//需求: 合并兩個文件到一個文件上。
public static void merge1() throws IOException{
//找到目標(biāo)文件對象
File inFile1 = new File("F:\\day01.txt");
File inFile2 = new File("f:\\day02.txt");
File outFile = new File("f:\\總結(jié).txt");
//輸出流
FileOutputStream fileOutputStream = new FileOutputStream(outFile);
//建立數(shù)據(jù)的輸入輸出通道
FileInputStream fileInputStream1 = new FileInputStream(inFile1);
FileInputStream fileInputStream2= new FileInputStream(inFile2);
//把輸入流對象存儲到集合集合中账胧。
ArrayList<FileInputStream> list = new ArrayList<FileInputStream>();
list.add(fileInputStream1);
list.add(fileInputStream2);
//邊讀邊寫
byte[] buf = new byte[1024];
int length = 0;
for(int i = 0 ; i<list.size() ; i++){
FileInputStream inputStream = list.get(i);
while((length = inputStream.read(buf))!=-1){
fileOutputStream.write(buf,0,length);
}
//關(guān)閉資源
inputStream.close();
}
fileOutputStream.close();
}
}