import java.net.*;
import java.io.*;
public class Client1 implements Runnable
{
    Socket clientSocket;
    boolean flag=true;                   //標(biāo)記是否結(jié)束
    Thread c;                            //用于向服務(wù)器端發(fā)送信息
    BufferedReader cin;
    DataOutputStream cout;
    public static void main(String arg[])
    {
        new Client1().ClientStart();
    }
    public void ClientStart()
    {
        try
        {                                //連接服務(wù)器端，這里使用本機
            clientSocket=new Socket("localhost",5678);
            System.out.println("已建立連接!");
            while(flag)
            {                            //獲取流對象
                InputStream is = clientSocket.getInputStream();
                cin=new BufferedReader(new InputStreamReader(is));
                OutputStream os = clientSocket.getOutputStream();
                cout = new DataOutputStream(os);
                c = new Thread(this);
                c.start();               //啟動線程，向服務(wù)器端發(fā)送信息
                String aline;
                while((aline=cin.readLine())!=null)
                {                        //接收服務(wù)器端的數(shù)據(jù)
                    System.out.println(aline);
                    if(aline.equals("bye"))
                    {
                        flag = false;
                        c.interrupt();
                        break;
                    }
                }	
                cout.close();
                os.close();
                cin.close();
                is.close();
                clientSocket.close();	 //關(guān)閉Socket連接
                System.exit(0);	 
            }
        }
        catch(Exception e)
        {
            System.out.println(e);
        }
    }
    public void run()
    {
        while(true)
        {
            try
            {                            //從鍵盤接收字符并向服務(wù)器端發(fā)送
                int ch;
                while((ch=System.in.read())!=-1)
                {
                    cout.write((byte)ch);
                    if(ch=='\n')
                        cout.flush();    //將緩沖區(qū)內(nèi)容向輸出流發(fā)送
                }
            }
            catch(Exception e)
            {
                System.out.println(e);
            }
        }
    }
}