//package Socker.Socker;

import java.io.BufferedReader;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.Socket;
import java.net.UnknownHostException;

public class socketOne implements Runnable{

	/**
	 * @param args
	 */
	Socket clientSocket ;
	boolean flag = true;
	Thread c ;
	BufferedReader cin ;
	DataOutputStream cout ;
	
	public static void main(String[] args) {
		// TODO Auto-generated method stub
		new socket().ClientStart();
	}
	public void ClientStart(){
		try {
			clientSocket = new Socket("localhost",45678);
			System.out.println("已經(jīng)建立連接!!");
			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();
				String aline ;
				while((aline = cin.readLine()) != null){
					System.out.println("服務(wù)端對(duì)客戶端說：" + aline);
					if(aline.equals("byte")){
						flag = false;
						c.interrupt();
						break;
					}
				}
				cout.close();
				os.close();
				is.close();
				cin.close();
				clientSocket.close();
				System.exit(0);
			}
			
		} catch (UnknownHostException e) {
			// TODO Auto-generated catch block
			System.out.print(e.getMessage());
		} catch (IOException e) {
			// TODO Auto-generated catch block
			System.out.print(e.getMessage());
		}
	}
	public void run() {
		// TODO Auto-generated method stub
		while(true){
			try{
				int ch ;
				if((ch = System.in.read()) != -1){
					cout.write((byte)ch);
					if(ch == '\n'){
						cout.flush();
					}
				}
			}catch(IOException e){
				System.out.print(e.getMessage());
			}
		}
	}

}