BIO 就是传统的java.io
包,同步并阻塞,基于流模型实现,在读入输入流或者输出流时,在读写动作完成之前,线程会一直阻塞。
NIO 是Java 1.4引入的java.nio
包,同步非阻塞,提供了 Channel、Selector、Buffer 等新的抽象,可以构建多路复用的、同步非阻塞 IO 程序,同时提供了更接近操作系统底层高性能的数据操作方式。
AIO 是Java 1.7之后引入的包,是 NIO 的升级版本,异步非阻塞,(Asynchronous IO),异步 IO 是基于事件和回调机制实现的,也就是应用操作之后会直接返回,不会堵塞在那里,当后台处理完成,操作系统会通知相应的线程进行后续的操作。
\ | BIO | NIO | AIO |
---|---|---|---|
IO 模型 | 同步阻塞 | 同步非阻塞(多路复用) | 异步非阻塞 |
编程难度 | 简单 | 复杂 | 复杂 |
可靠性 | 差 | 好 | 好 |
吞吐量 | 低 | 高 | 高 |
Java BIO 就是传统的 java io 编程,其相关的类和接口在 java.io
。
BIO(blocking I/O) : 同步阻塞,服务器实现模式为一个连接一个线程,即客户端有连接请求时服务器端就需 要启动一个线程进行处理,如果这个连接不做任何事情会造成不必要的线程开销,可以通过线程池机制改善(实现多个客户连接服务器)。
代码如下:
public class BioServer {
public static void main(String[] args) throws IOException {
// 创建线程池
ExecutorService executorService = Executors.newCachedThreadPool();
// 创建ServerSocket
ServerSocket serverSocket = new ServerSocket(8080);
System.out.println("server start");
while (true) {
// 监听, 等待客户端连接
final Socket socket = serverSocket.accept();;
System.out.println("client connect, thread: "+ Thread.currentThread());
executorService.execute(() -> handler(socket));
}
}
// 与客户端通信
public static void handler(Socket socket) {
byte[] bytes = new byte[1024];
// 通过socket获取输入流
try (InputStream inputStream = socket.getInputStream()) {
// 循环读取客户端发送的数据
while (true) {
int read = inputStream.read(bytes);
if (read != -1) {
System.out.println("receive message: " + new String(bytes, 0 , read) + ", thread: "+ Thread.currentThread());
} else {
break;
}
}
} catch (IOException e) {
e.printStackTrace();
} finally {
System.out.println("client close, thread: "+ Thread.currentThread());
}
}
}
cmd 窗口使用 telnet 127.0.0.1 8080 创建连接,输入ctrl+],输入send
见下一篇【Java I/O】NIO 详解
JDK 7 引入了 Asynchronous I/O,即 AIO。在进行 I/O 编程中,常用到两种模式:Reactor 和 Proactor。Java 的 NIO 就是 Reactor,当有事件触发时,服务器端得到通知,进行相应的处理。
AIO 即 NIO2.0,叫做异步不阻塞的 IO。AIO 引入异步通道的概念,采用了 Proactor 模式,简化了程序编写,有效的请求才启动线程,它的特点是先由操作系统完成后才通知服务端程序启动线程去处理,一般适用于连接数较多且连接时间较长的应用。
目前 AIO 还没有广泛应用,Netty 也是基于 NIO, 而不是 AIO。
原文:https://www.cnblogs.com/haif/p/14091739.html