Java Serializable, ObjectInputstream, E/S sin bloqueo

Question

Estoy comenzando con la serialización de Java, y no tengo claro cómo se supone que debe obtener objetos de una fuente en un escenario con I/I sin bloqueo O.

Toda la documentación que puedo encontrar que sugiere el uso de ObjectInputStream es correcta manera de leer en objetos serializados. Sin embargo, como mencioné, estoy usando java.nio y realizando operaciones sin bloqueo. Si readObject() se bloqueará hasta que haya un nuevo objeto disponible, esto no me puede ayudar

Resumen ... ¿Cómo se hace la serialización cuando se trabaja con Java NIO?

Answer 1

Envuelva las instancias serializadas en un protocolo que informe una longitud de carga útil, y la carga útil es la instancia en cuestión. Entonces, una vez que sepa que tiene un segmento que representa una instancia completa, puede usar ObjectInputStream de forma segura sabiendo que no se bloqueará.

Protocolo de la misma familia primeros 32 bits: bits de longitud de carga útil de longitud de carga útil: datos serializados

veces me sorprenden incluso a mí mismo.

Answer 2

Tendrá que implementar (o encontrar una implementación) un InputStream que se lee desde un búfer al que puede anexar desde otro subproceso.

Parece una cosa bastante extraña de intentar hacer. NIO tiene que ver con el alto rendimiento, y la serialización no.

Answer 3

Esto es clásico: ¿cómo puedes .read() si no hay nada que leer? NIO es claramente un rendimiento intensivo, dedicado a lograr io no bloqueante. Intenta hacer nio en Socket.read() - aún obtendrás una operación de bloqueo o se te pasará el tiempo de espera ... ninguna cantidad de fantasía hará que los datos aparezcan en el 'puerto' a menos que generes algunos datos ...

final SecureRandom dataGenerator = SecureRandom.getInstance("SHA1PRNG"); 

final Integer range = new Integer('z' - 'a'); 

for (big loop) 
{ 
    buffer.append(dataGenerator.nextInt (range.intValue() + (int) 'a')); 

// ............ 

do.something(buffer.toString()); 

Ahora sus habilidades de desarrollo se mueven, incluso si están en un paso glacial, pero se mueven.

try { 
    // Create a read/writeable file channel 
    File file = new File("filename"); 
    FileChannel channel = new RandomAccessFile(file, "rw").getChannel(); 

    // Create an output stream on the channel 
    OutputStream os = Channels.newOutputStream(channel); 

    // Create an inputstream on the channel 
    InputStream is = Channels.newInputStream(channel); 

    // Close the channel 
    is.close(); 
} catch (IOException e) { 
} 

mensaje edición: capto su respuesta crítica, espera a sus doce mil líneas en CORBA tratar de implementar readObjectNoData() (útil para inicializar objetos deserializados correctamente a pesar de un flujo fuente "hostil" o incompleto)

Se esperaba que mi código de pseudo único proporcionara algún tipo de flujo de datos para decodificar, recargar o lo que fuera, releí su publicación; Creo que dice cómo leer() no bloquear io en un objeto que puede no estar allí ... que profundiza en los problemas conocidos de Excepción y programación, se pone difícil tratando de trabajar esto con alguien que hace la pregunta de la manera usted lo redactó, intente reformularlo y que otros me expliquen qué es lo que está preguntando.

Voy a ir al puesto de tacos en este momento.