test暂时

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;

public class clint extends Thread{
    Socket socket = null;
    //ServerSocket serverSocket = null;
    
    clint(int port,String IP){
        try {
            //this.serverSocket = new ServerSocket(port);
            this.socket = new Socket(IP,port);
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
    
    @Override
    public void run() {
        // TODO Auto-generated method stub
        //super.run();
        //System.out.println("等待连接");
        try {
            //System.out.println("等待连接");
            //socket = serverSocket.accept();
            new Thread(new SendMassage()).start();
            InputStream in = socket.getInputStream();
            byte[] b = new byte[1024];
            int i=0;
            while((i=in.read(b))!=-1){
                System.out.println(b.toString());
            }
            in.close();
        } catch (IOException e) {
            // TODO: handle exception
            e.printStackTrace();
        }
        //socket = serverSocket.accept();
    }
        
    class SendMassage extends Thread{
        @Override
        public void run() {
            // TODO Auto-generated method stub
            super.run();
            try {
                OutputStream outputStream = socket.getOutputStream();
                Scanner scanner = new Scanner(System.in);
                String massageString = "";
                while(massageString!="bye"){
                    massageString = scanner.nextLine();
                    outputStream.write(massageString.getBytes());
                    outputStream.flush();
                }
                outputStream.close();
                scanner.close();
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            
        }
    }

     public static void main(String[] arg){
         clint testclint = new clint(8888,"192.168.49.69");
         testclint.start();
     }

}