IO(三)----序列流

时间:2023-03-09 05:41:22
IO(三)----序列流

SequenceInputStream 表示其他输入流的逻辑串联。它从输入流的有序集合开始,并从第一个输入流开始读取,直到到达文件末尾,接着从第二个输入流读取,依次类推,直到到达包含的最后一个输入流的文件末尾为止。

常用方法:

1、构造方法

SequenceInputStream(InputStream s1, InputStream s2) 通过记住这两个参数来初始化新创建的 SequenceInputStream(将按顺序读取这两个参数,先读取 s1,然后读取 s2),以提供从此 SequenceInputStream 读取的字节。

SequenceInputStream(Enumeration<? extends InputStream> e) 通过记住参数来初始化新创建的 SequenceInputStream,该参数必须是生成运行时类型为 InputStream 对象的 Enumeration 型参数。

2、读取方法

int read(byte[] b, int off, int len) 将最多 len 个数据字节从此输入流读入 byte 数组。

int read()  从此输入流中读取下一个数据字节。

3、关闭资源

void close() 关闭此输入流并释放与此流关联的所有系统资源。

常用操作就是合并读取

示例代码:

 // 需求: 把一首mp3先切割成n份,然后再把这些文件合并起来。
public class DemoSequenceInputStream { public static void main(String[] args) throws IOException {
// split();
merage();
} //分隔
public static void split() throws IOException{
File inFile = new File("D:\\西单女孩-原点 (3D武侠动画《画江湖之不良人》主题曲).mp3");
FileInputStream fileInputStream = new FileInputStream(inFile);
byte[] buf = new byte[1024*1024];
int length = 0;
for(int i = 0; (length = fileInputStream.read(buf)) != -1;i++){
File outFile = new File("D:\\SplitMusic\\","part"+i+".mp3");
FileOutputStream fileOutputStream = new FileOutputStream(outFile);
fileOutputStream.write(buf, 0, length);
fileOutputStream.close();
}
fileInputStream.close();
} //合并
public static void merage() throws IOException{
File dir = new File("D:\\SplitMusic");
File[] files = dir.listFiles();
//对数据进行排序
Arrays.sort(files);
Vector<FileInputStream> vector = new Vector<>();
for (File file : files) {
if (file.getName().endsWith(".mp3")) {
FileInputStream fileInputStream = new FileInputStream(file);
vector.add(fileInputStream);
}
}
Enumeration<FileInputStream> enumeration = vector.elements();
SequenceInputStream sequenceInputStream = new SequenceInputStream(enumeration);
FileOutputStream fileOutputStream = new FileOutputStream("D:\\合并.mp3");
int length = 0;
byte[] buf= new byte[1024*1024];
while((length = sequenceInputStream.read(buf)) != -1){
fileOutputStream.write(buf, 0, length);
}
fileOutputStream.close();
sequenceInputStream.close();
}
}