3

Есть сервер, на котором должен работать демон (фоновый процесс, не важно как назвать) постоянно обрабатывающий массив информации. Периодически он должен проверять не пришли ли какие-то сообщения от сетевых клиентов и, если пришли, записывать их в базу. Из-за определённых ограничений клиенты отправляют серверу сообщения исключительно по udp протоколу.
Если я правильно понял прочитанную литературу по работе с udp-сокетами, то выглядеть это будет примерно так:

-где-то вначале инициализируем сокет на определённом порту

try {
    socket = new DatagramSocket(port);
}
catch (SocketException e) {
    // Сообщение об ошибке, возможно остановка всего демона, если ничего не вышло
}


-далее выполняем основную работу демона и в определённые моменты пытаемся получить информацию из сокета:

byte[] bytes = new byte[1024];
DatagramPacket p = new DatagramPacket(bytes, bytes.length);
try {
    socket.receive(p);
}
catch(IOException e) {
}


Насколько я понимаю, если ни один клиент не прислал пакета данных, то на данном этапе всё остановится и процесс будет ждать прихода данных на сокет. Правильно?
А мне необходимо, чтоб работа продолжалась независимо от того, получены данные или нет. Если получены - хорошо - записали их в базу, если нет, ну и ладно - ещё масса работы.
В C++ существует возможность перевода сокета в неблокирующий режим, выглядит это приблизительно так:

int nonBlocking = 1;
if ( fcntl( handle, F_SETFL, O_NONBLOCK, nonBlocking ) == -1 )
{
    printf( "failed to set non-blocking socket\n" );
}

для UNIX и MAC и

DWORD nonBlocking = 1;
if ( ioctlsocket( handle, FIONBIO, &nonBlocking ) != 0 )
{
    printf( "failed to set non-blocking socket\n" );
}

для WINDOWS
где handle - дескриптор сокета.
При таком режиме, при чтении из сокета, в случае, когда данные в нём отсутствуют,

int received_bytes = recvfrom( handle, (char*)packet_data,
maximum_packet_size, 0, (sockaddr*)&from, &fromLength );

программа не остановится, а received_bytes просто будет равно нулю.
Существует ли в Java возможность переводить udp-сокет в неблокирующий режим? Или необходимо опрос сокета вести в отдельном потоке и при получении данных реализовывать какую-то событийность? Неблокирующие сокеты, в моём случае, были бы хороши тем, что опрос сокета должен проводиться в определённые моменты обработки основных данных и если получена какая-то информация, то она должна быть сохранена с привязкой к определённым ключам из основных данных, в остальное время пришедшие udp-пакеты неважны, их можно просто сбрасывать.
Бегло пробежавшись по результатам поисковых запросов не нашёл необходимого мне функционала в Java.


Почему поток для меня неудобен, попробую объяснить: всё это дело связано со сложной системой охранной сигнализации и видеонаблюдения. Грубо говоря: одни железки (железо1) постоянно пишут какие-то данные в базу. Один из процессов на сервере (процесс1) эту базу постоянно контролирует и при обнаружении в ней определённых новых данных рассылает другим железкам (железо2) сообщения. Те, в свою очередь, получив сообщения проводят определённые действия и проверки (это занимает какое-то небольшое время) и при возникновении у них каких-то событий отправляют данные на сервер по протоколу udp. Возникла задача получать эти сообщения (не критично, если некоторые будут теряться), сравнивать с данными из базы и при некоторых совпадениях - логировать. Существующее программное обеспечение не изменить - нет исходников.

Так вот проблема в том, что железо2, присылая сообщения, не ставит там никаких временных меток. А ещё оно может самостоятельно присылать сообщения, не инициированные запросами от процесса1. И мне было бы удобно в моём процессе мониторить базу (одновременно с другим процессом, это уже реализовано и сложностей с этим не возникает) и пытаться считать данные из сокета только в определённые моменты, когда там (в базе) появляются конкретные данные (эти события происходят довольно редко, раз в два-три часа), а в остальное время просто периодически сбрасывать данные сокета (если железо2 туда что-то прислало), как ненужные. Иначе я могу получить кучу данных, присланных за последнее время, которые к нужным мне событиям отношения не имеют, но выяснить это можно лишь дифференцировав это всё по времени, а временных меток (повторюсь) в сообщениях железа2 нет

Если реализовывать это в отдельном потоке, то для меня возникают определённые сложности с созданием событий и их вызовом. А неблокирующий сокет в этом случае - идеальное решение. Тем более, что такая функциональность на C++ точно есть, она работает и работает прекрасно. Вот и возник вопрос: возможно подобный функционал есть и у Java? Заодно, раз уж приходится всё делать именно на этом языке программирования, буду развиваться и учить для себя что-то новое.

1
  • А почему просто не вынести ожидание соединения в отдельный Thread?
    – VladD
    15 янв 2016 в 8:32

1 ответ 1

3

В Java все non-blocking IO содержится в пакете java.nio.channels. Неблокирующее UDP реализовано классом DatagramChannel:

Пользоваться можно как-то так:

DatagramChannel chan = DatagramChannel.open();
chan.configureBlocking( false );
chan.bind( new InetSocketAddress( 7777 ) );

ByteBuffer buffer = ByteBuffer.allocate( 4*1024 );

while (true) {
    buffer.clear();
    System.out.println("trying non-blocking receive...");
    SocketAddress from = chan.receive(buffer);
    System.out.println("non-blocking receive done.");

    if (from != null) {
        buffer.flip();
        System.out.printf("<<<--- got [%x] byte from %s%n", buffer.get(), from);
    }

    System.out.println( "sleeping..." );
    TimeUnit.SECONDS.sleep( 5 );
}
1
  • Почему-то не могу указать на то, что ответ полезен. Жму вверх, предлагает пройти регистрацию, ввожу свои регистрационные данные и мне выдаёт: "Stack Exchange (email) belongs to another user (mikhail)". Вы можете войти как mikhail или отменить попытку, чтобы остаться в системе под mikhail. (куки включены) Поэтому банально напишу: Спасибо, это именно то, что мне было нужно!
    – mikhail
    15 янв 2016 в 15:33

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.