Блог

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

СЕРВЕР :

         ServerSocket serverSocket = null;
        try {
            serverSocket = new ServerSocket(PORT);
            System.out.println("Server now hosted on port "   PORT);
            Socket s = serverSocket.accept();
            System.out.println("A client has connected !");

            BufferedInputStream bis = new BufferedInputStream(s.getInputStream());
            BufferedOutputStream bos = new BufferedOutputStream(s.getOutputStream());

            while(true){            
                //RECEIVE
                int data;
                String inString = "";
                while((data=bis.read()) != -1){
                    inString  = (char)data;
                }
                System.out.println("SLAVE : "   inString);              
            }
        } catch (IOException e) {
            // TODO Auto-generated catch block
            System.out.println("Port déjà utilisé");
        }finally {
            try {
                serverSocket.close();
                System.out.println("Server closed");
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
                System.out.println("Could not close port "   PORT);
            }
        }
  

КЛИЕНТ :

 Scanner sc = new Scanner(System.in);
        Socket s = null;

        try {
            s = new Socket("127.0.0.1", PORT);

            BufferedInputStream bis = new BufferedInputStream(s.getInputStream());
            BufferedOutputStream bos = new BufferedOutputStream(s.getOutputStream());

            System.out.println("Connexion established !");
            while(true){ // without this while loop, it works fine
                String send = "";
                System.out.print(">> ");
                send = sc.nextLine();
                bos.write(send.getBytes());
                bos.flush();
            }

        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
            System.out.println("Could not connect");;
        }
        finally {
            try {
                s.close();
                System.out.println("Closing socket");
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
                System.out.println("Could not close connection");;
            }
        }
        System.out.println("End of client");
    }
  

Я ожидал, что сервер запишет любые данные, которые он считывает из сокета, по мере их поступления.
Но это просто ничего не делает.
Я не уверен, что проблема возникает с сервера или клиента.

Проблема в вашем while((data=bis.read()) != -1){ коде.

Он выполняется до тех пор, пока не будет получен EOS -1

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

 while((data=bis.read()) != -1){
   inString  = (char)data;

   if (((char)data) == 'n') {
       System.out.println("SLAVE : "   inString);   
       inString = "";
   }
}