import java.awt.*;
import java.awt.event.*;
import java.applet.*;
import java.net.*;
import java.io.*;
import java.util.*;

public class ChatClient extends Applet {
    
  	TextField tfName = new TextField(15); //姓名輸入文本域
  	Button btConnect = new Button("連接"); //連接按鈕
  	Button btDisconnect = new Button("斷開連接");
  	TextArea tfChat = new TextArea(8,27); //顯示聊天信息文本框
  	Button btSend = new Button("發送");
  	TextField tfMessage = new TextField(30);  //聊天輸入
  	java.awt.List list1 = new java.awt.List(9); //顯示在線用戶信息
  
   	Socket socket=null;  //連接端口
  	PrintStream ps=null; //輸出流
  	Listen listen=null;  //監聽線程
  
  	public void init() {  //Applet初始化
	    tfChat.setEditable(false);	 //設置信息顯示框為不可編輯   
	    Panel panel1 = new Panel();  //實例化面板     
  		Panel panel2 = new Panel();        
  		Panel panel3 = new Panel();
  		tfChat.setBackground(Color.white);  //設置組件背景顏色
  		panel1.setBackground(Color.orange);
  		panel2.setBackground(Color.pink);    
	    panel3.setBackground(Color.orange);	    
	    panel1.add(new Label("姓名："));  //增加組件到面板上
	    panel1.add(tfName);
	    panel1.add(btConnect);
	    panel1.add(btDisconnect);    
	    panel2.add(tfChat);
	    panel2.add(list1);    
	    panel3.add(new Label("聊天信息"));
	    panel3.add(tfMessage);
	    panel3.add(btSend);	    
	    setLayout(new BorderLayout()); //設置Applet布局管理器
	    add(panel1, BorderLayout.NORTH);  //增加面板到Applet上
	    add(panel2, BorderLayout.CENTER);
	    add(panel3,  BorderLayout.SOUTH);
  	}

  	public boolean action(Event evt,Object obj){    //事件處理
  		try{
			if(evt.target==btConnect){   //點擊連接按鈕		
			    if (socket==null){
				 	socket=new Socket(InetAddress.getLocalHost(),5656);     //實例化一個套接字			                 
				 	ps=new PrintStream(socket.getOutputStream());   //獲取輸出流
				 	StringBuffer info=new StringBuffer("INFO: ");       			                                                      
				 	String userinfo=tfName.getText()+":"+InetAddress.getLocalHost().toString();
				 	ps.println(info.append(userinfo));	//輸出信息		
				 	ps.flush();
				 	listen=new Listen(this,tfName.getText(),socket);    //實例化監聽線程
				 	listen.start();     //啟動線程
				}   
			}
		   	else if(evt.target==btDisconnect){    //點擊斷開連接按鈕
		         disconnect();  //調用斷開連接方法
		    }
		   	else if(evt.target==btSend){   //點擊發送按鈕
		         if(socket!=null){
				     StringBuffer msg=new StringBuffer("MSG: ");     
					 String msgtxt=new String(tfMessage.getText());
					 ps.println(msg.append(tfMessage.getText()));   //發送信息  
					 ps.flush();
				 }
		   	}
		}
		catch (Exception ex){
			ex.printStackTrace();  //輸出錯誤信息
		}
    	return true;
  	}   

  	public void disconnect() {   //斷開連接方法
     	if(socket!=null){
			ps.println("QUIT");  //發送信息
			ps.flush();
	 	}
  	}

  	class Listen extends Thread{    //監聽服務器傳送的信息
 		String name=null;          //用戶名
	 	BufferedReader reader ;    //輸入流
 		PrintStream ps=null;     //輸出流
 		Socket socket=null;      //本地套接字
 		ChatClient client=null;   //客戶端ChatClient實例

 		public Listen(ChatClient p,String n,Socket s) {  
	 		client=p;
	 		name=n;
	 		socket=s;

	 		try{
			    reader = new BufferedReader(new InputStreamReader(s.getInputStream())); //獲取輸入流
		 		ps=new PrintStream(s.getOutputStream());  //獲取輸出流

			}
	 		catch(IOException ex){
	    		client.disconnect(); //出錯則斷開連接
	    		ex.printStackTrace(); //輸出錯誤信息
	   		}
    	}  
  
 		public void run(){  
      		String msg=null;
	  		while(socket!=null){
	     		try{
	     			msg=reader.readLine();  //讀取服務器端傳來信息
	     		}                 
		 		catch(IOException ex){
	    			client.disconnect(); //出錯則斷開連接
	    			ex.printStackTrace(); //輸出錯誤信息
		 		}
		 		if (msg==null) {    //從服務器傳來的信息為空則斷開此次連接
			   		client.listen=null;              
		   			client.socket=null;
		   			client.list1.removeAll();
		   			return;
		 		}
		 		StringTokenizer st=new StringTokenizer(msg,":");   //分解字符串
		 		String keyword=st.nextToken();         

		 		if(keyword.equals("newUser")) {    //新用戶連接信息
		     		client.list1.removeAll();  //移除原有用戶名
			 		while(st.hasMoreTokens()) {    //取得目前所有聊天室用戶名
			     		String str=st.nextToken();
				 		client.list1.add(str);  //增加到用戶列表中
			 		}
		 		}
		 		else if(keyword.equals("MSG")) {    //聊天信息	                                                 
	     			String usr=st.nextToken();
			 		client.tfChat.append(usr);  //增加聊天信息到信息顯示框
			 		client.tfChat.append(st.nextToken("\0"));
			 		client.tfChat.append("\n");  
			 	}
		 		else if(keyword.equals("QUIT")) {   //斷天連接信息  
		     		System.out.println("Quit");
		     		try{
		      			client.listen=null;
		      			client.socket.close();  //關閉端口
			  			client.socket=null;
             		}
             		catch(IOException e){}
			  		client.list1.removeAll();  //移除用戶列表	 
			 		return;
		 		}
	  		}
 		}     
	} 
}