static ExecutorService executorService=Executors.newFixedThreadPool(1000);

    public static void main(String[] args) {
        ServerSocket serverSocket=null;

        try {


            //服务端一定需要去监听一个端口号，ip默认就是本机的ip地址
            //ip:port
            serverSocket=new ServerSocket(8080);

            while(true) {
                //阻塞(连接阻塞）
                Socket socket = serverSocket.accept(); //接收客户端的连接（阻塞）
                executorService.execute(new SocketThread(socket));
            }
            /*//拿到输入流（阻塞， read/write阻塞）
            BufferedReader in=new BufferedReader(new InputStreamReader
                    (socket.getInputStream()));

            //输出流
            PrintWriter printWriter=new PrintWriter(socket.getOutputStream());
            //通过控制台拿到数据
            BufferedReader sin=new BufferedReader(new InputStreamReader(System.in));
            System.out.println("Client:"+in.readLine()); //获得输入流的信息
            String line=sin.readLine(); //获得控制台输入的数据
            while(!line.equals("bye")){
                printWriter.println(line); //写回到客户端
                printWriter.flush();

                System.out.println("client:"+in.readLine()); //读取客户端传过来的数据
                line=sin.readLine(); //重新读取控制台的数据
            }

            System.out.println(in.readLine()); //获得客户端的输入信息*/

        } catch (IOException e) {
            e.printStackTrace();
        }
    }

public static void main(String[] args) {
        try {
            //找到目标的ip和端口
            Socket socket=new Socket("localhost",8080);

            //在当前链接上写入输入
            PrintWriter out=new PrintWriter(socket.getOutputStream(),true);
            //控制台的输入流
            BufferedReader sin=new BufferedReader(new InputStreamReader(System.in));
            //拿到输入流
            BufferedReader in=new BufferedReader(new InputStreamReader
                    (socket.getInputStream()));

            String readline=sin.readLine(); //获得控制台的输入
            while(!readline.equals("bye")){
                out.println(readline);

                System.out.println("Server:"+in.readLine());
                readline=sin.readLine(); //重新获取
            }


        } catch (IOException e) {
            e.printStackTrace();
        }
    }