server.input.java

package Talk16T;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.Socket;

public class Input extends Thread {
    private BufferedReader inFromClient;
    private Socket connectionSocket;

    public Input(Socket connectionSocket) {
        this.connectionSocket = connectionSocket;

        try {
            inFromClient = new BufferedReader(new InputStreamReader(connectionSocket.getInputStream()));
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    @Override
    public void run() {
        boolean done = false;
        while (!done) {
            try {
                String text = inFromClient.readLine();
                if (text.equalsIgnoreCase("/close")) {
                    done = true;
                }
                else {
                    System.out.println("Client: " + inFromClient.readLine());
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }

        try {
            connectionSocket.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}