package day15;

import java.io.*;
import java.net.*;

/**
 * 簡易聊天器
 * @author Gunbuster
 *
 */
public class TCPClientD {

	
	public static void main(String[] args) {
		Socket s=null;
		PrintStream ps=null;
		BufferedReader brin=null;
		
		try {
			s=new Socket("127.0.0.1",8888);
			ps=new PrintStream(s.getOutputStream());
			brin=new BufferedReader(new InputStreamReader(s.getInputStream()));
			BufferedReader br=new BufferedReader(new InputStreamReader(System.in));
			Thread t=new ReadThread(brin);
			t.setDaemon(true);//當所有非服務線程結束時 該服務線程也結束了
			t.start();
			while (true) {
				System.out.println("請輸入發往服務器的內容:");

				String str = br.readLine();
				ps.println(str);
				ps.flush();
				if(str.equals("quit"))
                 break;
				System.out.println("服務器端發回的數據為:" + brin.readLine());
			}
		} catch (IOException e) {
			
			e.printStackTrace();
		} finally {
			if (ps != null)
				ps.close();
			if (s != null)
				try {
					s.close();
				} catch (IOException e) {

					e.printStackTrace();
				}
		}
	}

	

}


class ReadThread extends Thread{
	BufferedReader br;
	public ReadThread(BufferedReader br){
		this.br=br;
	}
	public void run(){
		while(true){
		try {
			System.out.println(br.readLine());
		} catch (IOException e) {
			
			e.printStackTrace();
		}	
		}
	}
}