Java InputStream 拼接

SequenceInputStream 是 Java 中的一个输入流类，用于将多个输入流 按顺序串联 为一个流。它可以将多个 InputStream 对象依次连接在一起，仿佛它们是一个连续的流。通常用于需要将多个文件、字节流等合并为一个流的场景。

1. SequenceInputStream 的基本功能

SequenceInputStream 的作用是依次读取多个流。读取第一个流中的数据，当第一个流读取完毕后，自动切换到下一个流继续读取，直到所有流的数据都读取完毕。

2. SequenceInputStream 的构造方法

SequenceInputStream 提供了两个构造方法，用于接受不同类型的输入源：

1. SequenceInputStream(InputStream s1, InputStream s2) 接受两个 InputStream 对象作为参数，将这两个流串联起来。

   InputStream s1 = new FileInputStream("file1.txt");
   InputStream s2 = new FileInputStream("file2.txt");
   SequenceInputStream sis = new SequenceInputStream(s1, s2);

2. SequenceInputStream(Enumeration<? extends InputStream> e) 接受一个 Enumeration 对象，该对象包含多个 InputStream，使得可以将多个流（不止两个）串联起来。

   Vector<InputStream> streams = new Vector<>();
   streams.add(new FileInputStream("file1.txt"));
   streams.add(new FileInputStream("file2.txt"));
   streams.add(new FileInputStream("file3.txt"));
   Enumeration<InputStream> e = streams.elements();
   SequenceInputStream sis = new SequenceInputStream(e);

3. SequenceInputStream 的使用示例

以下是一个简单的示例，演示如何将两个文件的内容合并到一起并输出。

import java.io.FileInputStream;
import java.io.SequenceInputStream;
import java.io.IOException;
 
public class SequenceInputStreamExample {
    public static void main(String[] args) {
        try (
            FileInputStream fis1 = new FileInputStream("file1.txt");
            FileInputStream fis2 = new FileInputStream("file2.txt");
            SequenceInputStream sis = new SequenceInputStream(fis1, fis2)
        ) {
            int data;
            while ((data = sis.read()) != -1) {
                System.out.print((char) data);
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

假设 file1.txt 内容为：

Hello, this is file 1.

file2.txt 内容为：

And this is file 2.

运行程序后，输出结果将是：

Hello, this is file 1.And this is file 2.

4. 使用多个输入流

如果需要合并多个输入流，可以使用 Vector 或其他集合来存储流，再使用 SequenceInputStream 的第二个构造方法。

import java.io.*;
import java.util.*;
 
public class MultiFileSequenceExample {
    public static void main(String[] args) {
        try {
            // 创建多个文件输入流
            FileInputStream fis1 = new FileInputStream("file1.txt");
            FileInputStream fis2 = new FileInputStream("file2.txt");
            FileInputStream fis3 = new FileInputStream("file3.txt");
 
            // 将流添加到 Vector
            Vector<InputStream> streams = new Vector<>();
            streams.add(fis1);
            streams.add(fis2);
            streams.add(fis3);
 
            // 创建 Enumeration 对象
            Enumeration<InputStream> e = streams.elements();
 
            // 创建 SequenceInputStream
            SequenceInputStream sis = new SequenceInputStream(e);
 
            int data;
            while ((data = sis.read()) != -1) {
                System.out.print((char) data);
            }
 
            // 关闭 SequenceInputStream（会自动关闭内部的 InputStream）
            sis.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

5. SequenceInputStream 注意事项

• 自动关闭流：SequenceInputStream 会在关闭时自动关闭所有包含的流，不需要手动关闭各个流。
• 读取顺序：按流在集合中的顺序读取数据，确保流之间的顺序无误。
• 适用场景：适用于合并多个文件的读取，或将多个数据源统一为一个输入流读取。

SequenceInputStream 简化了多个流的处理工作，使得代码更加清晰，在需要连续读取多个数据源的场景中非常有用。