package chatserver2;
	import java.awt.*;
	import java.awt.event.*;
	import java.io.*;
	import java.net.*;

	public class ChatRoomServer extends Frame implements Runnable{
	 Panel panel;
	 ScrollPane sPanel;
	 TextArea textArea;
	 Button button1;
	 ServerSocket serverSock;
	 public final static int DEFAULT_PORT=6666;//默認端口號
	 Thread chatAcceptThread;//啟動接受連接的線程
	 BroadcastThread broadcastThread;//廣播thread; run when server is listening 
	 java.util.Vector clients;//記錄連接的線程
	 java.util.Vector clientsInfor;//記錄連接線程的信息
	 public static int index=0;
	 
	 public ChatRoomServer(){
	  try{
	   jbInit();
	  }catch(Exception e){
	   e.printStackTrace();
	  }
	  serverListen();//服務器開始監聽
	 }
	 
	 private void jbInit(){//初始化界面
	  panel=new Panel();
	  sPanel=new ScrollPane();
	  textArea=new TextArea("server information:\n");
	  button1=new Button("退出");
	  
	  sPanel.add(textArea);
	  
	  button1.addActionListener(new java.awt.event.ActionListener(){//退出按鈕注冊
	   public void actionPerformed(ActionEvent e){
	    button1_actionPerformed(e);
	   }
	  });
	  panel.add(button1);
	  
	  this.addWindowListener(new ChatFrame_WindowAdapter(this));//注冊到繼承了窗口適配器的類
	  this.setSize(600,600);
	  this.setLayout(new BorderLayout());
	  this.add(sPanel,BorderLayout.CENTER);
	  this.add(panel,BorderLayout.SOUTH);
	  this.show();
	  
	 }
	 
	 private void button1_actionPerformed(ActionEvent e){
	  exit();
	 }
	 
	 public void processMsg(String str){//
	  textArea.append(str);
	 }
	 
	 private void serverListen(){
	  try{
	   serverSock=new ServerSocket(DEFAULT_PORT);
	  }catch(IOException e){
	   processMsg(e.toString());
	   processMsg("server failed!\n");
	  }
	  processMsg("server listening on port:"+DEFAULT_PORT);
	  clients=new java.util.Vector();
	  clientsInfor=new java.util.Vector();
	  
	  chatAcceptThread=new Thread(this);//啟動接受連接的線程
	  chatAcceptThread.start();
	  
	  broadcastThread=new BroadcastThread(this);//廣播線程
	  broadcastThread.start();
	  
	  //還有一個回收無用連接thread 的線程
	 }
	  
	 public void run(){//接受連接并記錄線程信息
	  int i=0;
	  try{
	   while(true){
	    Socket clientSock=serverSock.accept();
	    CommunicateThread ct=new CommunicateThread(clientSock,this,index);//創建線程保持連接
	    clients.add(ct);//record Communicate Thread;
	    i++;
	    index++;//version2
	    clientsInfor.add("Thread-"+i);
	    processMsg("Thread-"+i+"join in\n");
	    
	   }
	  }catch(IOException e){
	   processMsg(e.toString());
	  } 
	 }
	 
	 public void exit(){
	  broadcastThread.broadcast("Server exit!");
	  try{
	   serverSock.close();
	  }catch(IOException ioe){}
	  finally{
	   System.exit(0);
	  }
	 }
	 
	 public static void main(String[] args){
	  ChatRoomServer chat=new ChatRoomServer();
	 }
	}