java的BIO同步阻塞模型

朴灿烈づ我的快乐病毒、 2022-11-24 14:06 136阅读 0赞

BIO(Blocking IO) 同步阻塞模型，一个客户端连接对应一个处理线程。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N1bnl1aHVhX2tleWJvYXJk_size_16_color_FFFFFF_t_70]

java案例：

import java.io.IOException;
    import java.io.InputStream;
    import java.net.ServerSocket;
    import java.net.Socket;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    
    /** * BIO 阻塞IO * * 在JDK1.4出来之前，我们建立网络连接的时候采用BIO模式，需要先在服务端启动一个ServerSocket， * 然后在客户端启动Socket来对服务端进行通信，默认情况下服务端需要对每个请求建立一堆线程等待请求， * 而客户端发送请求后，先咨询服务端是否有线程相应，如果没有则会一直等待或者遭到拒绝请求， * 如果有的话，客户端会线程会等待请求结束后才继续执行。 * */
    public class BIOServer { 
        public static void main(String[] args) throws IOException { 
            //线程池机制
            //1、创建一个线程池
            ExecutorService executorService= Executors.newCachedThreadPool();
            ServerSocket serverSocket = new ServerSocket(6666);
            System.out.println("服务器启动了");
            while(true){ 
                Socket socket = serverSocket.accept();
                //2、如果有客户端链接，就创建一个线程，与之通讯（单独写一个方法）
                executorService.execute(()->{ 
                    System.out.println(Thread.currentThread().getName()+"当前线程");
                    handler(socket);
                });
            }
        }
    
        public static void handler(Socket socket){ 
            try { 
                byte[] bytes=new byte[1024];
                //通过socket获取输入流
                InputStream inputStream = socket.getInputStream();
                while(true){ 
                    System.out.println("线程在等待.......");
                    System.out.println(Thread.currentThread().getName()+"当前线程-----");
                    int read = inputStream.read(bytes);
                    if(read!=-1){ 
                        System.out.println(Thread.currentThread().getName()+"当前线程+++++");
                        System.out.println(new String(bytes,0,read));
                    }else { 
                        break;
                    }
                }
    
            }catch (Exception e){ 
                e.printStackTrace();
            }finally { 
                System.out.println("关闭与client的链接");
                try { 
                    socket.close();
                } catch (IOException e) { 
                    e.printStackTrace();
                }
            }
        }
    
    }

开启命令菜单，

telnet 127.0.0.1 6666

按CTRL+\] ，通过send命令发送请求，会看到线程一直被阻塞，不断的接受发来的字符。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N1bnl1aHVhX2tleWJvYXJk_size_16_color_FFFFFF_t_70 1]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N1bnl1aHVhX2tleWJvYXJk_size_16_color_FFFFFF_t_70]: /images/20221124/88e99a4b6ca449f5bcadf21f4cb0e485.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N1bnl1aHVhX2tleWJvYXJk_size_16_color_FFFFFF_t_70 1]: /images/20221124/9f663d8d186540b68dd0ceb2b4179819.png