Análisis StAX del canal Java NIO

Question

Estoy intentando recibir una secuencia de eventos XML sobre un canal Java NIO. Soy nuevo en el análisis de NIO y StAX, así que fácilmente podría estar pasando por alto algo :)

Mi búsqueda me ha llevado a varias implementaciones de SAX y StAX, pero todas parecen operar en InputStreams y InputSources, no en NIO canales Los dos intentos más cercanos que he hecho han sido para obtener el InputStream desde el canal y crear una PipedInputStream:

// method 1 
PipedOutputStream out = new PipedOutputStream(); 
InputStream in = new PipedInputStream(out); 
PrintWriter writer = new PrintWriter(out); 

//method 2 
InputStream in = channel.socket().getInputStream() 
//method 3 
IputStream in = Channels.newInputStream(channel); 

seguido de:

XMLStreamReader xmlStreamReader = XMLInputFactory.newInstance() 
     .createXMLStreamReader(in); 
//... 

Cuando el código anterior se utiliza con el método 1, bloquea en la línea createXMLStreamReader. Cuando se usan los métodos 2/3, inmediatamente lanzan IllegalBlockingModeException (entiendo por qué). Tal vez se necesita un nuevo enfoque?

Mi objetivo es tener un servidor sin bloqueo select => aceptar datos de caracteres de un cliente => analizarlos con eventos XML utilizando una codificación específica => reenviar ese objeto de evento a otro hilo para procesar => y volver a la selección.

Así que estoy pasando por alto algo, o hay un mejor enfoque que se puede utilizar? ¿Entonces qué?

Gracias!

Answer 1

¿Estás seguro de que necesitas utilizar NIO? No podrá ofrecer los beneficios relativos esperados originalmente:

Paul TYMA: Kill the myth please. NIO is not faster than IO

Paul Tyma: Writing Java Multithreaded Servers - whats old is new

Una pila que muestra dónde el interior createXMLStreamReader() que está bloqueando podría ayudar, pero probablemente se está comportando como se ha diseñado . Si fue diseñado para trabajar en contra de InputStreams que siempre (1) dan la cantidad esperada de datos; (2) final; o (3) bloquear, entonces no se comportará automáticamente de una manera (usualmente más complicada y con mayor estado) que puede regresar después de leer cualquier cantidad de entrada incompleta, sin muchas reelaboraciones profundas.

Answer 2

Debe utilizar la clase de utilidad java.nio.channels.Channels.

ReadableByteChannel ch = //... 
InputStream in = Channels.newInputStream(ch); 

Es posible que necesite configurar el canal de socket que va a bloquear.

SelectableChannel ch = //... 
ch.configureBlocking(true); 

Esto significa que no podrá realizar E/S sin bloqueo.

Answer 3

También comencé a buscar, también para el uso del servidor XMPP. He estado buscando y parece que solo hay una implementación que promete el soporte de NIO: Aalto http://wiki.fasterxml.com/AaltoHome

Pero parece haberse lanzado a la versión 0.9.5, marzo de 2009. Así que, no estoy seguro de qué tan bien mantenido es, pero este podría ser un buen punto de partida. A menos que puedas convencer a un proyecto más grande (tal vez Woodstox), para que rehaga algunas de sus clases internas para soporte de NIO.