threadedechoserver.java

本次project实现如下功能： 写了一个本地的多线程游戏服务器ThreadeEchoServer

//ThreadedEchoServer

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


public class ThreadedEchoServer
{  
	public static void main(String[] args )
   {
   	  int i = 1;
      try
      {
      	 ServerSocket s = new ServerSocket(9999);
         for (;;)
         {
         	Socket incoming = s.accept( );
            System.out.println("有连接为<" + i+">");
            new ThreadedEchoHandler(incoming, i).start();
            i++;
         }
      }
      catch (Exception e)
      {  
      	System.out.println(e);
      }
   }
}

class ThreadedEchoHandler extends Thread
{
	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 );
            
            
         out.println( "start" );
         System.out.println("连接 (" + counter + ")已启动．" );
         
        
         boolean done = false;
         while (!done)
         {  
         	String str = in.readLine();
         	if(str.trim().equals( "startllk") )
         		{
         			out.println( "startllk" );
         			System.out.println("连接 (" + counter + ")已启动连连看．" );         			
         		} 
         	if(str.trim().equals( "startERS") )
         		{
         			out.println( "startERS" );
         			System.out.println("连接 (" + counter + ")已启动俄罗斯方块．" );         			
         		} 
         	if(str.trim().equals( "exitllk") )
         		{
         			out.println( "exitllk" );
         			System.out.println("连接 (" + counter + ")已退出连连看．" );         			
         		} 
         	if(str.trim().equals( "exitERS") )
         		{
         			out.println( "exitERS" );
         			System.out.println("连接 (" + counter + ")已退出俄罗斯方块．" );         			
         		}
         	if(str.trim().equals( "exitkehu") )
         		{
         			out.println( "exit" );
         			System.out.println("断开连接 (" + counter + ")．" );
         			done=true;         			
         		}          	
         	
            //if (str.trim().equals( "exit") ) done = true;
         }         
         
         
         //incoming.close();
      }
      catch (Exception e)
      { 
      	 System.out.println(e);
      }
   }
   private Socket incoming;
   private int counter;
}