Il modo più efficiente per convertire InputStream in byte []?

Question

ChannelBufferInputStream responseStream = (ChannelBufferInputStream) response.getBodyAsStream(); 
ArrayList<Byte> arrayList = new ArrayList<Byte>(); 
try { 
    while (responseStream.available() > 0) { 
     arrayList.add(responseStream.readByte()); 
    } 
} catch (IOException e) { 
    e.printStackTrace(); 
    return internalServerError(); 
} 
Iterator<Byte> iterator = arrayList.iterator(); 
byte[] bytes = new byte[arrayList.size()]; 
int i = 0; 
while (iterator.hasNext()) { 
    bytes[i++] = iterator.next(); 
} 

Questo codice viene richiamato in ogni pagina della mia app Web. Sembra che funzioni abbastanza velocemente, ma c'è qualcosa che potrebbe rendere questa corsa più veloce?

Edit - Aggiornata con flusso di uscita di byte

ChannelBufferInputStream responseStream = (ChannelBufferInputStream) response.getBodyAsStream(); 
ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream(); 
try { 
    int read = responseStream.read(); 
    while (read != -1) { 
     byteArrayOutputStream.write(read); 
     read = responseStream.read(); 
    } 
} catch (IOException e) { 
    e.printStackTrace(); 
    return internalServerError(); 
} 
byte[] bytes = byteArrayOutputStream.toByteArray(); 
return ok(bytes).as(response.getHeader("Content-type")); 

Modifica - codice di prova di riferimento

ChannelBufferInputStream responseStream = (ChannelBufferInputStream) response.getBodyAsStream(); 
long t1 = System.nanoTime(); 

ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream(); 
try { 
    int read = responseStream.read(); 
    while (read != -1) { 
     byteArrayOutputStream.write(read); 
     read = responseStream.read(); 
    } 
} catch (IOException e) { 
    e.printStackTrace(); 
    return internalServerError(); 
} 
byte[] bytes = byteArrayOutputStream.toByteArray(); 

long t2 = System.nanoTime(); 
System.out.println(t2-t1); 
return ok(bytes).as(response.getHeader("Content-type")); 

Tempo medio di 100 + dopo richiesta - 46873

ChannelBufferInputStream responseStream = (ChannelBufferInputStream) response.getBodyAsStream(); 
long t1 = System.nanoTime(); 

ArrayList<Byte> arrayList = new ArrayList<Byte>(); 
try { 
    while (responseStream.available() > 0) { 
     arrayList.add(responseStream.readByte()); 
    } 
} catch (IOException e) { 
    e.printStackTrace(); 
    return internalServerError(); 
} 
Iterator<Byte> iterator = arrayList.iterator(); 
byte[] bytes = new byte[arrayList.size()]; 
int i = 0; 
while (iterator.hasNext()) { 
    bytes[i++] = iterator.next(); 
} 

long t2 = System.nanoTime(); 
System.out.println(t2-t1); 
return ok(bytes).as(response.getHeader("Content-type")); 

Tempo medio dopo 100 + richiesta - 522848

long t1 = System.nanoTime(); 
byte[] bytes; 
try { 
    bytes = org.apache.commons.io.IOUtils.toByteArray(responseStream); 
} catch (Exception e) { 
    return internalServerError(); 
} 

long t2 = System.nanoTime(); 
System.out.println(t2-t1); 

Tempo medio di 100 + dopo richiesta - 45088

long t1 = System.nanoTime(); 
byte[] bytes; 
try { 
    bytes = sun.misc.IOUtils.readFully(responseStream, -1, true); 
} catch (Exception e) { 
    return internalServerError(); 
} 

long t2 = System.nanoTime(); 
System.out.println(t2 - t1); 

Tempo medio di 100 + dopo richiesta - 20180

Answer 1

Sì. Utilizzare uno ByteArrayOutputStream anziché un ArrayList. Quindi leggi i blocchi di byte da InputStream (senza utilizzare available(), che non dovrebbe quasi mai essere utilizzato) e scrivi questi blocchi su ByteArrayOutputStream, finché il metodo read() restituisce -1. Quindi chiama aByteArray() sul tuo ByteArrayOutputStream.

È possibile utilizzare il metodo ByteStreams.toByteArray() di Guava, che fa tutto ciò che è per te, o si può leggere il suo codice sorgente per avere un'idea migliore di come lo fa. La lettura del IO tutorial potrebbe anche aiutare.

Answer 2

Perché? Questo codice è interamente equivalente a read(byte[]) con la differenza che esegue due passaggi di copia aggiuntivi sull'intero dato. Non hai bisogno di questo. Un semplice read(byte[]) sarebbe più volte più veloce.

L'uso di available() non è valido. Hai bisogno dell'intera risposta, non solo della parte che può essere letta senza bloccare. Hai bisogno di loop.

Answer 3

Cosa c'è che non va nel metodo Apache Commons IO IOUtils.toByteArray? Questo è stato ottimizzato per molti anni per questo scopo.