compresión en java nio buffers directos

Question

La corriente de entrada/salida gzip no funciona en búferes directos de Java.

¿Existe alguna implementación de algoritmo de compresión que opere directamente en búferes directos?

De esta forma no se sobrecargaría la copia de un búfer directo a una matriz de bytes java para la compresión.

Answer 1

no me refiero a restar valor a su pregunta, pero ¿Es este realmente un buen punto de optimización en su programa? ¿Has verificado con un generador de perfiles que tienes un problema? Su pregunta tal como está formulada implica que no ha realizado ninguna investigación, sino que simplemente está adivinando que tendrá un problema de rendimiento o memoria al asignar un byte []. Dado que es probable que todas las respuestas en este hilo sean de algún tipo, realmente debes verificar que tengas un problema en antes de solucionarlo.

Volviendo a la pregunta, si quiere comprimir los datos "en su lugar" en un ByteBuffer, la respuesta es no, no hay capacidad para hacerlo en Java.

Si asigna el búfer como el siguiente:

byte[] bytes = getMyData(); 
ByteBuffer buf = ByteBuffer.wrap(bytes); 

Puede filtrar su byte [] a través de un ByteBufferInputStream como la respuesta anterior sugiere.

Answer 2

Si está utilizando ByteBuffers puede utilizar algunas envolturas simples de entrada/OutputStream como éstas:

public class ByteBufferInputStream extends InputStream { 

    private ByteBuffer buffer = null; 

    public ByteBufferInputStream(ByteBuffer b) { 
     this.buffer = b; 
    } 

    @Override 
    public int read() throws IOException { 
     return (buffer.get() & 0xFF); 
    } 
} 

public class ByteBufferOutputStream extends OutputStream { 

    private ByteBuffer buffer = null; 

    public ByteBufferOutputStream(ByteBuffer b) { 
     this.buffer = b; 
    } 

    @Override 
    public void write(int b) throws IOException { 
     buffer.put((byte)(b & 0xFF)); 
    } 

} 

prueba:

ByteBuffer buffer = ByteBuffer.allocate(1000); 
ByteBufferOutputStream bufferOutput = new ByteBufferOutputStream(buffer); 
GZIPOutputStream output = new GZIPOutputStream(bufferOutput); 
output.write("stackexchange".getBytes()); 
output.close(); 

buffer.position(0); 

byte[] result = new byte[ 1000 ]; 

ByteBufferInputStream bufferInput = new ByteBufferInputStream(buffer); 
GZIPInputStream input = new GZIPInputStream(bufferInput); 
input.read(result); 

System.out.println(new String(result));