serverthread.java

java编写聊天室

import java.io.*;
import java.awt.*;
import java.net.*;
import java.util.*;
import java.awt.event.*;
 class ServerThread extends Thread{
	int sPort;
	ServerSocket sSocket;
	ServerFrame frame;
	
	TextArea sStatus;
	
	Vector Clients;
	Vector messages;
	Vector username;
	BroadCast BroadCastWriter;
	Renovate RenovateWriter;
	CleanDeadConnect Cleaner;
	//Sql sql;
	
	public ServerThread(ServerFrame f)
	{
		Clients=new Vector();
		messages=new Vector();
		username=new Vector();
		//sql=new Sql();
		
		try{
			sPort=6633;
			sSocket=new ServerSocket(sPort);
		}
		catch(IOException E){
			System.out.println("发生异常:"+E);
			System.out.println("无法建立服务器Socket!!");
			System.exit(1);
		}
		
		this.frame=f;
		sStatus=frame.ServerStatus;
		
		sStatus.append("聊天服务器已启动..\n\n");
		sStatus.append(">>>>>等待联机<<<<<\n\n\n\n");
		
		BroadCastWriter=new BroadCast(this);
		BroadCastWriter.start();
		
		RenovateWriter=new Renovate(this);
		RenovateWriter.start();
		
		Cleaner=new CleanDeadConnect(this);
		Cleaner.start();
	}
	
	public void run(){
		while(true){
			try{
				Socket cSocket=sSocket.accept();
				
				ClientThread cThread=new ClientThread(cSocket,this);
				cThread.start();
				
				//System.out.println("ServerThread先运行");
				
				
				   
				
			}
			catch(IOException E)
			{
				System.out.println("发生异常:"+E);
				System.out.println("建立客户端联机失败!");
				System.exit(2);
			}
		}
	}
	
	public void finalize(){
		try{
			sSocket.close();
		}
		catch(IOException E){}
		
		sSocket=null;
	}
	
	public void closeAll()
	   {
		   while(Clients.size()>0)
		   {
			   ClientThread c=(ClientThread)Clients.firstElement();
			   try
			   {
				   c.socket.close();
				}
			   catch(IOException e)
			   {
				   System.out.println("error"+e);
			   }
		   finally
		   {
			  Clients.removeElement(c);
			   
		   }
		  }
		   
	   }

}