Подключение входного потока к OutputStream

Question

обновление в java9: https://docs.oracle.com/javase/9/docs/api/java/io/InputStream.html#transferTo-java.io.OutputStream-

Я видел несколько подобных, но не совсем то, что-я-потребность темы.

У меня есть сервер, который будет в основном принимать входные данные от клиента, клиент A, и пересылать его, байты за байт, другой клиент, клиент B.

Я хотел бы подключить InputStream от клиента A с моим выходным потоком клиента B. Возможно ли это? Каковы способы сделать это?

Кроме того, эти клиенты отправляют друг другу сообщения, которые в некоторой степени чувствительны к времени, поэтому буферизация не будет выполняться. Я не хочу, чтобы буфер говорил 500, а клиент отправляет 499 байт, а затем мой сервер держится при пересылке 500 байтов, потому что он не получил последний байт, чтобы заполнить буфер.

Прямо сейчас, я разбираю каждое сообщение, чтобы найти его длину, а затем считывать длины байтов, а затем пересылать их. Я решил (и испытал), что это будет лучше, чем чтение байта и пересылка байта снова и снова, потому что это будет очень медленно. Я также не хотел использовать буфер или таймер по той причине, о которой я говорил в своем последнем абзаце, - я не хочу, чтобы сообщения ожидали очень долгое время, чтобы пройти через просто потому, что буфер не заполнен.

Каков хороший способ сделать это?

Answer 1

Просто потому, что вы используете буфер, это не означает, что поток должен заполнить этот буфер. Другими словами, это должно быть в порядке:

public static void copyStream(InputStream input, OutputStream output) 
    throws IOException 
{ 
    byte[] buffer = new byte[1024]; // Adjust if you want 
    int bytesRead; 
    while ((bytesRead = input.read(buffer)) != -1) 
    { 
     output.write(buffer, 0, bytesRead); 
    } 
} 

Это должно работать нормально - в основном read вызов будет блокировать до тех пор, пока это некоторые данные доступны, но он не будет ждать, пока это не все доступны для заполнения буфер. (Я предполагаю, что мог, и я считаю, FileInputStream обычно будет заполнить буфер, но поток присоединен к розетке, скорее всего, чтобы дать вам данные сразу.)

Я думаю, что стоит по крайней мере попробовать это простое решение первый.

Answer 2

Вы можете использовать циклический буфер:

код

// buffer all data in a circular buffer of infinite size 
CircularByteBuffer cbb = new CircularByteBuffer(CircularByteBuffer.INFINITE_SIZE); 
class1.putDataOnOutputStream(cbb.getOutputStream()); 
class2.processDataFromInputStream(cbb.getInputStream()); 

Maven зависимостей

<dependency> 
    <groupId>org.ostermiller</groupId> 
    <artifactId>utils</artifactId> 
    <version>1.07.00</version> 
</dependency> 

Mod подробнее е

http://ostermiller.org/utils/CircularBuffer.html

Answer 3

Как насчет использования

void feedInputToOutput(InputStream in, OutputStream out) { 
    IOUtils.copy(in, out); 
} 

и быть сделано с ним?

от библиотеки jacarta apache commons i/o, которая используется огромным количеством проектов, так что вы, вероятно, уже имеете банку в своем классе.

Answer 4

Асинхронный способ его достижения.

void inputStreamToOutputStream(final InputStream inputStream, final OutputStream out) { 
    Thread t = new Thread(new Runnable() { 

     public void run() { 
      try { 
       int d; 
       while ((d = inputStream.read()) != -1) { 
        out.write(d); 
       } 
      } catch (IOException ex) { 
       //TODO make a callback on exception. 
      } 
     } 
    }); 
    t.setDaemon(true); 
    t.start(); 
} 

Answer 5

В случае, если вы в функционал это функция, написанная на Scala, показывающий, как можно скопировать входной поток в выходной поток, используя только Vals (и не вары).

def copyInputToOutputFunctional(inputStream: InputStream, outputStream: OutputStream,bufferSize: Int) { 
    val buffer = new Array[Byte](bufferSize); 
    def recurse() { 
    val len = inputStream.read(buffer); 
    if (len > 0) { 
     outputStream.write(buffer.take(len)); 
     recurse(); 
    } 
    } 
    recurse(); 
} 

Обратите внимание, что это не рекомендуется использовать в приложениях Java с небольшим количеством доступных памятью, потому что с рекурсивной функцией вы можете легко получить ошибку исключения переполнения стека

Answer 6

Для полноты guava также имеет handy utility для этого

ByteStreams.copy(input, output); 

Answer 7

buffer_size является размером патронов для чтения в. Должно быть> 1kb и < 10MB.

private static final int BUFFER_SIZE = 2 * 1024 * 1024; 
private void copy(InputStream input, OutputStream output) throws IOException { 
    try { 
     byte[] buffer = new byte[BUFFER_SIZE]; 
     int bytesRead = input.read(buffer); 
     while (bytesRead != -1) { 
      output.write(buffer, 0, bytesRead); 
      bytesRead = input.read(buffer); 
     } 
    //If needed, close streams. 
    } finally { 
     input.close(); 
     output.close(); 
    } 
} 

Answer 8

Это версия Scala, что не является чистым и быстро (не StackOverflow):

import scala.annotation.tailrec 
    import java.io._ 

    implicit class InputStreamOps(in: InputStream) { 
    def >(out: OutputStream): Unit = pipeTo(out) 

    def pipeTo(out: OutputStream, bufferSize: Int = 1<<10): Unit = pipeTo(out, Array.ofDim[Byte](bufferSize)) 

    @tailrec final def pipeTo(out: OutputStream, buffer: Array[Byte]): Unit = in.read(buffer) match { 
     case n if n > 0 => 
     out.write(buffer, 0, n) 
     pipeTo(out, buffer) 
     case _ => 
     in.close() 
     out.close() 
    } 
    } 

Это позволяет использовать > символ, например, inputstream > outputstream, а также передавать пользовательские буферы/размеры.

Answer 9

JDK 9 добавил InputStream#transferTo(OutputStream out) для этой функции.

Answer 10

Использование org.apache.commons.io.IOUtils

InputStream inStream = new ... 
OutputStream outStream = new ... 
IOUtils.copy(inStream, outStream); 

или copyLarge для размера> 2GB