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


public class MultiUser extends Thread  
{
	private Socket client;

	public MultiUser( Socket c ) 
	{
		this.client = c;
	}

	public void run() 
	{
		try
		{
			BufferedReader in = new BufferedReader( new InputStreamReader( client.getInputStream() ) );
			PrintWriter out = new PrintWriter( client.getOutputStream() );

			while( true )
			{
				String str = in.readLine();
				System.out.println( str );
				out.println( "has reveive" +   str );
				out.flush();
				if( str.equals( "end" ))
					break;
			}
			client.close();

		}
		catch ( IOException ex )
		{

		}
		finally
		{

		}
	}

	public static void main( String[] args ) throws IOException
	{
		ServerSocket server = new ServerSocket( 5678 );
		while( true )
		{
			MultiUser mu = new MultiUser( server.accept() );
			mu.start();
		}
		
	}
}