package cr;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.PrintWriter;
import java.net.Socket;

public class ClientConnectListen extends Thread {

	Socket socket;

	BufferedReader breTemp;

	PrintWriter writer;

	ClientMain smaTemp;

	boolean booKick;

	ClientConnectListen(Socket sock, ClientMain smaTemp) {
		this.socket = sock;
		this.smaTemp = smaTemp;
		breTemp=smaTemp.breTemp;
		booKick = false;
	}

	public ClientConnectListen() {
	}

	public void run() {
		try {
			String strTemp;
             while ((strTemp=breTemp.readLine())!=null) {
                 if (strTemp.equals("ADD")){    //“ADD”消息的下一次消息發(fā)送的是要添加的聊友昵稱
                	 smaTemp. ltaOnline.addElement(breTemp.readLine()); //加到在線聊友昵稱列表
                   //  ltaOnline.refurbish();                    //刷新顯示
                	 smaTemp. jlaOnlineSum.setText(""+smaTemp.ltaOnline.getSum());   //更新在線人數(shù)
                 }
                 else {
                     if (strTemp.equals("DEL")){    //“DEL”消息的下一次消息發(fā)送的是要刪除的聊友昵稱
                    	 smaTemp. ltaOnline.delElement(smaTemp.breTemp.readLine());  //在線聊友昵稱列表中刪除
                       //  ltaOnline.refurbish();                     //刷新顯示
                    	 smaTemp.jlaOnlineSum.setText(""+smaTemp.ltaOnline.getSum());   //更新在線人數(shù)
                     }
                     else {
                    	 smaTemp. jtaChats.append(strTemp+ "\n");   //聊天信息追加到聊天記錄區(qū)
                     }
                  }
               }
           }catch (IOException ex) {
        	   smaTemp. jtaChats.append("接收服務器信息時出錯,可能是服務器已關閉\n");
            } 
	}
}