jnetrobust

Protocolo de rede virtual orientado a mensagens rápido, confiável e não intrusivo para Java 6+.
Atualmente em alfa.

O que é?

JNetRobust é um protocolo de rede virtual que reside entre as camadas de transporte e de aplicação.

Benefícios

• confiabilidade dos dados transmitidos
  conta características de rede como entrega fora de ordem, perda de pacote, duplicação de pacote
• recebidos, dados não validados ficam disponíveis imediatamente
  isso é diferente do TCP, pois o TCP fornece os dados somente depois de garantir a entrega no pedido
• o pacote é maior que o pacote do UDP, mas menor que o pacote do TCP
• evita algumas armadilhas de usar UDP e TCP juntos
  tráfego UDP e TCP simultâneo pode levar ao aumento da perda de pacotes

Advertências

• sem controle de fluxo
• atualmente não há controle de congestionamento
  versões futuras podem incluir esse recurso

Por que devo usá-lo?

Se você não precisa de confiabilidade, use UDP.
Se você precisa de confiabilidade e pode esperar a validação, use TCP.
Se você precisa de confiabilidade, mas se beneficia do recebimento de dados não validados e sem latência, experimente o JNetRobust.

Como faço para usá-lo?

É uma biblioteca e não impõe restrições sobre como você a utiliza:

• o protocolo mantém um estado interno, que é atualizado toda vez que você o utiliza
• o protocolo apenas adiciona/remove metadados de/para seus dados originais
• você decide o que fazer com os dados empacotados com metadados (por exemplo, adicionar alguns de seus próprios metadados, etc...)
• você decide como deseja serializar os dados empacotados com metadados (por exemplo, com serialização padrão, Kryo, etc...)
• você decide como deseja enviar os dados empacotados com metadados (por exemplo, DatagramSocket simples, NIO DatagramChannel mais recente ou até mesmo estruturas de rede como Apache MINA)

Você pode usar a implementação de referência que une todas essas peças para começar; um exemplo está listado abaixo.

Consulte as páginas Wiki para obter informações adicionais!

Falar é barato. Mostre-me o código. [1]

Aqui está um exemplo mínimo e completo de uso da implementação de referência fornecida:
Código

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

Saída do console

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

Onde posso baixar os binários, fontes e javadoc?

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 >

Configuração manual
Você pode baixar os jar da seção de lançamento e importá-los para o seu caminho de classe.

Onde posso navegar no javadoc?

Você pode ler a documentação na página IO do JNetRobusts.

Diversos

Problemas abertos e/ou solicitações pull abertas . Sugestões, relatórios de bugs, melhorias de código e recursos adicionais são muito bem-vindos!

Copyright (c) 2014 mucaho.
MPL 2.0. Leia uma breve explicação. Gostaria de encorajar a contribuição para este repositório original por meio de solicitações pull, caso você tenha feito alguma modificação.