Организация прослушивания Сокета в Java.

@Alexadr · Регистрация: 30.06.2011

Студворк — интернет-сервис помощи студентам

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

Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
Socket s = new Socket();
s.connect(new InetSocketAddress('192.168.0.16',4445),1000);
FlagOfRead = 1;
int i=0;
while(1 == 1)
{
  if(FlagOfRead == 1) // если флаг чтения = 1 то читаем
  {
    byte []buf = new byte [100];
    s.getInputStream().read(buf)
 
    FlagOfRead = 0; // после чтения выставляем флаг в 0
 
// ЗДЕСЬ Я ЧТО-ТО ДЕЛАЮ С ПОЛУЧЕННЫМИ ДАННЫМИ
 
  }
  try
  {
    Thread.sleep(50);
  }
  catch (InterruptedException e)
  {
    e.printStackTrace();  
  }
 
}

Как видно я создаю сокет и потом читаю с него данные, если их можно чтиать, флаг FlagOfRead я меняю интерактивно - щелчком по кнопке, - как только есть данные!!!

Так вот вопрос: Есть ли в Java некая функция которая будет обеспечивать ожидание(при этом остальная чать проги будет работать) до тех пор пока в сокете не появятся какие-нибудь данные?, - например в Unix есть функция 'select' для этих целей.

Или какой можно другой вариант исполнения того что я сделал. В принципе оно работает...

@mselez · 24.08.2011, 18:26

операция read - блокирующая, т.е. while цикл в ней будет сам стоять, если нет данных.

@Alexadr · 25.08.2011, 10:02 **[ТС]**

2mselez
В принипе вы правы, но все-таки это немного не то что хотелось, т.к. механизм блокировки ввода/вывода использовать не хотелось!!!

@аriakon · 25.08.2011, 12:48

можно использовать отдельный поток для чтения из сокета или библиотеки Nio там тоже есть select для этих целей

@Alexadr · 25.08.2011, 14:14 **[ТС]**

2 ariakon
Можно по подробнее про библиотеку Nio!!!
Я нашел её!!!, но что-то сокетов и select(ов) не обнаружил, разве что SocketChannel...

@mselez · 25.08.2011, 17:21

NIO - это усовершенствованный вариант, разбираться проще начать с традиционного.
То, что вы привели в коде, больше похоже на одноразовое соединение: открыли сокетное соединение, послали запрос на сервер, прочитали ответ, закрыли соединение. Это делается в одном потоке и примеры есть во многих учебниках. Такой вариант прост и применим, когда общение с сервером носит эпизодический характер.
Если вы хотите иметь постоянное соединение, то операции ввода-вывода надо выделять в отдельный поток или потоки. Отказ от блокирования потока при чтении имеет смысл только на сервере, который обслуживает одновременно много клиентов. Это позволяет обслуживать всех клиентов одним потоком. Собственно, это и реализовано в НИО через селекторы. А в клиентском приложении, которое работает с одним сервером, в этом смысла нет.
Еще одно преимущество НИО состоит в том, что там можно осуществить более высокую эффективность передачи данных между операционной системой и джавой.

@cryozot · 30.08.2011, 16:22

Очень редко возникает практическая необходимость использовать на сервере неблокирующие сетевые операции. Радикального увеличения количества обрабатываемых клиентов это всё равно не даст. Разве что в случае весьма специфического сервера или каких-нибудь 'эзотерических' архитектур типа SEDA...

Короче, использование неблокирующих сетевых операций NIO само по себе обычно не оправдано, проще, как уже говорилось, вынести работу с сетью в отдельный поток.

@mselez · 30.08.2011, 20:58

При использовании блокирующих сокетов на каждый сокет создается отдельный поток. Если соединения постоянные (не одноразовые), то когда к серверу подключены одновременно 100 клиентов, то для обслуживания 100 блокирующих сокетов надо создать 100 потоков. НИО дает возможность обслужить эти 100 сокетов (в неблокирующем режиме) одним потоком (поочередно).
В этом и преимущество.

@mselez · 30.08.2011, 21:05

потоком я называл thread

@cryozot · 31.08.2011, 07:47

Только в довольно редких и специфических случая можно полноценно обслужить хотя бы несколько клиентов одним потоком. Что касается общего количества потоков, то в цифре 100 нет ничего страшного. У нас, например, сервер переходит в насыщение, когда количество параллельных потоков приближается к 2000. И это если запускать на довольно слабой машине с одним процессором.

Поэтому, моё мнение такое: нет смысла экономить на количестве потоков ввода-вывода и переходить из-за этого на NIO, это ведёт только нерациональному увеличению трудозатрат.

@mselez · 31.08.2011, 17:00

'Только в довольно редких и специфических случая можно полноценно обслужить хотя бы несколько клиентов одним потоком..'

Конечно. Применение NIO очевидно предполагает, что этот один поток, обслуживающий сокеты, занимается всего лишь чтением-записью, т.е. он просто читает запрос очередного клиента и ставит его в очередь на выполнение другим потокам. Потом отправляет клиенту то, что накопилось для него в очереди. Поскольку запросы у клиентов разные по 'тяжести' и по интенсивности, то некоторая экономия в количестве бегающих потоков будет.

'Поэтому, моё мнение такое: нет смысла экономить на количестве потоков ввода-вывода и переходить из-за этого на NIO, это ведёт только нерациональному увеличению трудозатрат.'

Возможно.

Новые блоги и статьи Все статьи Все блоги /
Ритм жизни kumehtar 27.02.2026 Иногда приходится жить в ритме, где дел становится всё больше, а вовлечения в происходящее — всё меньше. Плотный график не даёт вниманию закрепиться ни на одном событии. Утро начинается с быстрых,. . .	SDL3 для Web (WebAssembly): Сборка библиотек SDL3 и Box2D из исходников с помощью CMake и Emscripten 8Observer8 27.02.2026 Недавно вышла версия SDL 3. 4. 2 библиотеки SDL3. На странице официальной релиза доступны исходники, готовые DLL (для x86, x64, arm64), а также библиотеки для разработки под Android, MinGW и Visual. . .	SDL3 для Web (WebAssembly): Реализация движения на Box2D v3 - трение и коллизии с повёрнутыми стенами 8Observer8 20.02.2026 Содержание блога Box2D позволяет легко создать главного героя, который не проходит сквозь стены и перемещается с заданным трением о препятствия, которые можно располагать под углом, как верхнее. . .	Конвертировать закладки radiotray-ng в m3u-плейлист damix 19.02.2026 Это можно сделать скриптом для PowerShell. Использование . \СonvertRadiotrayToM3U. ps1 <path_to_bookmarks. json> Рядом с файлом bookmarks. json появится файл bookmarks. m3u с результатом. # Check if. . .
Семь CDC на одном интерфейсе: 5 U[S]ARTов, 1 CAN и 1 SSI Eddy_Em 18.02.2026 Постепенно допиливаю свою "многоинтерфейсную плату". Выглядит вот так: https:/ / www. cyberforum. ru/ blog_attachment. php?attachmentid=11617&stc=1&d=1771445347 Основана на STM32F303RBT6. На борту пять. . .	Камера Toupcam IUA500KMA Eddy_Em 12.02.2026 Т. к. у всяких "хикроботов" слишком уж мелкий пиксель, для подсмотра в ESPriF они вообще плохо годятся: уже 14 величину можно рассмотреть еле-еле лишь на экспозициях под 3 секунды (а то и больше),. . .	И ясному Солнцу zbw 12.02.2026 И ясному Солнцу, и светлой Луне. В мире покоя нет и люди не могут жить в тишине. А жить им немного лет.	«Знание-Сила» zbw 12.02.2026 «Знание-Сила» «Время-Деньги» «Деньги -Пуля»

@mselez 0 / 0 / 0 Регистрация: 22.07.2009 Сообщений: 457
	24.08.2011, 18:26
	операция read - блокирующая, т.е. while цикл в ней будет сам стоять, если нет данных. 0

@Alexadr 0 / 0 / 2 Регистрация: 30.06.2011 Сообщений: 173
	25.08.2011, 10:02 [ТС]
	2mselez В принипе вы правы, но все-таки это немного не то что хотелось, т.к. механизм блокировки ввода/вывода использовать не хотелось!!! 0

@аriakon 0 / 0 / 0 Регистрация: 05.04.2009 Сообщений: 78
	25.08.2011, 12:48
	можно использовать отдельный поток для чтения из сокета или библиотеки Nio там тоже есть select для этих целей 0

@Alexadr 0 / 0 / 2 Регистрация: 30.06.2011 Сообщений: 173
	25.08.2011, 14:14 [ТС]
	2 ariakon Можно по подробнее про библиотеку Nio!!! Я нашел её!!!, но что-то сокетов и select(ов) не обнаружил, разве что SocketChannel... 0

@mselez 0 / 0 / 0 Регистрация: 22.07.2009 Сообщений: 457
	25.08.2011, 17:21
	NIO - это усовершенствованный вариант, разбираться проще начать с традиционного. То, что вы привели в коде, больше похоже на одноразовое соединение: открыли сокетное соединение, послали запрос на сервер, прочитали ответ, закрыли соединение. Это делается в одном потоке и примеры есть во многих учебниках. Такой вариант прост и применим, когда общение с сервером носит эпизодический характер. Если вы хотите иметь постоянное соединение, то операции ввода-вывода надо выделять в отдельный поток или потоки. Отказ от блокирования потока при чтении имеет смысл только на сервере, который обслуживает одновременно много клиентов. Это позволяет обслуживать всех клиентов одним потоком. Собственно, это и реализовано в НИО через селекторы. А в клиентском приложении, которое работает с одним сервером, в этом смысла нет. Еще одно преимущество НИО состоит в том, что там можно осуществить более высокую эффективность передачи данных между операционной системой и джавой. 0

@cryozot 1 / 1 / 0 Регистрация: 02.08.2011 Сообщений: 64
	30.08.2011, 16:22
	Очень редко возникает практическая необходимость использовать на сервере неблокирующие сетевые операции. Радикального увеличения количества обрабатываемых клиентов это всё равно не даст. Разве что в случае весьма специфического сервера или каких-нибудь 'эзотерических' архитектур типа SEDA... Короче, использование неблокирующих сетевых операций NIO само по себе обычно не оправдано, проще, как уже говорилось, вынести работу с сетью в отдельный поток. 0

@mselez 0 / 0 / 0 Регистрация: 22.07.2009 Сообщений: 457
	30.08.2011, 20:58
	При использовании блокирующих сокетов на каждый сокет создается отдельный поток. Если соединения постоянные (не одноразовые), то когда к серверу подключены одновременно 100 клиентов, то для обслуживания 100 блокирующих сокетов надо создать 100 потоков. НИО дает возможность обслужить эти 100 сокетов (в неблокирующем режиме) одним потоком (поочередно). В этом и преимущество. 0

@mselez 0 / 0 / 0 Регистрация: 22.07.2009 Сообщений: 457
	30.08.2011, 21:05
	потоком я называл thread 0

@cryozot 1 / 1 / 0 Регистрация: 02.08.2011 Сообщений: 64
	31.08.2011, 07:47
	Только в довольно редких и специфических случая можно полноценно обслужить хотя бы несколько клиентов одним потоком. Что касается общего количества потоков, то в цифре 100 нет ничего страшного. У нас, например, сервер переходит в насыщение, когда количество параллельных потоков приближается к 2000. И это если запускать на довольно слабой машине с одним процессором. Поэтому, моё мнение такое: нет смысла экономить на количестве потоков ввода-вывода и переходить из-за этого на NIO, это ведёт только нерациональному увеличению трудозатрат. 0

@mselez 0 / 0 / 0 Регистрация: 22.07.2009 Сообщений: 457
	31.08.2011, 17:00
	'Только в довольно редких и специфических случая можно полноценно обслужить хотя бы несколько клиентов одним потоком..' Конечно. Применение NIO очевидно предполагает, что этот один поток, обслуживающий сокеты, занимается всего лишь чтением-записью, т.е. он просто читает запрос очередного клиента и ставит его в очередь на выполнение другим потокам. Потом отправляет клиенту то, что накопилось для него в очереди. Поскольку запросы у клиентов разные по 'тяжести' и по интенсивности, то некоторая экономия в количестве бегающих потоков будет. 'Поэтому, моё мнение такое: нет смысла экономить на количестве потоков ввода-вывода и переходить из-за этого на NIO, это ведёт только нерациональному увеличению трудозатрат.' Возможно. 0