//用來實現接受從客戶端發來的數據流 監聽用戶發來的信息 并執行相關的方法
package dssclient;
import java.io.BufferedInputStream;
import java.io.IOException;
import java.io.PrintStream;
import java.net.Socket;
import java.util.StringTokenizer;

public class ClientListen extends Thread{
	ListUser tkparent;
	String name;
	Socket socket;
	BufferedInputStream in;                                 //用來實現接受從客戶端發來的數據流
	PrintStream out;                   
	byte[] data = new byte[512];
	static String ENC = "GB2312";

	public ClientListen(ListUser p,Socket s){   //接收數據和發送數據的流
		//接受參數
		tkparent=p;
		socket=s;
		try{//實例化兩個數據流
			out=new PrintStream(s.getOutputStream());        //發送數據
			in=new BufferedInputStream(s.getInputStream());  //接收數據
		}
		catch(IOException e){
			System.out.println("錯誤:"+e);
			tkparent.disconnect();
		}
	} 
  
	public void run(){
		String msg = null;
		while(true){
			try{
				in.read(data);
				msg = new String(data,ENC);
			}
			catch(IOException e){
				System.out.println("錯誤:"+e);
				tkparent.disconnect();
			}
			if (msg == null){                           //如果從服務器傳來的信息為空則斷開此次連接          
				try{
					tkparent.sk.close();
				}
				catch(IOException e){
				}
				return;
			}
			StringTokenizer st=new StringTokenizer(msg,":");   //用StringTokenizer類來實現讀取分段字符
			String keyword=st.nextToken();                     //讀取信息頭即關鍵字用來識別是何種信息
			if(keyword.equals("EXIST"))
			{
				int size=Integer.parseInt(st.nextToken());
				for(int i=0;i<size;i++){
					tkparent.adduser(st.nextToken());
				}
			}
			
			else if(keyword.equals("MSG")){                  //如果關鍵字是MSG則是服務器傳來的聊天信息
		//		parent.msghandle(st.nextToken("\0"));                
			}
	
			else if(keyword.equals("NEW")){
				tkparent.adduser(st.nextToken());	        
			}
			
			
			else if(keyword.equals("BULK")){
				tkparent.batchandle(st.nextToken("\0"));   			
			}
			else if(keyword.equals("QUIT")){
				tkparent.removeuser(st.nextToken());
			}		
			else if(keyword.equals("ERROR")){
			}		
			else if(keyword.equals("FILE_TO")){
				tkparent.FileTobox(st.nextToken("\0"));			
			}
			else if(keyword.equals("FILE_FROM")){
				tkparent.FileFrombox(st.nextToken("\0"));
			}	
			
		}
	}    
	
	void send(String msg){
		out.print(msg);
		out.flush();
	}
}