mocket

ม็อกเก็ต

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

ดาวน์โหลด

• ใช้ jitpack เป็นที่เก็บข้อมูล
• เพิ่มจำลองการพึ่งพา

ดังที่แสดงด้านล่าง:

1. มาเวน

< 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. เกรเดิล

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

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

เซิร์ฟเวอร์ที่เรียบง่าย

ในการสร้างเซิร์ฟเวอร์:

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

หากต้องการอ่าน:

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

วิธีเขียน:

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

เขียนลายเซ็น:

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

ลูกค้าที่เรียบง่าย

วิธีสร้างไคลเอนต์:

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

หากต้องการอ่าน:

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

วิธีเขียน:

   client . write ( data );

เขียนลายเซ็น:

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

ในการเขียน mapper แบบกำหนดเอง

ใช้อินเทอร์เฟซ Java และเพิ่มลงในไคลเอนต์และตัวสร้างเซิร์ฟเวอร์เป็น

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

ตัวอย่าง

ไคลเอนต์เซิร์ฟเวอร์ตัวอย่างสามารถพบได้ที่นี่ตัวอย่าง

การสาธิตแอป Android

ใช้กรณี

1. การสื่อสารบริการ-บริการภายในศูนย์ข้อมูล
2. ใช้ในแอป Android เพื่อประสิทธิภาพที่ดีขึ้นในเครือข่ายที่ไม่สม่ำเสมอ
3. ใช้ในอุปกรณ์ Android ที่ใช้เซนเซอร์เพื่อส่งข้อมูลเป็นระยะไปยังเซิร์ฟเวอร์

*เกตเวย์บางตัวอาจบล็อกการรับส่งข้อมูล UDP

เหตุการณ์สำคัญครั้งต่อไป

1. เพิ่มการสนับสนุน SSL
2. มีการสนับสนุนสำหรับ TCP
3. รองรับ TCP หลายส่วน

มีส่วนร่วม

ฉันยินดีเป็นอย่างยิ่งที่จะยอมรับการมีส่วนร่วมจากภายนอกในโครงการในรูปแบบของข้อเสนอแนะ รายงานข้อผิดพลาด และยิ่งกว่านั้น - ดึงคำขอ :)

หากคุณต้องการส่งคำขอดึง โปรดปฏิบัติตามคำแนะนำใน CONTRIBUTING.md

ใบอนุญาต

ลิขสิทธิ์ (C) 2016 - 2017 นิชานต์ ปาตัก

 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.