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并将它们导入到您的类路径中。