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並將它們匯入到您的類別路徑中。