天天看点

java的BIO同步阻塞模型

BIO(Blocking IO) 同步阻塞模型,一个客户端连接对应一个处理线程。

java的BIO同步阻塞模型

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