import *;
import *;

public class client2 {
    public static void main(String args[]){
        try {
        Socket s = new Socket("127.0.0.1", 6666);
        Runnable userInput = new keyboardIn(s);
        Runnable serverInput = new serverIn(s);
        Thread t1 = new Thread(userInput);
        Thread t2 = new Thread(serverInput);
        t1.start();
        t2.start();
        //s.close();
        }
        catch(Exception e){
            e.printStackTrace();
        }
    }
}

class keyboardIn implements Runnable {
    Socket s;
    public keyboardIn(Socket s) {
        this.s = s;
    }

    public void run() {
        try {
            BufferedReader input = new BufferedReader(new InputStreamReader(System.in));
            PrintWriter out = new PrintWriter(s.getOutputStream(),true);
            String line = null;
            while((line = input.readLine()) != null){
                out.println(line);
                if("exit".equals(line)){
                    break;
                }
            }
        }catch(IOException e){
            e.printStackTrace();
        }
    }
}

class serverIn implements Runnable {
    Socket s;
    public serverIn(Socket s) {
        this.s = s;
    }
   
    public void run() {
        try {
        BufferedReader bufr = new BufferedReader(new InputStreamReader(s.getInputStream()));
        String line = null;
        while((line = bufr.readLine()) != null){
            System.out.println("督昢傷ㄩ"+line);
            }
        }catch(IOException e){
            e.printStackTrace();
        }
    }