jnetrobustダウンロード - jnetrobustソースコードのダウンロード

jnetrobust

その他のカテゴリー

1.0.0

ダウンロード

Java 6 以降向けの高速で信頼性が高く、非侵入的なメッセージ指向の仮想ネットワークプロトコル。
現在はアルファ版です。

それは何ですか？

JNetRobust は、トランスポート層とアプリケーション層の間に存在する仮想ネットワークプロトコルです。

利点

送信データの信頼性
順序通りでない配送、荷物の紛失、荷物の重複などのネットワーク特性に対抗します
受信した未検証のデータはすぐに利用可能です
これは TCP とは異なります。TCP は、順序どおりの配信を保証できた後でのみデータを提供します。
パッケージは UDP のパッケージより大きいですが、TCP のパッケージよりは小さいです
UDP と TCP を併用する場合のいくつかの落とし穴を回避します
UDP と TCP トラフィックの同時発生により、パケット損失が増加する可能性があります

注意事項

フロー制御なし
現在、輻輳制御はありません
将来のリリースにはこの機能が含まれる可能性があります

なぜそれを使用する必要があるのですか?

信頼性が必要ない場合は、UDP を使用してください。
信頼性が必要で、検証されるまで待つことができる場合は、TCP を使用してください。
信頼性は必要だが、遅延なしで未検証のデータを受信できる利点がある場合は、JNetRobust を試してください。

どうやって使用すればいいですか？

これはライブラリなので、使用方法に制限はありません。

プロトコルは内部状態を維持し、使用するたびに更新されます
このプロトコルは、元のデータにメタデータを追加したり、元のデータからメタデータを削除したりするだけです
メタデータでパッケージ化されたデータをどうするかはあなたが決定します (例: 独自のメタデータを追加するなど)。
メタデータでパッケージ化されたデータをどのようにシリアル化するかを決定します (デフォルトのシリアル化、Kryo など)。
メタデータがパッケージ化されたデータを送信する方法を決定します (例: プレーン DatagramSocket、新しい NIO DatagramChannel、または Apache MINA などのネットワークフレームワーク)

これらすべての部分を結合するリファレンス実装を使用して開始できます。例を以下に示します。

追加情報については、Wiki ページを参照してください。

話は安っぽい。コードを見せてください。 [1]

以下は、提供されたリファレンス実装を使用する最小限の完全な例です。
コード

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

コンソール出力

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

バイナリ、ソース、Javadoc はどこでダウンロードできますか?

メイビン

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

手動セットアップ
リリースセクションからjarをダウンロードし、クラスパスにインポートできます。