import java.io.*;
import java.net.*;
 
public class MultiThreadServer implements Runnable {
 
    Socket socket;
 
    MultiThreadServer(Socket csocket) {
        this.socket = csocket;
    }
 
    public static void main(String args[]) throws Exception {
        ServerSocket ssock = new ServerSocket(9899);
        System.out.println("Listening");
        int a = 0;
        while (true) {
            Socket sock = ssock.accept();
            a++;
            InetAddress addr = sock.getInetAddress();
            System.out.println("Connection made to " + addr.getHostName() + " (" + addr.getHostAddress() + ") ID: " + a);
            new Thread(new MultiThreadServer(sock)).start();
        }
    }
 
    public void run() {
        try {
            BufferedReader in = new BufferedReader(
                    new InputStreamReader(
                    socket.getInputStream()));
            StringBuilder input = new StringBuilder();
            char temp;
            PrintStream ps = new PrintStream(socket.getOutputStream());
            while (true) {
                if (!socket.isConnected()) {
                    System.out.println("NOT CONNECTED ANYMORE!!");
                    break;
                }
                input.append((char) in.read());
                //Last character.
                temp = input.charAt(input.length() - 1);
 
                if ((int) temp == 1) {
                    input.setLength(input.length() - 1);
                    System.out.println("INPUT: " + input);
                    if (input.toString().equals("Hello")) {
                        ps.println("Well Hello There");
                    }
                    input = null;
                    input = new StringBuilder();
                }
            }
            in.close();
            ps.close();
            socket.close();
        } catch (IOException e) {
            System.out.println(e);
        }
    }
}
 

Commenting Options