Как разрешить серверу получать более одного сообщения от клиентов?

Question

Я хочу иметь сервер, который работает и получает сообщения от клиентов, таких как другие приложения Java. Я делаю это через BufferedReader с InputStream и пока я делаю это один раз, он работает, как ожидалось. Сообщение обрабатывается методом и записывает на экран тестовое сообщение о полученном сообщении, но если я разрешу запустить его в цикле while, оно скажет:

java.net.SocketException: Connection reset

Так что, как только сервер получил сообщение, я не знаю, как получить второе или любое следующее.

Мой основной исходный код:

public static void main (String[] args)  {

    int port = 13337;
    BufferedReader msgFromClient = null;
    PrintWriter msgToClient = null;

    timeDate td = new timeDate(); //Class i did for myself to get time/date

    ServerSocket s_socket = null;
    try {
        s_socket = new ServerSocket(port);
        System.out.println("Server startet at "+td.getCurrDate()+" "+td.getCurrTime());
    }
    catch (IOException ioe) {
        System.out.println("Server on Port "+port+" couldnt be created. \nException: "+ioe.getMessage());
    }

    Socket socket = null;
    try {
        socket = s_socket.accept();
    } catch (IOException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }

    try {
        msgFromClient = utils.createInputStream(socket);
    } catch (IOException ioe) {
        System.out.println("Creation of an Input Stream failed.\n Exception - "+ioe);
    }
    try {
        msgToClient   = utils.createOutputStream(socket);
    } catch (IOException ioe) {
        System.out.println("Creation of an Output Stream failed.\n Exception - "+ioe);
    } 

    String input = null;
    while (true) {
            try {
                input = msgFromClient.readLine();
            } catch (IOException ioe) {
                System.out.println(ioe);
            }
            if(input!=null) {
                System.out.println("Jumping out of loop: "+input);
                utils.processCode(input);
            }
    } 

Оба класса для создания потоков выглядят так:

public static BufferedReader createInputStream (Socket socket) throws IOException {

    BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));

    return br;
}

public static PrintWriter createOutputStream (Socket socket) throws IOException {

    PrintWriter pw = new PrintWriter(socket.getOutputStream(), true);

    return pw;
}   

Класс "processCode" тогда просто является переключателем.

Answer 1

Socket socket = null;
try {
    socket = s_socket.accept();
} catch (IOException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
}

Вы принимаете только одно Соединение и после этого вы выполняете свою обработку. Вам нужно открыть новую тему для каждого соединения

ExecutorService threadLimit = Executors.newFixedThreadPool(10);
    while(true)  {
        Socket s = serverSocket.accept();
        treadLimit.submit(new HandleThread(s));
    }