mocket

Maquette

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

Télécharger

• Utiliser jitpack comme référentiel
• Ajouter une simulation aux dépendances

Comme indiqué ci-dessous :

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

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

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

Serveur simple

Pour créer un serveur :

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

A lire :

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

Pour écrire :

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

Écrire la signature :

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

Client simple

Pour créer un client :

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

A lire :

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

Pour écrire :

   client . write ( data );

Écrire la signature :

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

Pour écrire un mappeur personnalisé

Implémentez l'interface Java et ajoutez-la au générateur de client et de serveur en tant que

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

Exemple

Un exemple de client de serveur peut être trouvé ici.

Démo de l'application Android

Cas d'utilisation

1. Communication service-service à l’intérieur du centre de données.
2. Utiliser dans l'application Android pour de meilleures performances dans les réseaux instables.
3. Utiliser dans un appareil Android basé sur un capteur pour transmettre* des données périodiques au serveur.

*Certaines passerelles peuvent bloquer le trafic UDP.

Étape suivante

1. Ajoutez la prise en charge SSL.
2. Avoir un support pour TCP.
3. Prise en charge TCP multipart.

Contribuer

Je suis plus qu'heureux d'accepter des contributions externes au projet sous forme de commentaires, de rapports de bugs et encore mieux - de demandes de tirage :)

Si vous souhaitez soumettre une pull request, veuillez faire un effort pour suivre le guide dans CONTRIBUTING.md.

Licence

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.