BIO的阻塞

public class Client {
    public static void main(String[] args) {
        Scanner se=new Scanner(System.in);
        System.out.println("请输入客户端编号：");
        int code=se.nextInt();
        System.out.println("客户端编号是："+code);
        Socket socket=null;

        try
        {
            System.out.println("客户端"+code+"开始连接服务器...");
            socket=new Socket("127.0.0.1",8888);
            if(socket!=null){
                System.out.println("客户端"+code+"连接服务器成功！");
            }
            OutputStream out= socket.getOutputStream();
            while (true){

                System.out.println("客户端"+code+"请输入要发送的内容：");
               String str=se.next();
               if(str.trim().equalsIgnoreCase("quit"))
                   break;
               out.write((code+"--->"+str).getBytes("utf-8"));
            }
            out.close();
            socket.close();


        }catch (Exception ex){
            ex.printStackTrace();
        }

    }

public class Server {
    private static  int port=8888;
    public static void main(String[] args) throws IOException {

        ServerSocket serverSocket=null;
                try{
                    serverSocket=new ServerSocket(port);
                    System.out.println("服务端开始监听："+port);
                    while (true){
                     var clientSocket= serverSocket.accept();//第一处阻塞
                        System.out.println("接受一个客户端请求");
                        InputStream in=clientSocket.getInputStream();
                        int hasread=0;
                        byte[] bufer=new byte[1024];
                        while ((hasread=in.read(bufer))!=-1){//第二处阻塞
                            System.out.println("客户端输入字符："+new String(bufer,0,hasread));
                        }
                        clientSocket.close();
                        in.close();
                    }

                }
                catch (Exception ex){
                    ex.printStackTrace();
                }finally {
                    try {
                        serverSocket.close();
                    } catch (IOException e) {
                        e.printStackTrace();
                    }

                }
    }