На этой странице: http://blog.ostermiller.org/convert-java-outputstream-inputstream описывается, как создать InputStream из OutputStream:
new ByteArrayInputStream(out.toByteArray())
Другие альтернативы - использование PipedStreams и новых потоков, что является громоздким.
Мне не нравится идея копирования большого количества мегабайт в новый массив байтов в памяти. Есть ли библиотека, которая делает это более эффективно?
РЕДАКТИРОВАТЬ:
По совету Лоуренса Гонсалвеса я попробовал PipedStreams, и оказалось, что с ними не так уж сложно справиться. Вот пример кода в clojure:
(defn #^PipedInputStream create-pdf-stream [pdf-info]
(let [in-stream (new PipedInputStream)
out-stream (PipedOutputStream. in-stream)]
(.start (Thread. #(;Here you write into out-stream)))
in-stream))
источник
new Thread
по какой-либо причине не подходит для вашего контейнера, посмотрите, есть ли пул потоков, который вы можете использовать.Существует еще одна библиотека с открытым исходным кодом, называемая EasyStream, которая прозрачно работает с конвейерами и потоками. Это не сложно, если все идет хорошо. Проблемы возникают, когда (глядя на пример Лоуренса Гонсалвеса)
Выдает исключение. В этом примере поток просто завершается, и исключение теряется, а внешний поток
InputStream
может быть усечен.Easystream занимается распространением исключений и другими неприятными проблемами, которые я отлаживал около года. (Я являюсь хранителем библиотеки: очевидно, мое решение - лучшее;)) Вот пример того, как его использовать:
final InputStreamFromOutputStream<String> isos = new InputStreamFromOutputStream<String>(){ @Override public String produce(final OutputStream dataSink) throws Exception { /* * call your application function who produces the data here * WARNING: we're in another thread here, so this method shouldn't * write any class field or make assumptions on the state of the outer class. */ return produceMydata(dataSink) } };
Также есть хорошее введение, в котором объясняются все другие способы преобразования OutputStream в InputStream. Стоит взглянуть.
источник
Простое решение, позволяющее избежать копирования буфера, - создать специальный
ByteArrayOutputStream
:public class CopyStream extends ByteArrayOutputStream { public CopyStream(int size) { super(size); } /** * Get an input stream based on the contents of this output stream. * Do not use the output stream after calling this method. * @return an {@link InputStream} */ public InputStream toInputStream() { return new ByteArrayInputStream(this.buf, 0, this.count); } }
При необходимости запишите в указанный выше выходной поток, затем вызовите,
toInputStream
чтобы получить входной поток через базовый буфер. Считайте выходной поток закрытым после этого момента.источник
Я думаю, что лучший способ подключить InputStream к OutputStream - через конвейерные потоки, доступные в пакете java.io, как показано ниже :
// 1- Define stream buffer private static final int PIPE_BUFFER = 2048; // 2 -Create PipedInputStream with the buffer public PipedInputStream inPipe = new PipedInputStream(PIPE_BUFFER); // 3 -Create PipedOutputStream and bound it to the PipedInputStream object public PipedOutputStream outPipe = new PipedOutputStream(inPipe); // 4- PipedOutputStream is an OutputStream, So you can write data to it // in any way suitable to your data. for example: while (Condition) { outPipe.write(mByte); } /*Congratulations:D. Step 4 will write data to the PipedOutputStream which is bound to the PipedInputStream so after filling the buffer this data is available in the inPipe Object. Start reading it to clear the buffer to be filled again by the PipedInputStream object.*/
На мой взгляд, у этого кода есть два основных преимущества:
1 - Дополнительного потребления памяти кроме буфера нет.
2 - Вам не нужно обрабатывать очередь данных вручную
источник
Обычно я стараюсь избегать создания отдельного потока из-за увеличения вероятности тупиковой ситуации, увеличения сложности понимания кода и проблем с обработкой исключений.
Вот предлагаемое мной решение: ProducerInputStream, который создает контент фрагментами путем повторных обращений к producerChunk ():
public abstract class ProducerInputStream extends InputStream { private ByteArrayInputStream bin = new ByteArrayInputStream(new byte[0]); private ByteArrayOutputStream bout = new ByteArrayOutputStream(); @Override public int read() throws IOException { int result = bin.read(); while ((result == -1) && newChunk()) { result = bin.read(); } return result; } @Override public int read(byte[] b, int off, int len) throws IOException { int result = bin.read(b, off, len); while ((result == -1) && newChunk()) { result = bin.read(b, off, len); } return result; } private boolean newChunk() { bout.reset(); produceChunk(bout); bin = new ByteArrayInputStream(bout.toByteArray()); return (bout.size() > 0); } public abstract void produceChunk(OutputStream out); }
источник