alla ricerca di migliori classi di Netty da utilizzare per lo streaming in memoria tra i thread

Question

Sto cercando una raccomandazione relativa alla migliore classe Netty (es) di utilizzare tale sostegno le seguenti funzionalità:

• in memoria, la comunicazione JVM locale
• basato sul flusso
• supporto più thread scrittura dei dati binari nel flusso
• Single Thread lettura dei dati dal flusso
• è thread-safe sul lato di scrittura
• gestisce automaticamente sottostante crescita byte
• supporta timeout configurabile sul filo di lettura

A prima vista, il ChunkedWriteHandler + sia le classi ChunkedNioStream o ChunkedStream assomigliano l'approccio migliore, ma non so dalla lettura della documentazione se soddisfano tutti i requisiti di cui sopra.

Se chiunque può fornire qualche direzione / raccomandazione, sarebbe molto apprezzato!

Grazie, Bob

UPDATE: Dopo aver scavato un po ', devo essere guardando ChannelBufferInputStream e ChannelBufferOutputStream? Non avendo utilizzato Netty ancora, sto ancora a venire fino a velocità su che cosa vengono utilizzati pezzi dove.

Answer 1

Sono un po 'confuso .. Può darci qualche dettaglio in più circa il caso d'uso? Normalmente non si vuole usare "blocco" operazioni con Netty. Per la comunicazione VM si dovrebbe checkout il pacchetto locale: http://netty.io/docs /stable/api/org/jboss/netty/channel/local/package-frame.html