mocket

Mocket

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

Herunterladen

• Verwenden Sie Jitpack als Repository
• Fügen Sie Mocket zu Abhängigkeiten hinzu

Wie unten gezeigt:

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

Einfacher Server

So erstellen Sie einen Server:

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

Zum Nachlesen:

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

Zu schreiben:

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

Unterschrift schreiben:

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

Einfacher Client

So erstellen Sie einen Client:

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

Zum Nachlesen:

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

Zu schreiben:

   client . write ( data );

Unterschrift schreiben:

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

So schreiben Sie einen benutzerdefinierten Mapper

Implementieren Sie die Java-Schnittstelle und fügen Sie sie dem Client- und Server-Builder hinzu als

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

Beispiel

Ein Beispiel für einen Server-Client finden Sie hier.

Android-App-Demo

Anwendungsfall

1. Service-Service-Kommunikation im Rechenzentrum.
2. Verwendung in der Android-App für bessere Leistung in instabilen Netzwerken.
3. Verwenden Sie ein sensorbasiertes Android-Gerät, um periodische Daten an den Server zu übertragen*.

*Einige Gateways blockieren möglicherweise den UDP-Verkehr.

Nächster Meilenstein

1. SSL-Unterstützung hinzufügen.
2. Unterstützung für TCP.
3. Unterstützung für mehrteiliges TCP.

Mitwirken

Ich freue mich sehr über externe Beiträge zum Projekt in Form von Feedback, Fehlerberichten und noch besser – Pull-Requests :)

Wenn Sie eine Pull-Anfrage einreichen möchten, befolgen Sie bitte die Anleitung in CONTRIBUTING.md.

Lizenz

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.