package j2;

import java.io.BufferedReader;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.Socket;
import java.net.UnknownHostException;
public class ThreadEchoClient implements Runnable {
    BufferedReader isbr = null;
    Thread thread = null;
    public ThreadEchoClient(Socket socket) {
	try {
	    isbr = new BufferedReader(new InputStreamReader(socket.getInputStream()));
	} catch (IOException e) {
	    e.printStackTrace();
	}
	thread = new Thread(this);
	thread.start();
    }
	
    @Override
    public void run() {
	// サーバーからのメッセージを受け取り画面に表示します
	String line;
	try {
	    while ((line = isbr.readLine()) != null) {
		System.out.println("Server: " + line);
		if (line.equals("quit")) break;
	    }
	} catch (IOException e) {
	    e.printStackTrace();
	} finally {
	    System.exit(0);
	}
    }

    public static void main(String[] args) {
	// ソケットや入出力用のストリームの宣言
	Socket socket = null;
	DataOutputStream dos = null;
	BufferedReader stdinbr = null;

	// ポート9999番を開く
	String host = "localhost";
	try {
	    socket = new Socket(host, 9999);
	    dos = new DataOutputStream(socket.getOutputStream());
	    stdinbr = new BufferedReader(new InputStreamReader(System.in));
	} catch (UnknownHostException e) {
	    System.err.println("Don't know about host: "+host);
	} catch (IOException e) {
	    System.err.println("Couldn't get I/O for the connection to: "+host);
	}

	// サーバーにメッセージを送る
	if (socket != null && dos != null ) {
	    new ThreadEchoClient(socket);
	    try {
		// メッセージを送ります
		dos.writeBytes("HELLO\n");
		dos.writeBytes("type quit to disconnect\n");

		// 標準入力（キーボード）からのメッセージを送信します
		while (true) {
		    String s = stdinbr.readLine();
		    dos.writeBytes(s+"\n");
		}

	    } catch (UnknownHostException e) {
		System.err.println("Trying to connect to unknown host: " + e);
	    } catch (IOException e) {
		System.err.println("IOException: " + e);
	    }
	}
    }
}