mocket

Moket

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

Unduh

• Gunakan jitpack sebagai repositori
• Tambahkan mocket ke dependensi

Seperti yang ditunjukkan di bawah ini:

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

Server Sederhana

Untuk membangun server:

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

Untuk membaca:

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

Untuk menulis:

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

Tulis tanda tangan:

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

Klien Sederhana

Untuk membangun klien:

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

Untuk membaca:

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

Untuk menulis:

   client . write ( data );

Tulis tanda tangan:

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

Untuk menulis pembuat peta khusus

Implementasikan antarmuka Java dan tambahkan ke pembuat klien dan server sebagai

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

Contoh

Contoh klien server dapat ditemukan di sini contohnya.

Demo Aplikasi Android

Kasus Penggunaan

1. Komunikasi layanan-layanan di dalam pusat data.
2. Gunakan di aplikasi Android untuk kinerja yang lebih baik di jaringan yang tidak stabil.
3. Gunakan perangkat Android berbasis senser untuk mendorong* data berkala ke server.

*Beberapa gateway mungkin memblokir lalu lintas UDP.

Tonggak Sejarah Berikutnya

1. Tambahkan dukungan SSL.
2. Memiliki dukungan untuk TCP.
3. Dukungan TCP multi-bagian.

Berkontribusi

Saya dengan senang hati menerima kontribusi eksternal pada proyek dalam bentuk umpan balik, laporan bug, dan bahkan lebih baik lagi - permintaan tarik :)

Jika Anda ingin mengajukan pull request, silakan ikuti panduan di CONTRIBUTING.md.

Lisensi

Hak Cipta (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.