jnetrobust

Protocolo de red virtual orientado a mensajes rápido, confiable y no intrusivo para Java 6+.
Actualmente en alfa.

¿Qué es?

JNetRobust es un protocolo de red virtual que reside entre la capa de transporte y la de aplicación.

Beneficios

• confiabilidad de los datos transmitidos
  contrarresta características de la red como entrega fuera de orden, pérdida de paquetes, duplicación de paquetes
• recibidos, los datos no validados están disponibles inmediatamente
  esto es diferente de TCP, ya que TCP le proporciona los datos solo después de que pueda garantizar la entrega en orden
• el paquete es más grande que el paquete de UDP, pero más pequeño que el paquete de TCP
• evita algunos problemas al usar UDP y TCP juntos
  El tráfico UDP y TCP simultáneo puede provocar una mayor pérdida de paquetes

Advertencias

• sin control de flujo
• actualmente no hay control de congestión
  Las versiones futuras pueden incluir esta característica.

¿Por qué debería usarlo?

Si no necesita confiabilidad, use UDP.
Si necesita confiabilidad y puede esperar a que se valide, use TCP.
Si necesita confiabilidad, pero se beneficia al recibir datos no validados sin latencia, pruebe JNetRobust.

¿Cómo lo uso?

Es una biblioteca y no impone restricciones sobre cómo usarla:

• el protocolo mantiene un estado interno, que se actualiza cada vez que lo utilizas
• el protocolo simplemente agrega/elimina metadatos a/de sus datos originales
• usted decide qué hacer con los datos empaquetados con metadatos (por ejemplo, agregar algunos de sus propios metadatos, etc.)
• usted decide cómo desea serializar los datos empaquetados con metadatos (por ejemplo, con serialización predeterminada, Kryo, etc.)
• usted decide cómo desea enviar los datos empaquetados con metadatos (por ejemplo, DatagramSocket simple, NIO DatagramChannel más nuevo o incluso marcos de red como Apache MINA)

Puede utilizar la implementación de referencia que une todas esas piezas para comenzar; a continuación se enumera un ejemplo.

¡Consulte las páginas Wiki para obtener información adicional!

Hablar es barato. Muéstrame el código. [1]

A continuación se muestra un ejemplo mínimo y completo del uso de la implementación de referencia proporcionada:
Código

 public class BidirectionalMain {
    public static void main ( String [] args ) throws Exception {
        String receivedMessage ;

        // host addresses
        InetSocketAddress ADDRESS_A = new InetSocketAddress ( InetAddress . getLocalHost (), 12345 );
        InetSocketAddress ADDRESS_B = new InetSocketAddress ( InetAddress . getLocalHost (), 12346 );

        // setup ProtocolHosts using the host's local address and registering all serialization dataTypes
        // ProtocolHost supports multiplexing between different peers using respective topicId, remote address and dataType

        ProtocolHost protocolHostA = new ProtocolHost ( "A" , ADDRESS_A , String . class );
        ProtocolHandle < String > protocolHandleA = protocolHostA . register ( Byte . MIN_VALUE , ADDRESS_B );

        ProtocolHost protocolHostB = new ProtocolHost ( "B" , ADDRESS_B , String . class );
        ProtocolHandle < String > protocolHandleB = protocolHostB . register ( Byte . MIN_VALUE , ADDRESS_A );


        // send from A
        protocolHandleA . send ( Arrays . asList ( "Hi!" , "How you doing?" ));

        System . out . println ();
        Thread . sleep ( 100 );

        // receive at B
        while (( receivedMessage = protocolHandleB . receive ()) != null ) {
            System . out . println ( "<B> t " + receivedMessage );
        }

        // send from B
        protocolHandleB . send ( "Howdy! Fine, thanks." );

        System . out . println ();
        Thread . sleep ( 100 );

        // receive at A
        while (( receivedMessage = protocolHandleA . receive ()) != null ) {
            System . out . println ( "<A> t " + receivedMessage );
        }
    }
}

Salida de consola

 [A]: Data sent                      -32767    Hi!
[A]: Data sent                      -32766    How you doing?

[B]: Data received ordered          -32767    Hi!
[B]: Data received                  -32767    Hi!
[B]: Data received ordered          -32766    How you doing?
[B]: Data received                  -32766    How you doing?
[B]: Newest data received           -32766    How you doing?
<B> Hi!
<B> How you doing?
[B]: Data sent                      -32767    Howdy! Fine, thanks.

[A]: Data was received at other end -32767    Hi!
[A]: Data was received at other end -32766    How you doing?
[A]: Data received ordered          -32767    Howdy! Fine, thanks.
[A]: Data received                  -32767    Howdy! Fine, thanks.
[A]: Newest data received           -32767    Howdy! Fine, thanks.
<A> Howdy! Fine, thanks.

¿Dónde puedo descargar los binarios, fuentes y javadoc?

experto

 <!-- JNetRobust library; mandatory -->
< dependency >
    < groupId >com.github.mucaho</ groupId >
    < artifactId >jnetrobust-core</ artifactId >
    < version >0.0.2</ version >
</ dependency >

 <!-- JNetRobust examples; optional -->
< dependency >
    < groupId >com.github.mucaho</ groupId >
    < artifactId >jnetrobust-samples</ artifactId >
    < version >0.0.2</ version >
</ dependency >

Configuración manual
Puede descargar los jar desde la sección de lanzamiento e importarlos a su classpath.

¿Dónde puedo navegar por el javadoc?

Puede leer los documentos en la página IO de JNetRobusts.

Varios

Problemas abiertos y/o solicitudes de extracción abiertas . ¡Las sugerencias, informes de errores, mejoras de código y características adicionales son bienvenidas!

Copyright (c) 2014 mucaho.
MPL 2.0. Leer breve explicación. Me gustaría alentar la contribución a este repositorio original a través de solicitudes de extracción, si realizó alguna modificación.