import java.net.*;
import java.io.*;
public class ClientThread extends Thread          
{	//維持服務器與單個客戶端的連接線程，負責接收客戶端發來得信息
	//聲明Socket對象，用于保存客戶端的連接
    Socket clientSocket;
    
    //聲明服務器端數據輸入輸出流
    DataInputStream in = null;
    DataOutputStream out = null;
    
    //聲明ServerThread對象
    ServerThread serverThread;
    String str;
    public static int ConnectNumber=0;

    public ClientThread(Socket socket,ServerThread serverThread)
    {
        clientSocket=socket;   
        this.serverThread=serverThread;
        try
        {
        		//創建服務器端數據輸入輸出流
                in = new DataInputStream(clientSocket.getInputStream());
                out = new DataOutputStream(clientSocket.getOutputStream());
        }
        catch (IOException e2)
        {
            System.out.println("發生異常"+e2);
            System.out.println("建立I/O通道失敗！");
            System.exit(3);
        }
    }

    public void run()
    {
        while(true)
        {
            try
            {
            	//讀入客戶端發送來得信息
                String Message=in.readUTF();
                synchronized(serverThread.messages)
                {
                    if(Message!=null)
                    {
                    	//將客戶端發送來得信息存于Vector數組中
                        serverThread.messages.addElement(Message);
                        Sever.jTextArea1.append(Message+'\n');
                    }
                }
            }
            catch(IOException E){break;}
        }
    }
}