0

Нужно чтобы клиент постоянно находился в режиме ожидания ввода команд со стороны пользователя. Эти команды затем отправляются на сервер.

Нашел много примеров Клиент-Серверного общения (Java).
Например этот: Простейшее клиент-серверное приложение

В этом примере клиент ожидает ввода с консоли. А как сделать ожидание ввода с компонета управления, например TextField (JavaFX)?

Есть идея, сохранять текст из TextField в некую переменную. Клиент будет раз в секунду проверять эту переменную на изменения. При изменении отправлять строку на сервер.

Либо обработать событие ActionEvent для TextField . Можно ли определить в клиенте функцию, которая будет получать строку и отправлять ее на сервер? Эта функция я полагаю должна вызываться из обработчика ActionEvent .

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

17
  • отправлять что-то на сервер, после того, как нажата кнопка после ввода? 15 янв 2019 в 16:07
  • @michael_best Да, что написать в обработчике события ActionEvent? Можно ли определить в Клиенте функцию, которая будет получать строку и отправлять ее на Сервер. Эта функция я полагаю должна вызываться из обработчика ActionEvent 15 янв 2019 в 16:19
  • думаю есть смысл написать onClickEvent. А в нем уже String s = whereStringIs.getText(). А затем s.sendSomeWhere(); 15 янв 2019 в 16:35
  • @michael_best Подвох в том, что при использовании потока System.in не нужно думать о том, что делать Клиенту во время ожидания. System.in является блокирующим и Клиент автоматически находится в режиме ожидания. Грубо говоря, как изменить поток ввода, что бы был с TextField а не с консоли? 16 янв 2019 в 9:07
  • как вы определяете, когда пользователь перестал вводить что-то в поле? 16 янв 2019 в 10:43

1 ответ 1

0

Можно организовать приостановление и возобновления потока клиент с помощью функций wait(), notify() . Вот минимальная рабочая часть кода класса клиент:

public class MyClient extends Thread{

    private DataOutputStream ostream ;
    private DataInputStream istream;
    private Socket socket;

    private boolean isPause;
    private boolean isContinue;

    private String command;

    private final String HOST;
    private final int PORT;
    private final int BUFF_SIZE=64;
    private final GuiElement guiElement;

    public MyClient(String HOST, int PORT,GuiElement guiElement) {
        this.HOST=HOST;
        this.PORT=PORT;
        this.guiElement=guiElement;
        this.isPause=true;
        this.isContinue=true;
        this.setDaemon(true);

        try {
            socket = new Socket(HOST, PORT);
            ostream = new DataOutputStream(socket.getOutputStream());
            istream = new DataInputStream(socket.getInputStream());
        } catch (Exception e) {
            isPause=false;
            isContinue=false;
        }

        start();
    }

    public void run() {

        while(isContinue) {

            //-----waiting
            synchronized(this) {
                while(isPause) {
                    try {
                        wait();
                    } catch (InterruptedException e) {
                        closeSocket();
                    }
                }
            }

            //-----sending command
            sendCommand();
        }

        closeSocket();
    }

    //-----invoked from the class that creates this Client thread
    //-----when the user has clicked the enter button on the input field 
    synchronized public void setCommand(String command) {
        this.command=command;
        isPause=false;
        notify();
    }

    private void sendCommand() {

        try {
            ostream.write(command.getBytes());
            ostream.flush();

            byte buf[] = new byte[BUFF_SIZE];
            int r;

            r = istream.read(buf);
            String data = new String(buf, 0, r);

        } catch (Exception e) {
            closeSocket();
        }
        Platform.runLater(() -> guiElement.print(data)); /* display a message on a GUI element  */
        isPause=true;
    }

    private void closeSocket() {
        try {
            if(socket.isClosed())return;
            else socket.close();
        } catch (Exception e) {
            isPause=false;
            isContinue=false;
        }
    }
}

После запуска поток клиент находится в режиме ожидания. При вызове извне (из основного потока, который обращается к потоку клиент например так: client.setCommand(some message) ) функции setCommand() устанавливается текущая команда и уведомляется о прекращении ожидания ( notify() ) . Далее поток выходит из блока while(isPause){...} для отправки команды серверу самостоятельно запуская функцию sendCommand(). После выполнения функции sendCommand() поток снова переходит в режим ожидания попадая в блок while(isPause){...}

Ваш ответ

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

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