serverthread.java

《Java TCP/IP应用开发详解》的部分源程序,开发环境为ECLIPSE3.1

package Section17;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.PrintWriter;
import java.net.Socket;

public class ServerThread extends Thread {

	public ServerThread() {}
	public void run()
	{
		Angent angent=null;
		String theOutput=null;
		try{
			angent=ChatServer.theStack.pop();
			Socket angentSocket=angent.socket;
			BufferedReader in=angent.in;
			
			PrintWriter out=angent.out;
			ChatProtocol cp=new ChatProtocol();
			while(true)
			{
				String str=in.readLine();
				if(str==null)
				  {
					String s=angent.userName+" left...";
					ChatServer.broadcast.removeUser(angent);
					ChatServer.broadcast.broadcast(s);
				    System.out.println(s);
					return;
				  }
				
				System.out.println("you input string is "+str);
                
				if(angent.userName==null)
				  {
					System.out.println("the Angent's userName is null!");
					if(str!=null&&(!str.trim().equals("")))
					  	angent=cp.login(str,angent);
						          		
                	else
                	  {
                		theOutput="You must register first:please input your name.Usage:[login;;yourname]";
    					out.println(theOutput);
    					out.flush();
                		
                	  }
				  }   
				else
				  cp.chat(str,angent);
			}
		
		}catch(Exception e)
		{e.printStackTrace();}
	}		
					
}				
				
				/*if(angent.userName==null)
				  {
					theOutput="Register:please input your name.Usage:[login;;yourname]";
					out.println(theOutput);
					out.flush();
				  }
				else
						if(str!=null)
			    	       if(!str.equals(""))
			    	         {
			    		       angent=cp.login(str,angent);
			    		       if(angent.exist())cp.chat(str,angent);
			    	         }
				}else{
					throw new IOException();
				}
			}
		}catch(IOException ex){
			String s=angent.userName+" left...";
			ChatServer.broadcast.removeUser(angent);
			ChatServer.broadcast.broadcast(s);
		}
	}*/