import java.io.*;
import java.net.*;

public class server
{	public static void main(String[] args)
	{	int i=1;
		try
		{	ServerSocket s = new ServerSocket(27001);  //establish a server
			while(true)
			{	Socket incoming = s.accept();          //waiting for "i" client
				System.out.println(" Spawning " + i); 
				new ThreadedEchoHandler(incoming, i).start();
				i++;
			}
		}
		catch(Exception e)
		{	System.out.println(e);
		}
	}
}

class ThreadedEchoHandler extends Thread
{	private Socket incoming;
	private int counter;
	
	public ThreadedEchoHandler(Socket i, int c)
	{	incoming = i;
		counter  = c;
	}
	public void run()
	{	try
		{	BufferedReader in = new BufferedReader(new InputStreamReader(incoming.getInputStream()));
			PrintWriter out = new PrintWriter(incoming.getOutputStream(), true); //autoFlush
			out.println("Hello! Enter 'x' for exit");
			boolean done = false;
			while(!done)
			{	String str = in.readLine();
				if(str == null)	done = true;
				else
				{	out.println("Echo (" + counter + "): " + str);
					
					if(str.trim().equals("x"))
					done = true;    	
				}
			}
			incoming.close();
		}
		catch(Exception e)
		{	System.out.println(e);
		}
	}
} 

import java.net.*;import java.io.*;public class client{	public static void main(String[] args)	{			try		{	Socket s = new Socket("", 27001); 			PrintWriter out = new PrintWriter(s.getOutputStream());			out.print("Server hello!");		}		catch(Exception e)		{	System.out.println(e);		}	}}