Java. Как корректно организовать взаимодествие с сетью?

Question

[DimOFF]

В качестве хобби делаю один проект. В процессе написания сетевой части возник вопрос. Суть следующая. Мое приложение на Java должно подключиться к серверу и ждать оттуда данные или передавать их туда (с сервера поступает команда что-то сделать или на клиенте наступает событие о котором нужно отчитаться).
Реализовано это приблизительно так

InputStreamReader isr = new InputStreamReader(client.getInputStream());
            BufferedReader in = new BufferedReader(isr);
            PrintWriter out = new PrintWriter(client.getOutputStream());
            String line;
            String msg;
            while (true) {
                if (isr.ready()) {
                    line = in.readLine();
                    if (line.startsWith("EXIT")) {
                        Logger.getLogger(Client.class.getName()).log(Level.INFO,"Exit");
                        break;                        
                    }
                    if (line.startsWith("BEGIN")) {
                        Logger.getLogger(Client.class.getName()).log(Level.INFO,"BEGIN");
                        break;                        
                    }
                } else {
                    try {
                        this.sleep(1);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
                if (! msg.isEmpty()) {
                    out.println(msg);
                }
            }
            out.close();
            in.close();
            client.close();

Есть ли возможность обойтись без this.sleep(1); и не греть воздух холостым ходом?

Comments

[ivan19631224]

А зачем вам в данном случае этот "isr.ready()"? Не пробовали просто сразу делать in.readLine() в цикле? Это вызов блокирующий и должен ждать пока не дождётся конца очередной строки.
И ещё, вы можете посмотреть нагрузку даже для вашего решения? По-идее она должна быть близка к нулю (по крайней мере, я так предполагаю), т.к. на проверку "isr.ready()" тратятся микросекунды (или даже наносекунды), а основное время поток находится в sleep, т.е. не жрёт CPU (хотя, конечно, такой подход в любом случае неправильный, могут быть разные проблемы при большом количестве таких потоков или при больших нагрузках).

[DimOFF]

isr.ready() позволяет узнать наличие данных, которые я не прочитал. Если их нет, то посмотреть нет ли чего для отправки. Если мы вставим сразу in.readline(), то пока не прочитаем строку выполнения не будет. А может же возникнуть ситуация, что получать нечего, зато есть что отправить.

[ivan19631224]

А зачем вам обязательно читать и писать в одном и том же потоке? В чём проблема писать в отдельном?

Answer 1

[Алексей Черемисин]

Так или иначе, лучше использовать NIO, и проверять наличие данных через selector! Вот на почитать - www.javaportal.ru/java/articles/useselectfast.html... (ожидание входящих данных)
И откажитесь вообще от sleep - это не очень красиво.
Да, возможно, данные придется буферировать, так как они могут прийти в двух пакетах, например "BEG" и "IN"
С файлами отдельная история - наверное поможет вот это! Механизм аналогичный - https://docs.oracle.com/javase/tutorial/essential/...

Comments

[DimOFF]

Вот потому я и озадачился поиском решения без sleep(). Посмотрел про NIO. Я не понимаю как прикрутить Selector к, допустим изменению файла на диске или появлению других событий, о которых мое приложение должно доложить на сервер.

[Алексей Черемисин]

С файлами отдельная история - наверное поможет вот это! Механизм аналогичный - https://docs.oracle.com/javase/tutorial/essential/...

Answer 2

[Толстый Лорри]

Так или иначе придется проверять наличие данных (это может быть скрыто за механизмом асинхронного вызова, но суть будет та же - eventloop). Продолжительностью sleep вы можете искать баланс между скоростью отклика и занимаемыми ресурсами.