Создание эхо-сервера: подключенный клиент получает исключение IO

Question

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

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

private void processClientRequest(Socket clientSocket) throws IOException { 
    InputStream in = clientSocket.getInputStream(); 
    PrintWriter out = 
     new PrintWriter(clientSocket.getOutputStream()); 
    long time = System.currentTimeMillis(); 

    out.write("Server - " + time + ": " + in); 

    out.close(); 
    in.close(); 
} 

Скажите, пожалуйста, если этот метод не является проблемой, и вам нужны другие части моего кода. Спасибо заранее!

Редактировать: Мне теперь удалось заставить мой сервер отвечать клиенту. Я сделал это, изменив метод processClientRequest к этому:

try { 
    BufferedReader in = 
     new BufferedReader(
      new InputStreamReader(clientSocket.getInputStream())); 

    PrintWriter out = 
     new PrintWriter(clientSocket.getOutputStream()); 

    long time = System.currentTimeMillis(); 

    out.write("Server - " + time + ": " + in.readLine()); 

    out.close(); 

    try { 
     in.close(); 
    } catch (IOException e) { 
     System.err.println("Couldn't close input stream"); 
    } 
} catch(IOException e) { 
     System.err.println("Got an IOException error while reading or writing from/to client"); 
} 

Но сейчас мой сервер может отвечать только клиент один раз. Если клиент записывает на сервер второй раз, он получает ответ, но вместо сообщения клиентов это «null». И так как я хочу, чтобы мой эхо-сервер мог отвечать клиенту до тех пор, пока клиент не выключится или что-то в этом роде, мне нужно выяснить, как это изменить. Я полагаю, что мне понадобится какой-то цикл while, чтобы это произошло, но я попытался, например, поставить весь оператор try в бесконечный цикл while, но это просто дало мне массу IOExceptions.

Answer 1

Вы не читаете входные данные клиентов. Вы просто передаете toString. Вам нужно сделать цикл while и прочитать из. Возможно, в отдельном потоке, если вы не уверены, что ввод короток. В тестовом коде должно быть в порядке:

private void processClientRequest(Socket clientSocket) throws IOException { 
     InputStream in = clientSocket.getInputStream();//wrap this in a object stream or other to read lines/ utf 
     int i = 0; 
     while(i++ < 1000 && in.available() > 0){ 
      int read = in.read();//use it if u want, like to a string builder declared out of loop and echo it back after u read input 
     } 
     PrintWriter out = 
     new PrintWriter(clientSocket.getOutputStream()); 
     long time = System.currentTimeMillis(); 

     out.write("Server - " + time + ": " + in); 

     out.close();//should be in seperate try catches so if 1 close fails u still close other and finally close socket in 3rd try catch 
     in.close(); 
} 

Socket server с работой эхо-сервера, мини-веб-сервер и полезным во многих других отношениях.