jnetrobust

Schnelles, zuverlässiges und nicht aufdringliches nachrichtenorientiertes virtuelles Netzwerkprotokoll für Java 6+.
Derzeit in der Alpha-Phase.

Was ist das?

JNetRobust ist ein virtuelles Netzwerkprotokoll, das zwischen der Transport- und der Anwendungsschicht angesiedelt ist.

Vorteile

• Zuverlässigkeit der übertragenen Daten
  Bekämpft Netzwerkmerkmale wie Lieferung außerhalb der Reihenfolge, Paketverlust und Paketduplizierung
• empfangene, nicht validierte Daten stehen sofort zur Verfügung
  Dies unterscheidet sich von TCP, da TCP Ihnen die Daten erst dann zur Verfügung stellt, nachdem es die Lieferung in der richtigen Reihenfolge garantieren kann
• Das Paket ist größer als das Paket von UDP, aber kleiner als das Paket von TCP
• vermeidet einige Fallstricke bei der gemeinsamen Verwendung von UDP und TCP
  Gleichzeitiger UDP- und TCP-Verkehr kann zu erhöhtem Paketverlust führen

Vorbehalte

• keine Flusskontrolle
• derzeit keine Staukontrolle
  Zukünftige Versionen könnten diese Funktion enthalten

Warum sollte ich es verwenden?

Wenn Sie keine Zuverlässigkeit benötigen, verwenden Sie UDP.
Wenn Sie Zuverlässigkeit benötigen und auf die Validierung warten können, verwenden Sie TCP.
Wenn Sie Zuverlässigkeit benötigen, aber vom Empfang nicht validierter Daten ohne Latenz profitieren, probieren Sie JNetRobust aus.

Wie verwende ich es?

Es handelt sich um eine Bibliothek und es gibt keine Einschränkungen hinsichtlich der Art und Weise, wie Sie sie verwenden:

• Das Protokoll behält einen internen Status bei, der jedes Mal aktualisiert wird, wenn Sie es verwenden
• Das Protokoll fügt lediglich Metadaten zu Ihren Originaldaten hinzu bzw. entfernt diese
• Sie entscheiden, was mit den in Metadaten verpackten Daten geschehen soll (z. B. einige Ihrer eigenen Metadaten hinzufügen usw.).
• Sie entscheiden, wie Sie die in Metadaten verpackten Daten serialisieren möchten (z. B. mit Standardserialisierung, Kryo usw.)
• Sie entscheiden, wie Sie die in Metadaten verpackten Daten senden möchten (z. B. einfaches DatagramSocket, neueres NIO DatagramChannel oder sogar Netzwerk-Frameworks wie Apache MINA).

Sie können die Referenzimplementierung verwenden, die all diese Teile zusammenfügt, um loszulegen; Ein Beispiel ist unten aufgeführt.

Weitere Informationen finden Sie auf den Wiki-Seiten!

Reden ist billig. Zeig mir den Code. [1]

Hier ist ein minimales, vollständiges Beispiel für die Verwendung der bereitgestellten Referenzimplementierung:
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 );
        }
    }
}

Konsolenausgabe

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

Wo kann ich die Binärdateien, Quellen und Javadoc herunterladen?

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 >

Manuelle Einrichtung
Sie können die jar -Dateien aus dem Release-Bereich herunterladen und in Ihren Klassenpfad importieren.

Wo kann ich das Javadoc durchsuchen?

Sie können die Dokumente auf der IO-Seite von JNetRobusts lesen.

Sonstiges

Offene Issues und/oder offene Pull Requests . Vorschläge, Fehlerberichte, Codeverbesserungen und zusätzliche Funktionen sind herzlich willkommen!

Copyright (c) 2014 mucaho.
MPL 2.0. Lesen Sie die kurze Erklärung. Ich möchte dazu ermutigen, über Pull-Requests zu diesem ursprünglichen Repository beizutragen, wenn Sie Änderungen vorgenommen haben.