Java序列输入流的一个使用例子

SequenceInputStream

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

下面实现的例子是先读取本地文件流再读取一个网络流，然后输出；先读取一个网络流再读取一个本地文件流，然后再输出。

package com.kkoolerter;

import java.io.File;
import java.io.FileInputStream;
import java.io.InputStream;
import java.io.SequenceInputStream;
import java.net.URL;

public class JDKSequenceInputStream {

public static void main(String[] args) throws Exception {
InputStream is = new FileInputStream(new File("HJ0x000"));
URL url = new URL("http://www.baidu.com");
InputStream dis = url.openStream();

SequenceInputStream sequenceInputStream = new SequenceInputStream(is, dis);

int len = -1;
int len2 = -1;
byte[] buffer = new byte[1024];
byte[] buffer2 = new byte[1024];
StringBuilder sb = new StringBuilder();
StringBuilder sb1 = new StringBuilder();
while((len = sequenceInputStream.read(buffer))!=-1 ){
sb.append(new String(buffer,0,len));

}
System.out.println("-------------------");
System.out.println(sb.toString());
is.close();
dis.close();
sequenceInputStream.close();

InputStream is2 = new FileInputStream(new File("HJ0x000"));
URL url2 = new URL("http://www.baidu.com");
InputStream dis2 = url.openStream();
SequenceInputStream sequenceInputStream2 = new SequenceInputStream(dis2, is2);
System.out.println("+++++++++++++++++++");
while((len2 = sequenceInputStream2.read(buffer2))!=-1){
sb1.append(new String(buffer2,0,len2));
}
System.out.println(sb1.toString());

is2.close();
dis2.close();
sequenceInputStream2.close();
}

}

上面的例子将输出相反的结果。

SequenceInputStream

的内部实现通过java.util.Enumeration和Vector来实现输入流按一定的顺序读取。由于使用到Vector，故SequenceInputStream是线程安全的。还有，SequenceInputStream会自动关闭读取完毕的流，然后继续向前读取直到完成。
本文出自 “有思想的代码” 博客，请务必保留此出处http://wujuxiang.blog.51cto.com/2250829/426948