mocket

Moquete

 Lightweight, Typesafe, Reliable, Guaranty delivery, Ordered, High performant java nio sockets build 
on top of udp.

Download

• Use jitpack como repositório
• Adicionar mocket às dependências

Conforme mostrado abaixo:

1. Maven

< project >
...
    < repositories >
    ...
        < repository >
            < id >jitpack.io</ id >
            < url >https://jitpack.io</ url >
        </ repository >
    </ repositories >
</ project >

    < dependencies >
        ...
        < dependency >
            < groupId >com.github.Nishant-Pathak</ groupId >
            < artifactId >mocket</ artifactId >
            < version >v1.0</ version >
        </ dependency >
    </ dependencies >

2. Gradle

    allprojects {
        repositories {
            .. .
            maven { url ' https://jitpack.io ' }
        }
    }

    dependencies {
        compile ' com.github.Nishant-Pathak:mocket:v1.0 '
    }

Servidor Simples

Para construir o servidor:

   ServerBuilder < byte []> serverBuilder = new ServerBuilder < byte []>()
        . port ( serverPort );
   Server < byte []> server = serverBuilder . build ();

Para ler:

    while ( true ) {
      // blocking read
      Pair < SocketAddress , byte []> readBytes = server . read ();
    }

Para escrever:

    // write to server
    server . write ( read . getSecond (), read . getFirst ());

Escrever assinatura:

  /**
   * writed data to the given address
   * @param data to send to addredd
   * @param address of the client connected
   * @throws IOException if error occurs while writing to the socket
   * @throws InterruptedException if write is interrupted
   */
  void write ( T data , SocketAddress address ) throws IOException , InterruptedException ;

Cliente Simples

Para construir o cliente:

    ClientBuilder < byte []> builder = new ClientBuilder < byte []>()
        . host ( "127.0.0.1" , 8080 );
    Client < byte []> client = builder . build ();

Para ler:

    // blocking read
    byte [] data = client . read ();

Para escrever:

   client . write ( data );

Escrever assinatura:

  /**
   * write object of type T on the wire
   * it used @{@link com.network.mocket.handler.MocketStreamHandler} to parse the object
   * @param data object to send on wire to the server.
   * @throws IOException if error occurs while writing to the socket
   * @throws InterruptedException if write is interrupted
   */
  void write ( T data ) throws IOException , InterruptedException ;

Para escrever mapeador personalizado

Implemente a interface java e adicione-a ao construtor de cliente e servidor como

        builder . addHandler ( new MyCustomHandler ())

 public interface MocketStreamHandler < P > {
  /**
   * Used to encode object to byte stream
   * @param in inout object of tye {P}
   * @return byte array representing object
   * @throws ParseException throws if fails to encode or decode
   */
  byte [] encode ( P in ) throws ParseException ;

  /**
   * Used to decode bytestream to object
   * @param out inout object of tye {P}
   * @return byte array representing object
   * @throws ParseException throws if fails to encode or decode
   */
  P decode ( byte [] out ) throws ParseException ;
}

Exemplo

Um exemplo de cliente de servidor pode ser encontrado aqui.

Demonstração de aplicativo Android

Caso de uso

1. Comunicação serviço-serviço dentro do data center.
2. Use no aplicativo Android para melhor desempenho em redes instáveis.
3. Use um dispositivo Android baseado em sensor para enviar* dados periódicos ao servidor.

*Alguns gateways podem bloquear o tráfego UDP.

Próximo marco

1. Adicione suporte SSL.
2. Tenha suporte para TCP.
3. Suporte TCP multiparte.

Contribuindo

Fico mais do que feliz em aceitar contribuições externas para o projeto na forma de feedback, relatórios de bugs e, melhor ainda, solicitações pull :)

Se você gostaria de enviar uma solicitação pull, faça um esforço para seguir o guia em CONTRIBUTING.md.

Licença

Direitos autorais (C) 2016 - 2017 Nishant Pathak

 Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at

   http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.