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와 같은 네트워크 프레임워크)를 보내는 방법을 결정합니다.

시작하기 위해 모든 조각을 하나로 묶는 참조 구현을 사용할 수 있습니다. 예가 아래에 나열되어 있습니다.

추가 정보는 위키 페이지를 참조하세요!

토크는 저렴합니다. 코드를 보여주세요. [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 를 다운로드하여 클래스 경로로 가져올 수 있습니다.