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

public class ThreadedServer
{
	public static void main(String[] args )
	{
		try
		{
			int i = 1;
			ServerSocket s = new ServerSocket(6989); //make up a port number I did
			while(true)
			{
				Socket incoming = s.accept();
				System.out.println("Spawning " + i);
				ThreadedEchoHandler ter = new ThreadedEchoHandler(incoming, i);
				Thread t = new Thread(ter);
				t.start();
				i++;
			}
		}
		catch(Exception e)
		{
			e.printStackTrace();
		}
	}
}
class ThreadedHandler implements Runnable
{
	private Socket incoming;
	private int counter;
	
	public ThreadedEchoHandler(Socket i, int c)
	{
		incoming = i;
		counter = c;
	}
	public void run()
	{
		try
		{
			try
			{
				InputStream instream = incoming.getInputStream();
				OutputStream outstream = incoming.getOutputStream();
				Scanner in = new Scanner(instream);
				PrintWriter out = new PrintWriter(outstream);
				out.println( "Welcome to CEL Server! Enter ADIOS to exit." );
				boolean done = false;
				while(!done && in.hasNextLine())
				{
					String l = in.nextLine();
					System.out.println("Client" + counter + " says: " + l);
					if (l.trim().equals("BYE"))
						done = true;
				}
			}
			finally
			{
				incoming.close();
			}
		}
		catch(Exception e)
		{
			e.printStackTrace();
		}
	}
}

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

public class EchoServer 
{
	public static void main(String[] args) 
	{
		try
		{
			ServerSocket s = new ServerSocket(6989);
			//establish server socket

			Socket incoming = s.accept();
			//waits for incoming client
			try
			{
				InputStream instream = incoming.getInputStream();
				OutputStream outstream = incoming.getOutputStream();
				
				Scanner in = new Scanner(instream);
				PrintWriter out = new PrintWriter(outstream, true /* autoFlush */);
				
				out.println( "Welcome to my Server! Enter ADIOS to exit." );
				boolean done = false;
				while (!done && in.hasNextLine())
				{
					String line = in.nextLine();
					if(line.trim().equals("ADIOS"))
					{
						out.println("Server Disconnected");
						break;
					}
					System.out.println(incoming.getRemoteSocketAddress() + " says:" + line);
				}
			}
			finally
			{
				incoming.close();
			}
		}
		catch(IOException e)
		{
			e.printStackTrace();
		}
	}
}