mocket

Mocket

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

Descargar

• Utilice jitpack como repositorio
• Agregar mocket a las dependencias

Como se muestra a continuación:

1. experto

< 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 sencillo

Para construir un servidor:

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

Para leer:

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

Para escribir:

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

Escribir firma:

  /**
   * 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 sencillo

Para construir cliente:

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

Para leer:

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

Para escribir:

   client . write ( data );

Escribir firma:

  /**
   * 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 escribir un mapeador personalizado

Implemente la interfaz Java y agréguela al generador de cliente y 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 ;
}

Ejemplo

El cliente de servidor de muestra se puede encontrar aquí ejemplo.

Demostración de la aplicación de Android

Caso de uso

1. Comunicación servicio-servicio dentro del centro de datos.
2. Úselo en la aplicación de Android para obtener un mejor rendimiento en redes inestables.
3. Utilícelo en un dispositivo Android basado en sensores para enviar* datos periódicos al servidor.

*Algunas puertas de enlace pueden bloquear el tráfico UDP.

Próximo hito

1. Agregue soporte SSL.
2. Tener soporte para TCP.
3. Soporte TCP multiparte.

Contribuyendo

Estaré más que feliz de aceptar contribuciones externas al proyecto en forma de comentarios, informes de errores y, mejor aún, solicitudes de extracción :)

Si desea enviar una solicitud de extracción, haga un esfuerzo por seguir la guía en CONTRIBUTING.md.

Licencia

Copyright (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.