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 ;

Чтобы написать собственный картограф

Реализуйте интерфейс 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 Things на базе сенсора для отправки* периодических данных на сервер.

*Некоторые шлюзы могут блокировать UDP-трафик.

Следующая веха

1. Добавьте поддержку SSL.
2. Есть поддержка TCP.
3. Поддержка многочастного TCP.

Содействие

Я более чем рад принять внешний вклад в проект в виде отзывов, отчетов об ошибках и, что еще лучше, запросов на включение :)

Если вы хотите отправить запрос на включение, постарайтесь следовать инструкциям на CONTRIBUTING.md.

Лицензия

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