Client.java

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

public class Client {
    private Socket clientSocket;
    private PrintWriter out;
    private BufferedReader in;
    private boolean running;

    public Client() {
      running = true;
    }

    public void connectTo(String ip, int port) throws IOException {
        connectToServer(ip, port);
        startTerminalInputThread();
        printReceivedMessages();
    }

    private void connectToServer(String ip, int port) throws IOException{
        clientSocket = new Socket(ip, port);
        out = new PrintWriter(clientSocket.getOutputStream(), true);
        in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
    }

    private void startTerminalInputThread() {
        TerminalInput terminalInput = new TerminalInput(this);
        new Thread(terminalInput).start();
    }

    private void printReceivedMessages() throws IOException {
        String message;
        while(running && (message = receiveMessage()) != null) {
          System.out.println(message);
        }
        disconnect();
    }

    private String receiveMessage() throws IOException {
      return in.readLine();
    }

    public boolean isRunning() {
      return running;
    }

    public void stopRunning() {
      running = false;
    }

    public void sendMessage(String message) throws IOException{
        out.println(message);
    }

    public void disconnect() {
      running = false;
        try {
          if(in != null) {
            in.close();
          }
          if(out != null) {
            out.close();
          }
          if(clientSocket != null) {
            clientSocket.close();
          }
        } catch(Exception e) {
          System.out.println("Error occured disconnecting: " + e);
        }
    }
}