jnetrobust

Protocole de réseau virtuel orienté message rapide, fiable et non intrusif pour Java 6+.
Actuellement en alpha.

Qu'est-ce que c'est?

JNetRobust est un protocole de réseau virtuel qui réside entre la couche transport et la couche application.

Avantages

• fiabilité des données transmises
  compteur les caractéristiques du réseau telles que la livraison dans le désordre, la perte de colis, la duplication de colis
• reçues, les données non validées sont disponibles immédiatement
  ceci est différent de TCP, car TCP ne vous fournit les données qu'après avoir pu garantir une livraison dans l'ordre
• le package est plus gros que le package UDP, mais plus petit que le package TCP
• évite certains pièges liés à l'utilisation conjointe d'UDP et de TCP
  le trafic UDP et TCP simultané peut entraîner une augmentation de la perte de paquets

Mises en garde

• pas de contrôle de flux
• actuellement aucun contrôle de congestion
  les futures versions pourraient inclure cette fonctionnalité

Pourquoi devrais-je l'utiliser ?

Si vous n'avez pas besoin de fiabilité, utilisez UDP.
Si vous avez besoin de fiabilité et que vous pouvez attendre qu'elle soit validée, utilisez TCP.
Si vous avez besoin de fiabilité, mais que vous bénéficiez de la réception de données non validées sans latence, essayez JNetRobust.

Comment puis-je l'utiliser ?

Il s'agit d'une bibliothèque et n'impose aucune restriction sur la façon dont vous l'utilisez :

• le protocole maintient un état interne, mis à jour à chaque fois que vous l'utilisez
• le protocole ajoute/supprime simplement des métadonnées à/de vos données d'origine
• vous décidez quoi faire avec les données emballées dans les métadonnées (par exemple, ajoutez certaines de vos propres métadonnées, etc...)
• vous décidez comment vous souhaitez sérialiser les données emballées dans les métadonnées (par exemple avec la sérialisation par défaut, Kryo, etc...)
• vous décidez comment vous souhaitez envoyer les données emballées dans les métadonnées (par exemple, DatagramSocket simple, NIO DatagramChannel plus récent ou même des frameworks réseau comme Apache MINA)

Vous pouvez utiliser l'implémentation de référence qui rassemble toutes ces pièces pour commencer ; un exemple est répertorié ci-dessous.

Référez-vous aux pages Wiki pour plus d'informations !

Parler ne coûte pas cher. Montre-moi le code. [1]

Voici un exemple minimal et complet d’utilisation de l’implémentation de référence fournie :
Code

 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 );
        }
    }
}

Sortie console

 [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.

Où puis-je télécharger les binaires, les sources et le javadoc ?

Maven

 <!-- 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 >

Configuration manuelle
Vous pouvez télécharger les jar à partir de la section release et les importer dans votre chemin de classe.

Où puis-je parcourir la javadoc ?

Vous pouvez lire la documentation sur la page IO de JNetRobusts.

Divers

Problèmes ouverts et/ou demandes d’extraction ouvertes . Les suggestions, rapports de bogues, améliorations du code et fonctionnalités supplémentaires sont les bienvenus !

Copyright (c) 2014 mucaho.
MPL2.0. Lisez une brève explication. Je voudrais encourager la contribution à ce référentiel original via des pull request, si vous avez apporté des modifications.