1

我正在使用 SequenceInputStream 将多个流合并为一个流。我在JDK8上。以下是代码。

private InputStream mergeInputStreams(final Map<String, InputStream> fileAssets, final JSONObject json) throws Exception {

    final List<InputStream> listStreams = new ArrayList<InputStream>();

    listStreams.add(stringToStream(HEADER));
    addToList(json, listStreams);

    listStreams.add(stringToStream(HEADER_2));
    addToList(fileAssets.get(FILE_2), listStreams, true);

    listStreams.add(stringToStream(HEADER_3));
    addToList(fileAssets.get(FILE_3), listStreams, false);

    return new SequenceInputStream(Collections.enumeration(listStreams));
}

private void addToList(final InputStream inputStream, List<InputStream> listStreams, final boolean delimiter) throws Exception {
    final byte[] input = byteArrayFromStream(inputStream);
    listStreams.add(intToStream(input.length));
    listStreams.add(new ByteArrayInputStream(input));
    if (delimiter) {
        listStreams.add(stringToStream("\n"));
    }
}

private void addToList(final JSONObject json, final List<InputStream> listStreams) throws Exception {
    final String jsonString = json.toString();
    listStreams.add(intToStream(jsonString.length()));
    listStreams.add(stringToStream(jsonString));
}

我遇到的问题是，我总是从 SequenceInputStream 对象获取第一个流，即我只获取 HEADER 字符串。我尝试了几种选择，包括

new SequenceInputStream(listStreams.get(9), listStreams.get(9));

在上面的示例中，我尝试将相同的输入合并两次。但是，我仍然只得到第 9 个输入流一次。

我已经验证我确实在枚举中得到了多个流。

如果有人可以帮助我了解这里发生了什么，那就太好了。

4

2 回答 2

2

它将读取第一个流直到流结束，然后是第二个，依此类推。可能这不是你所期待的？这也意味着您不能两次提供相同的流，因为它在第一次使用时已经被完全读取。

我看不出构造函数与它有什么关系。

于 2015-04-28T08:30:09.093 回答
0

这是我们所拥有的：

  1. 从“n”个流创建一个序列输入流对象“s”
  2. 使用外部库将“s”上传到 S3。lib.uploadToS3(s)

问题： 第三方库 uploadToS3(stream) 调用正在使用 stream.available() 来初始化缓冲区数组，它正在从流中填充并上传。

看起来 SequenceInputStream.available() （http://grepcode.com/file/repository.grepcode.com/java/root/jdk/openjdk/6-b14/java/io/SequenceInputStream.java）从当前流其迭代。例如，在 lib.uploadToS3() 的上下文中，它使用的是序列中第一个流中的 available()。

我们修复了什么： 我们修复了库以使用 IOUtils.copy() 而不是编写依赖于 available() 的复制代码。

于 2015-04-29T20:01:09.213 回答