import java.io.BufferedReader;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.ServerSocket;
import java.net.Socket;

import com.ibm.xtq.xslt.runtime.Hashtable;

public class server {

	private static Socket s;
	private static ServerSocket ss;
	static int i=1;
	public static void main(String[] args) 
        {
		try
		{
			ss=new ServerSocket(1234   );
			System.out.println("\nThe server\t"+ss.getInetAddress().getLocalHost()
					+"\tis listening at port\t"+ss.getLocalPort());
			while(true)
			{
				s=ss.accept();
				new threadHandler(s,i).start();
				i++;
				
			}
			
		}
		catch(Exception ioe)
		{
			System.out.println(ioe);
			
		}
	}

}

class threadHandler extends Thread
{
	Socket clientSocket;
	int clientNo;
	DataInputStream dis;
	DataOutputStream dos;
	Hashtable ht=new Hashtable();
	BufferedReader br;
	
	threadHandler(Socket s,int n)
	{
		clientSocket=s;
		clientNo=n;
		System.out.println("Client No "+clientNo+clientSocket.getPort()+ "has logged in ");
	}
	public void run()
	{
		while(true)
		{
			try
			{
			dis=new DataInputStream(clientSocket.getInputStream());
			dos=new DataOutputStream(clientSocket.getOutputStream());
			String recd=dis.readUTF();
			System.out.println(recd);
			br=new BufferedReader(new InputStreamReader(System.in));
			System.out.println("\n\nType Message" + " for client...\n");
			String fromServer=br.readLine();
			
			dos.writeUTF("\nThanks for" +"Joining Us......."+fromServer );
			}
			catch(IOException e)
			{
				System.out.println(e);
			}
		}
	}
}