Блог

У меня есть 2 кнопки в моем клиенте с прослушивателем кнопок каждая.

В моем первом прослушивателе кнопок я отправляю строку через сокет и получаю обратно массив целых чисел после его преобразования. Никаких проблем нет. Вот мой код.

 public void rollDice() {

    try {
        DataOutputStream sout1 = new DataOutputStream(socket.getOutputStream());
        String line = "dice";
        PrintStream out1 = new PrintStream(sout1);
        out1.println(line);
    } catch (UnknownHostException e1) {
        e1.printStackTrace();
    } catch (IOException e1) {
        e1.printStackTrace();
    }

}
  

Со вторым слушателем я хочу сначала отправить строку, чтобы перевести сервер в правильное состояние, а после я хочу отправить целое число для продолжения процесса. Вот мой код, но, похоже, он не работает. Сервер печатает случайное число, даже если я отправляю «2».

 public void sendDice() {

    try {
        DataOutputStream sout2 = new DataOutputStream(socket.getOutputStream());
        String line = "pick";
        PrintStream out2 = new PrintStream(sout2);
        out2.println(line);

        out2.write(diceListLength);
    } catch (UnknownHostException e1) {
        e1.printStackTrace();
    } catch (IOException e1) {
        e1.printStackTrace();
    }
}
  

Вот сторона сервера.

 public void run() {

        boolean running = true;

        try {

            // Create streams for reading / writing lines of text to the socket
            DataInputStream input = new DataInputStream(s.getInputStream());
            DataInputStream inputInt = new DataInputStream(s.getInputStream());

            ObjectOutputStream output = new ObjectOutputStream(s.getOutputStream());

            // Print a message:
            System.out.println("nClient from: "   s.getInetAddress()   " port "   s.getPort());

            while(running) {
                String st = input.readLine();

                if (st.equals("dice")) {
                    for (int i = 0; i < diceRolled.length - number; i  ) {
                        diceRolled[i] = (int) ( 1   Math.random() * 6);
                        System.out.print(diceRolled[i]   " ");
                    }
                    output.writeObject(diceRolled);
                    output.reset();
                } else if (st.equals("pick")) {
                    number = inputInt.readInt();
                    System.out.print(number);

                }
            } 
        } catch (IOException e) {
            System.out.println("Error: "   e.getMessage());
         // Always be sure to close the socket
        } finally {
            try {
                if (s != null) {
                    System.out.println(s.getLocalSocketAddress()   " closed.");
                    s.close();
                }                   
            } catch (Exception e) {
                System.out.println("Error: "   e.getMessage());
            }
        }
    }
  

Попробуйте установить автозапуск в потоке печати при его создании … одно целое число не будет отправлено до тех пор, пока новая строка или буфер не будут заполнены.

Из документации java

autoFlush — Логическое значение; если true, выходной буфер будет очищаться всякий раз, когда записывается массив байтов, вызывается один из методов println или записывается символ новой строки или байт (‘n’)

Также полезно:

1. Используйте обмен сообщениями на основе строк, т. Е. Второй тип сообщения может быть "pick:4" (проверить с st.startsWith("pick") помощью), а затем проанализировать целое число. С вашим кодом вы можете легко потерять состояние. (Однострочные сообщения являются «псевдоатомными»).
2. Не создавайте DataInputStreams в каждом методе прослушивателя, сделайте их объектными переменными (то же самое для потоков печати …). Нет необходимости (повторно) создавать объекты при каждом нажатии.