BIO(Blocking IO) 同步阻塞模型,一个客户端连接对应一个处理线程。
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