clientthread.java

flash源码.fla和as文件

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

public class ClientThread extends Thread
{
protected Socket client; 
protected BufferedReader in; 
protected PrintStream out; 
public  static int ConnectNumber=0;
Server s;
String m;


	public ClientThread(Socket client_socket,Server s) 
	{ 
		client=client_socket; 
		this.s=s;
		
		ConnectNumber++;
		try 
		{ 
			in=new BufferedReader(new InputStreamReader(client.getInputStream())); 
			out=new PrintStream(client.getOutputStream()); 
		} 
		catch(IOException e) 
		{ 
			try 
			{
				client.close(); 
			}
			catch(IOException e2)
			{
				;
			}
			System.err.println ("Exception while getting socket streram:"+e); 
         return; 
		} 
		
		m=getClientAddress()+",进入！呵呵！"+",LS";
		s.messages.addElement(m);
	    System.out.println("total number:"+ConnectNumber);
	}
 

	public void run() 
	{ 
	    while(true)
	    {
       		try 
    		{ 
                String line=in.readLine();
	            synchronized(s.messages)
	            {
	                if(line!=null)
	                {
	                    s.messages.addElement(line);
	                }
	                else 
	                    break;
	                
	             }		        
          
            }
	  	    catch(IOException e)
	   	    {
		        break;
	   	    } 
	    }
	  	  
	}//run 
	
	
	public String getClientName()
	{
	    return client.getInetAddress().getHostName();
	}
	
	public String getClientAddress()
	{
	    return client.getInetAddress().getHostAddress();
	}
	
	public void finalize()
	{
	    try
	    {
	        in.close();
	        out.close();
	        client.close();
	    }
	    catch(Exception e)
	    {}
	    client=null;
	    in=null;
	    out=null;
	}
}