jnetrobust

Быстрый, надежный и ненавязчивый протокол виртуальной сети, ориентированный на сообщения, для Java 6+.
На данный момент в альфе.

Что это такое?

JNetRobust — это протокол виртуальной сети, который находится между транспортным и прикладным уровнями.

Преимущества

• надежность передаваемых данных
  счетчики сетевых характеристик, таких как доставка вне очереди, потеря пакетов, дублирование пакетов
• получено, непроверенные данные доступны немедленно
  это отличается от TCP, поскольку TCP предоставляет вам данные только после того, как он может гарантировать правильную доставку.
• пакет больше пакета UDP, но меньше пакета TCP
• позволяет избежать некоторых ошибок совместного использования UDP и TCP
  одновременный трафик UDP и TCP может привести к увеличению потери пакетов

Предостережения

• нет контроля потока
• в настоящее время нет контроля перегрузки
  будущие выпуски могут включать эту функцию

Почему я должен его использовать?

Если вам не нужна надежность, используйте UDP.
Если вам нужна надежность и вы можете дождаться ее проверки, используйте TCP.
Если вам нужна надежность, но вы получаете выгоду от получения непроверенных данных без задержек, попробуйте JNetRobust.

Как мне его использовать?

Это библиотека, и она не накладывает никаких ограничений на ее использование:

• протокол поддерживает внутреннее состояние, которое обновляется каждый раз, когда вы его используете
• протокол просто добавляет/удаляет метаданные в/из исходных данных
• вы решаете, что делать с данными, упакованными в метаданные (например, добавить некоторые свои собственные метаданные и т. д.).
• вы решаете, как вы хотите сериализовать данные, упакованные в метаданные (например, с помощью сериализации по умолчанию, Kryo и т. д.).
• вы решаете, как вы хотите отправлять упакованные метаданные данные (например, простой DatagramSocket, новый NIO DatagramChannel или даже сетевые платформы, такие как Apache MINA).

Для начала вы можете использовать эталонную реализацию, которая объединяет все эти части; пример приведен ниже.

Обратитесь к страницам Wiki для получения дополнительной информации!

Разговор стоит дешево. Покажи мне код. [1]

Вот минимальный, полный пример использования предоставленной эталонной реализации:
Код

 public class BidirectionalMain {
    public static void main ( String [] args ) throws Exception {
        String receivedMessage ;

        // host addresses
        InetSocketAddress ADDRESS_A = new InetSocketAddress ( InetAddress . getLocalHost (), 12345 );
        InetSocketAddress ADDRESS_B = new InetSocketAddress ( InetAddress . getLocalHost (), 12346 );

        // setup ProtocolHosts using the host's local address and registering all serialization dataTypes
        // ProtocolHost supports multiplexing between different peers using respective topicId, remote address and dataType

        ProtocolHost protocolHostA = new ProtocolHost ( "A" , ADDRESS_A , String . class );
        ProtocolHandle < String > protocolHandleA = protocolHostA . register ( Byte . MIN_VALUE , ADDRESS_B );

        ProtocolHost protocolHostB = new ProtocolHost ( "B" , ADDRESS_B , String . class );
        ProtocolHandle < String > protocolHandleB = protocolHostB . register ( Byte . MIN_VALUE , ADDRESS_A );


        // send from A
        protocolHandleA . send ( Arrays . asList ( "Hi!" , "How you doing?" ));

        System . out . println ();
        Thread . sleep ( 100 );

        // receive at B
        while (( receivedMessage = protocolHandleB . receive ()) != null ) {
            System . out . println ( "<B> t " + receivedMessage );
        }

        // send from B
        protocolHandleB . send ( "Howdy! Fine, thanks." );

        System . out . println ();
        Thread . sleep ( 100 );

        // receive at A
        while (( receivedMessage = protocolHandleA . receive ()) != null ) {
            System . out . println ( "<A> t " + receivedMessage );
        }
    }
}

Консольный вывод

 [A]: Data sent                      -32767    Hi!
[A]: Data sent                      -32766    How you doing?

[B]: Data received ordered          -32767    Hi!
[B]: Data received                  -32767    Hi!
[B]: Data received ordered          -32766    How you doing?
[B]: Data received                  -32766    How you doing?
[B]: Newest data received           -32766    How you doing?
<B> Hi!
<B> How you doing?
[B]: Data sent                      -32767    Howdy! Fine, thanks.

[A]: Data was received at other end -32767    Hi!
[A]: Data was received at other end -32766    How you doing?
[A]: Data received ordered          -32767    Howdy! Fine, thanks.
[A]: Data received                  -32767    Howdy! Fine, thanks.
[A]: Newest data received           -32767    Howdy! Fine, thanks.
<A> Howdy! Fine, thanks.

Где я могу скачать двоичные файлы, исходники и javadoc?

Мавен

 <!-- JNetRobust library; mandatory -->
< dependency >
    < groupId >com.github.mucaho</ groupId >
    < artifactId >jnetrobust-core</ artifactId >
    < version >0.0.2</ version >
</ dependency >

 <!-- JNetRobust examples; optional -->
< dependency >
    < groupId >com.github.mucaho</ groupId >
    < artifactId >jnetrobust-samples</ artifactId >
    < version >0.0.2</ version >
</ dependency >

Ручная настройка
Вы можете загрузить jar -файлы из раздела релизов и импортировать их в свой путь к классам.

Где я могу просмотреть javadoc?

Вы можете прочитать документацию на странице ввода-вывода JNetRobusts.

Разное

Открытые проблемы и/или открытые запросы на включение . Предложения, отчеты об ошибках, улучшения кода и дополнительные функции приветствуются!

Copyright (c) Мукахо, 2014 г.
МПЛ 2.0. Прочитайте краткое объяснение. Я хотел бы призвать вас внести свой вклад в этот исходный репозиторий с помощью запросов на включение, если вы внесли какие-либо изменения.