server.java

flash源码.fla和as文件

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

public class Server extends Thread
{
public final static int Default_port=5566;
protected int port;
protected ServerSocket listen_socket;
ServerFrame frame;
Vector Clients;
Vector messages;

BroadCast BroadCastOut;
CleanDeadConnect Cleaner;
JTextArea    ta;

	public Server(int port,ServerFrame f)
	{
	    Clients=new Vector();
	    messages=new Vector();
	    
	    if(port==0)
	    {
	        port=Default_port;
	    }
	    this.port=port;
	    try{
	        listen_socket=new ServerSocket(port);
	    }
	    catch(IOException e){;}
	    this.frame=f;
	    ta=frame.sStatus;
	    ta.append("listen on port:"+port+"\n");
	    ta.append("chat server has run!\n");
	    //System.out.println("Server:listen on port "+port);
	    BroadCastOut=new BroadCast(this);
	    Cleaner=new CleanDeadConnect(this);
	    
	    BroadCastOut.start();
	    Cleaner.start();
	}
	
	public void run()
	{
	     while(true)
	     {
	        try{
	       
	            Socket client_socket=listen_socket.accept();
	            ClientThread c=new ClientThread(client_socket,this); 
	            c.start();
	            synchronized(Clients)
	            {
	                Clients.addElement(c);
	                System.out.println("number:"+Clients.size());
	            }
	        }
	    
	    catch(IOException e){
	        System.out.println("failed!");
	    }
	    }
	}
	
}