netty中的IO、NIO、AIO使用詳解
更新時(shí)間：2023年12月21日 10:44:58 作者：Colins~
這篇文章主要介紹了netty中的IO、NIO、AIO使用詳解,本文會(huì)說(shuō)明各種IO的特點(diǎn)、分別解決了什么樣的問(wèn)題做一個(gè)分析闡述,并結(jié)合Java代碼例子來(lái)輔助理解,像這些的歷史演進(jìn)和詳細(xì)的底層原理網(wǎng)上很多,所以我們只站在應(yīng)用層,使用者的角度去分析,需要的朋友可以參考下
BIO——同步阻塞IO
看這個(gè)名稱(chēng)大家可能會(huì)有點(diǎn)陌生，我們直接上例子：
服務(wù)端：
public static void main(String[] args) throws IOException {
//1.創(chuàng)建服務(wù)端Socket 并綁定端口
ServerSocket serverSocket = new ServerSocket(8080);
//2.等待客戶(hù)端連接 阻塞的
Socket accept = serverSocket.accept();
System.out.println(accept.getRemoteSocketAddress() + " 客戶(hù)端已連接");
//3.獲取輸入、輸出流
InputStream inputStream = accept.getInputStream();
OutputStream outputStream = accept.getOutputStream();
//4.接收客戶(hù)端信息
byte[] bytes = new byte[1024];
inputStream.read(bytes);
String data = new String(bytes);
System.out.println("來(lái)自" + accept.getRemoteSocketAddress() + "的信息：" + data);
//5.返回信息
outputStream.write(data.getBytes());
accept.shutdownOutput();
//6.關(guān)閉資源
inputStream.close();
outputStream.close();
accept.close();
serverSocket.close();
}客戶(hù)端：
public static void main(String[] args) throws IOException {
//1.創(chuàng)建客戶(hù)端Socket
Socket socket = new Socket("127.0.0.1",8080);
//2.獲取輸入、輸出流
InputStream inputStream = socket.getInputStream();
OutputStream outputStream = socket.getOutputStream();
//3.給服務(wù)端發(fā)送信息
outputStream.write("你好".getBytes());
socket.shutdownOutput();
//4.獲取服務(wù)端返回信息
byte[] data = new byte[1024];
inputStream.read(data);
System.out.println("來(lái)自服務(wù)端的信息：" + new String(data));
//6.關(guān)閉資源
inputStream.close();
outputStream.close();
socket.close();
}這就是我們熟知的Socket連接，也是Java最早的網(wǎng)絡(luò)通信IO，為什么這種叫同步阻塞IO：
因?yàn)樵谧鰎ead操作、accept操作的時(shí)候會(huì)阻塞沒(méi)法往下執(zhí)行，說(shuō)白了就是串行的，就因?yàn)檫@個(gè)服務(wù)端和客戶(hù)端只能1對(duì)1通信，這合理嘛？肯定不合理啊，所以進(jìn)階的有了偽異步IO
偽異步阻塞IO
看完上面的，很多人就有想法了，你說(shuō)同步的只能1對(duì)1通信，那我直接把服務(wù)端改成多線(xiàn)程版本不就好了嘛，不就可以1對(duì)多通信了嘛，沒(méi)錯(cuò)這版本確實(shí)是這樣，如下：
服務(wù)端：
public static void main(String[] args) throws IOException {
//1.創(chuàng)建服務(wù)端Socket 并綁定端口
ServerSocket serverSocket = new ServerSocket(8080);
//2.等待客戶(hù)端連接 多線(xiàn)程模式 (開(kāi)線(xiàn)程異步等待)
new Thread(()->{
while (true){
try {
Socket accept = serverSocket.accept();
System.out.println(accept.getRemoteSocketAddress() + " 客戶(hù)端已連接");
// 開(kāi)線(xiàn)程異步處理客戶(hù)端連接任務(wù)
new Thread(new AcceptHandler(accept)).start();
} catch (IOException e) {
e.printStackTrace();
}
}
}).start();
// 阻塞防止程序退出
while (true){}
}
private static class AcceptHandler implements Runnable{
private Socket accept;
private InputStream inputStream = null;
private OutputStream outputStream =null;
public AcceptHandler(Socket accept){
this.accept=accept;
}
@Override
public void run() {
try {
//3.獲取輸入、輸出流
inputStream = accept.getInputStream();
outputStream = accept.getOutputStream();
//4.接收客戶(hù)端信息
byte[] bytes = new byte[1024];
inputStream.read(bytes);
String data = new String(bytes);
if(data!=null){
System.out.println("來(lái)自" + accept.getRemoteSocketAddress() + "的信息：" + data);
//5.返回信息
outputStream.write(data.getBytes());
accept.shutdownOutput();
}
} catch (IOException e) {
System.out.println(accept.getRemoteSocketAddress() + "發(fā)送異常斷開(kāi)連接");
closeSource();
}finally {
System.out.println(accept.getRemoteSocketAddress() + "斷開(kāi)連接");
closeSource();
}
}
private void closeSource(){
//6.關(guān)閉資源
try {
if(inputStream!=null){inputStream.close();}
if(outputStream!=null){outputStream.close();}
accept.close();
} catch (IOException ioException) {
ioException.printStackTrace();
}
}
}客戶(hù)端不變，服務(wù)端我們做了三個(gè)改動(dòng)：
一：在等待客戶(hù)端連接的時(shí)候我們開(kāi)啟一個(gè)線(xiàn)程，并死循環(huán)等待連接，這樣可以保證不阻塞主線(xiàn)程的運(yùn)行，同時(shí)可以不斷的和客戶(hù)端建立連接
二：和客戶(hù)端建立連接后又開(kāi)啟一個(gè)線(xiàn)程來(lái)單獨(dú)處理與客戶(hù)端的通信
三：最后加了個(gè)死循環(huán)防止程序退出，因?yàn)楝F(xiàn)在是異步的了
這樣處理不就是異步的了嗎？為什么叫偽異步阻塞IO呢？
雖然現(xiàn)在不會(huì)阻塞主線(xiàn)程了，但是阻塞并沒(méi)有解決，該阻塞的地方依舊還是會(huì)阻塞，所以本質(zhì)上來(lái)說(shuō)只是解決了1對(duì)1連接通信的問(wèn)題
但是新的問(wèn)題又來(lái)了，現(xiàn)在雖然是1對(duì)多通信，但是有一個(gè)客戶(hù)端連接就新建一個(gè)線(xiàn)程，1萬(wàn)個(gè)客戶(hù)端就1萬(wàn)個(gè)線(xiàn)程，這合理嗎？這明顯不合理啊，用線(xiàn)程池管理？那也不行啊，這連接一多還要排隊(duì)嗎？極端情況下，隊(duì)列不一樣會(huì)爆？
那怎么辦？有沒(méi)有可能一個(gè)線(xiàn)程監(jiān)聽(tīng)多個(gè)連接呢？于是有了NIO
NIO——同步非阻塞IO
NIO的引入同時(shí)引入了三個(gè)概念ByteBuffer緩沖區(qū)、Channel通道和Selector多路復(fù)用器
- Channel的作用：就是一個(gè)通道，數(shù)據(jù)讀取和寫(xiě)入的通道，根據(jù)功能可以分為不同的通道如：網(wǎng)絡(luò)通道ServerSocketChannel和SocketChannel、文件操作通道FileChannel等等
- Selector的作用：是輪詢(xún)Channel上面的事件，如讀事件、寫(xiě)事件、連接事件、接受連接事件
- ByteBuffer緩沖區(qū)：就是向Channel讀取或?qū)懭霐?shù)據(jù)的對(duì)象，本質(zhì)就是個(gè)字節(jié)數(shù)組
怎么理解這三個(gè)呢？說(shuō)白了以傳統(tǒng)IO為例：服務(wù)端accept就是接受連接事件、客戶(hù)端connect就是連接事件、發(fā)送消息就是寫(xiě)事件、讀取消息就是讀事件 Selector就是監(jiān)聽(tīng)這些事件的工具 ServerSocketChannel是服務(wù)端接受連接的通道，所以只能注冊(cè)監(jiān)聽(tīng)連接事件 SocketChannel是服務(wù)端與客戶(hù)端連接建立后的通道，所以可以注冊(cè)讀寫(xiě)事件、連接事件 ByteBuffer就是Channel讀取或?qū)懭霐?shù)據(jù)的單位對(duì)象
下面搞個(gè)例子看看，注釋全有：
服務(wù)端：
public static void main(String[] args) throws IOException {
// 開(kāi)啟服務(wù)端Socket通道
ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();
// 設(shè)置為非阻塞
serverSocketChannel.configureBlocking(false);
// 綁定端口
serverSocketChannel.socket().bind(new InetSocketAddress(8080));
// 打開(kāi)多路復(fù)用器 并將其注冊(cè)到通道上 監(jiān)聽(tīng)連接請(qǐng)求事件
Selector selector = Selector.open();
// 為服務(wù)端Socket通道 注冊(cè)一個(gè)接受連接的事件
// 假設(shè)有客戶(hù)端要連接 下面輪詢(xún)的時(shí)候就會(huì)觸發(fā)這個(gè)事件 我們就可以去與客戶(hù)端建立連接了
serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);
while (true) {
// 這段時(shí)間沒(méi)獲取到任何事件，則跳過(guò)下面操作
// 不同于IO和BIO的阻塞 多路復(fù)用器會(huì)一直輪詢(xún) 如果長(zhǎng)時(shí)間無(wú)事件 這里會(huì)一直空循環(huán)
// 所以這里在查詢(xún)事件的時(shí)候加了個(gè)時(shí)間 這樣無(wú)事件的情況下 1s才會(huì)循環(huán)一次
if (selector.select(1000) == 0) {
continue;
}
// 獲取到本次輪詢(xún)所獲取到的全部事件
Iterator<SelectionKey> selectorKeys = selector.selectedKeys().iterator();
// 輪詢(xún)獲取到的事件，并處理
while (selectorKeys.hasNext()) {
SelectionKey selectorKey = selectorKeys.next();
//這個(gè)已經(jīng)處理的事件Key一定要移除。如果不移除，就會(huì)一直存在在selector.selectedKeys集合中
//待到下一次selector.select() > 0時(shí)，這個(gè)Key又會(huì)被處理一次
selectorKeys.remove();
try {
// 事件key處理 也就是事件處理
selectorKeyHandler(selectorKey, selector);
} catch (Exception e) {
SocketChannel channel = (SocketChannel) selectorKey.channel();
System.out.println(channel.getRemoteAddress() + "客戶(hù)端已斷開(kāi)連接");
if (selectorKey != null) {
selectorKey.cancel();
if (selectorKey.channel() != null) {
selectorKey.channel().close();
}
}
}
}
}
}
// 事件處理方法 按照事件類(lèi)型處理不同的事件
public static void selectorKeyHandler(SelectionKey selectorKey, Selector selector) throws IOException {
// 連接事件 代表有客戶(hù)端連接 所以需要去處理這個(gè)連接請(qǐng)求
if (selectorKey.isAcceptable()) {
acceptHandler(selectorKey, selector);
}
// 讀事件 可以去讀取信息
if (selectorKey.isReadable()) {
readHandler(selectorKey, selector);
}
// 寫(xiě)事件 可以向客戶(hù)端發(fā)送信息
if (selectorKey.isWritable()) {
SocketChannel socketChannel = (SocketChannel) selectorKey.channel();
writeHandler(socketChannel);
// 寫(xiě)事件完成后要取消寫(xiě)事件不然會(huì)一直寫(xiě) 我這里就干脆注冊(cè)了個(gè)讀事件
socketChannel.register(selector,SelectionKey.OP_READ);
}
}
// 連接事件處理 這個(gè)有客戶(hù)端要建立連接了 所以accept與客戶(hù)端建立連接
public static void acceptHandler(SelectionKey selectorKey, Selector selector) throws IOException {
ServerSocketChannel channel = (ServerSocketChannel) selectorKey.channel();
SocketChannel accept = channel.accept();
// 建立連接后 客戶(hù)端和服務(wù)端就等于形成了一個(gè)數(shù)據(jù)交互的通道 SocketChannel
// 這個(gè)通道也要設(shè)置為非阻塞
accept.configureBlocking(false);
// 為這個(gè)通道注冊(cè)一個(gè)讀事件 表示我先讀取客戶(hù)端信息
accept.register(selector, SelectionKey.OP_READ);
System.out.println(accept.getRemoteAddress() + "客戶(hù)端已連接");
}
// 讀事件處理 讀取客戶(hù)端的信息
public static void readHandler(SelectionKey selectorKey, Selector selector) throws IOException {
SocketChannel channel = (SocketChannel) selectorKey.channel();
ByteBuffer allocate = ByteBuffer.allocate(1024);
int read = channel.read(allocate);
if (read > 0) {
allocate.flip();
byte[] bytes = new byte[allocate.remaining()];
allocate.get(bytes);
System.out.println(channel.getRemoteAddress() + "發(fā)來(lái)消息：" + new String(bytes));
}
if(read<0){
System.out.println(channel.getRemoteAddress() + "斷開(kāi)連接");
}
// 讀完信息后要給客戶(hù)端發(fā)送信息 所以這個(gè)再注冊(cè)一個(gè)寫(xiě)的事件
channel.register(selector, SelectionKey.OP_WRITE);
}
// 寫(xiě)事件處理
public static void writeHandler(SocketChannel socketChannel) throws IOException {
byte[] bytes = "你好".getBytes();
ByteBuffer allocate = ByteBuffer.allocate(bytes.length);
allocate.put(bytes);
allocate.flip();
socketChannel.write(allocate);
}客戶(hù)端：
public static void main(String[] args) throws IOException {
// 開(kāi)啟一個(gè)Socket通道
SocketChannel clientChannel = SocketChannel.open();
// 設(shè)置非阻塞
clientChannel.configureBlocking(false);
// 允許端口復(fù)用
clientChannel.socket().setReuseAddress(true);
// 連接地址
clientChannel.connect(new InetSocketAddress("127.0.0.1", 8080));
// 開(kāi)啟多路復(fù)用器
Selector selector = Selector.open();
// 為這個(gè)通道注冊(cè)一個(gè)連接事件
clientChannel.register(selector, SelectionKey.OP_CONNECT);
while (true) {
// 這段時(shí)間沒(méi)獲取到任何事件，則跳過(guò)下面操作
// 不同于IO和BIO的阻塞 多路復(fù)用器會(huì)一直輪詢(xún) 如果長(zhǎng)時(shí)間無(wú)事件 這里會(huì)一直空循環(huán)
// 所以這里在查詢(xún)事件的時(shí)候加了個(gè)時(shí)間 這樣無(wú)事件的情況下 1s才會(huì)循環(huán)一次
if (selector.select(1000) == 0) {
continue;
}
// 獲取到本次輪詢(xún)所獲取到的全部事件
Iterator<SelectionKey> selectorKeys = selector.selectedKeys().iterator();
// 輪詢(xún)獲取到的事件，并處理
while (selectorKeys.hasNext()) {
SelectionKey selectorKey = selectorKeys.next();
//這個(gè)已經(jīng)處理的事件Key一定要移除。如果不移除，就會(huì)一直存在在selector.selectedKeys集合中
//待到下一次selector.select() > 0時(shí)，這個(gè)Key又會(huì)被處理一次
selectorKeys.remove();
try {
// 事件key處理
selectorKeyHandler(selectorKey, selector);
} catch (Exception e) {
if (selectorKey != null) {
selectorKey.cancel();
if (selectorKey.channel() != null) {
selectorKey.channel().close();
}
}
}
}
}
}
// 事件處理方法
public static void selectorKeyHandler(SelectionKey selectorKey, Selector selector) throws IOException {
// 連接事件 判斷是否連接成功
if (selectorKey.isValid()) {
SocketChannel channel = (SocketChannel) selectorKey.channel();
if (selectorKey.isConnectable() && channel.finishConnect()) {
System.out.println("連接成功........");
// 連接成功注冊(cè)寫(xiě)事件 向服務(wù)端發(fā)送信息
channel.register(selector,SelectionKey.OP_WRITE);
}
}
// 讀事件 可以去讀取信息
if (selectorKey.isReadable()) {
readHandler(selectorKey, selector);
}
// 寫(xiě)事件 可以向客戶(hù)端發(fā)送信息
if (selectorKey.isWritable()) {
SocketChannel channel = (SocketChannel) selectorKey.channel();
writeHandler(channel);
// 寫(xiě)事件完成后要取消寫(xiě)事件不然會(huì)一直寫(xiě) 我這里就干脆注冊(cè)了個(gè)讀事件
channel.register(selector,SelectionKey.OP_READ);
}
}
// 讀事件處理 就是處理服務(wù)端發(fā)來(lái)的消息
public static void readHandler(SelectionKey selectorKey, Selector selector) throws IOException {
SocketChannel channel = (SocketChannel) selectorKey.channel();
ByteBuffer allocate = ByteBuffer.allocate(1024);
int read = channel.read(allocate);
if (read > 0) {
allocate.flip();
byte[] bytes = new byte[allocate.remaining()];
allocate.get(bytes);
System.out.println("服務(wù)端發(fā)來(lái)消息：" + new String(bytes));
}
if(read<0){
System.out.println("與服務(wù)端斷開(kāi)連接");
}
}
// 寫(xiě)事件處理 就是像服務(wù)端發(fā)送消息
public static void writeHandler(SocketChannel socketChannel) throws IOException {
byte[] bytes = "你好".getBytes();
ByteBuffer allocate = ByteBuffer.allocate(bytes.length);
allocate.put(bytes);
allocate.flip();
socketChannel.write(allocate);
}可以看到寫(xiě)法和傳統(tǒng)的IO完全不一樣了，操作的對(duì)象都是Channel，讀寫(xiě)對(duì)象都是ByteBuffer，那到底是什么引起了這種改變呢？因?yàn)橄到y(tǒng)內(nèi)核的優(yōu)化，說(shuō)白了這種操作都是API，底層都是需要系統(tǒng)支持的，系統(tǒng)在這塊也有一個(gè)模型優(yōu)化，簡(jiǎn)單介紹三種模型區(qū)別：
- select： 每有一個(gè)連接的產(chǎn)生會(huì)打開(kāi)一個(gè)Socket描述符(下面簡(jiǎn)稱(chēng)FD)，select會(huì)把這些FD保存在一個(gè)數(shù)組中，因?yàn)槭菙?shù)組所以就代表有了容量的上限意味了連接數(shù)量的上限，每次調(diào)用，都會(huì)遍歷這個(gè)數(shù)組，1w個(gè)連接就算只有一個(gè)事件，也會(huì)遍歷這1w個(gè)連接，效率極低
- poll： 和select不同，這個(gè)底層結(jié)構(gòu)是鏈表，所有沒(méi)了連接數(shù)量的上限，但是每次調(diào)用依舊會(huì)遍歷所有的
- epoll： 底層結(jié)構(gòu)是紅黑樹(shù)，同樣沒(méi)有連接數(shù)量的上限，而且有一個(gè)就緒的事件列表，這意味著不再需要遍歷所有的連接了
JDK中采用的就是epoll模型，但盡管這樣也依舊是同步的，因?yàn)檫€是需要主動(dòng)去獲取結(jié)果，只是從方式阻塞等待變成了輪詢(xún)，有沒(méi)有什么方式在結(jié)果產(chǎn)生的時(shí)候異步的回調(diào)呢？于是有了AIO
AIO——異步IO
這種方式同樣需要系統(tǒng)的支持，目前主流還是NIO，這塊就不多介紹了，提供個(gè)例子：
服務(wù)端：
public static void main(String[] args) throws IOException {
AsynchronousServerSocketChannel serverSocketChannel = AsynchronousServerSocketChannel.open();
serverSocketChannel.bind(new InetSocketAddress(8080));
// 接收連接的時(shí)候 提供連接處理類(lèi)
serverSocketChannel.accept(serverSocketChannel, new ServerSocketHandler());
// 異步的 防止程序退出
while (true) {
}
}
// 連接處理
public static class ServerSocketHandler implements CompletionHandler<AsynchronousSocketChannel, AsynchronousServerSocketChannel> {
@Override
public void completed(AsynchronousSocketChannel result, AsynchronousServerSocketChannel attachment) {
// 繼續(xù)接受連接
attachment.accept(attachment, this);
try {
System.out.println(result.getRemoteAddress() + " 已連接");
} catch (IOException e) {
e.printStackTrace();
}
new Thread(() -> {
// 異步讀
readHandler(result);
}).start();
// 寫(xiě)數(shù)據(jù)處理
writeHandler(result, "你好");
}
@Override
public void failed(Throwable exc, AsynchronousServerSocketChannel attachment) {
System.out.println("發(fā)生異常");
}
public void readHandler(AsynchronousSocketChannel socketChannel) {
ByteBuffer allocate = ByteBuffer.allocate(1024);
socketChannel.read(allocate, allocate, new CompletionHandler<Integer, ByteBuffer>() {
@Override
public void completed(Integer result, ByteBuffer attachment) {
try {
if (result > 0) {
attachment.flip();
byte[] bytes = new byte[attachment.remaining()];
attachment.get(bytes);
System.out.println(socketChannel.getRemoteAddress() + " 客戶(hù)端消息: " + new String(bytes));
readHandler(socketChannel);
}
} catch (IOException e) {
e.printStackTrace();
}
}
@Override
public void failed(Throwable exc, ByteBuffer attachment) {
System.out.println();
try {
System.out.println(socketChannel.getRemoteAddress() + " 已下線(xiàn)");
socketChannel.close();
} catch (IOException e) {
e.printStackTrace();
}
}
});
}
public void writeHandler(AsynchronousSocketChannel socketChannel, String data) {
byte[] bytes = data.getBytes();
ByteBuffer allocate = ByteBuffer.allocate(bytes.length);
allocate.put(bytes);
allocate.flip();
socketChannel.write(allocate, allocate, new CompletionHandler<Integer, ByteBuffer>() {
@Override
public void completed(Integer result, ByteBuffer attachment) {
if (attachment.hasRemaining()) {
socketChannel.write(attachment, attachment, this);
}
}
@Override
public void failed(Throwable exc, ByteBuffer attachment) {
try {
socketChannel.close();
} catch (IOException e) {
e.printStackTrace();
}
}
});
}
}客戶(hù)端：
public static void main(String[] args) throws IOException {
AsynchronousSocketChannel socketChannel=AsynchronousSocketChannel.open();
socketChannel.connect(new InetSocketAddress("127.0.0.1", 8080), null, new AsyncClientHandler(socketChannel));
while (true){}
}
public static class AsyncClientHandler implements CompletionHandler<Void, AsyncClientHandler>{
private AsynchronousSocketChannel socketChannel;
public AsyncClientHandler(AsynchronousSocketChannel socketChannel){
this.socketChannel=socketChannel;
}
@Override
public void completed(Void result, AsyncClientHandler attachment) {
new Thread(()->{
// 異步 一秒發(fā)送一次消息
while (true){
writeHandler("你好");
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}).start();
// 讀處理
readHandler();
}
@Override
public void failed(Throwable exc, AsyncClientHandler attachment) {
}
public void readHandler() {
ByteBuffer allocate = ByteBuffer.allocate(1024);
socketChannel.read(allocate, allocate, new CompletionHandler<Integer, ByteBuffer>() {
@Override
public void completed(Integer result, ByteBuffer attachment) {
attachment.flip();
byte[] bytes = new byte[attachment.remaining()];
attachment.get(bytes);
System.out.println(" 服務(wù)端消息: " + new String(bytes));
}
@Override
public void failed(Throwable exc, ByteBuffer attachment) {
try {
socketChannel.close();
} catch (IOException e) {
e.printStackTrace();
}
}
});
}
public void writeHandler( String data) {
byte[] bytes = data.getBytes();
ByteBuffer allocate = ByteBuffer.allocate(bytes.length);
allocate.put(bytes);
allocate.flip();
socketChannel.write(allocate, allocate, new CompletionHandler<Integer, ByteBuffer>() {
@Override
public void completed(Integer result, ByteBuffer attachment) {
if (attachment.hasRemaining()) {
socketChannel.write(attachment, attachment, this);
}
}
@Override
public void failed(Throwable exc, ByteBuffer attachment) {
try {
socketChannel.close();
} catch (IOException e) {
e.printStackTrace();
}
}
});
}
}總結(jié)
| BIO | 偽異步IO | NIO | AIO | |
| 線(xiàn)程:客戶(hù)端 | 1:1 | N:M (M可以大于N) | 1:N (一個(gè)線(xiàn)程處理多個(gè)) | 0:M (無(wú)需額外線(xiàn)程,異步回調(diào)) |
| I/O類(lèi)型 | 同步阻塞 | 偽異步阻塞 | 同步非阻塞 | 異步非阻塞 |
| 可靠性 | 非常差 | 差 | 高 | 高 |
| 難度 | 簡(jiǎn)單 | 簡(jiǎn)單 | 復(fù)雜 | 復(fù)雜 |
| 性能 | 低 | 中 | 高 | 高 |
到此這篇關(guān)于netty中的IO、NIO、AIO使用詳解的文章就介紹到這了,更多相關(guān)netty的IO、NIO、AIO內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
這篇文章主要介紹了Spring IOC 容器啟動(dòng)流程分析,本文給大家介紹的非常詳細(xì)，具有一定的參考借鑒價(jià)值，需要的朋友可以參考下2019-08-08
Springboot分模塊項(xiàng)目搭建的實(shí)現(xiàn)
在軟件開(kāi)發(fā)中,利用Spring?Boot進(jìn)行分模塊項(xiàng)目搭建能夠提高代碼的模塊化和復(fù)用性,本文主要介紹了Springboot分模塊項(xiàng)目搭建的實(shí)現(xiàn),感興趣的可以了解一下2024-10-10
Java inputstream和outputstream使用詳解
這篇文章主要介紹了Java inputstream和outputstream使用詳解,本篇文章通過(guò)簡(jiǎn)要的案例,講解了該項(xiàng)技術(shù)的了解與使用,以下就是詳細(xì)內(nèi)容,需要的朋友可以參考下2021-08-08
這篇文章主要介紹了Java注解詳細(xì)介紹,本文講解了Java注解是什么、Java注解基礎(chǔ)知識(shí)、Java注解類(lèi)型、定義Java注解類(lèi)型的注意事項(xiàng)等內(nèi)容,需要的朋友可以參考下2021-07-07
下面小編就為大家?guī)?lái)一篇SpringMvc入門(mén)指南(必看)。小編覺(jué)得挺不錯(cuò)的，現(xiàn)在就分享給大家，也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧2016-06-06
這篇文章主要為大家詳細(xì)介紹了java設(shè)計(jì)模式之適配器模式，介紹了什么是適配器模式，適配器模式的種類(lèi)，感興趣的小伙伴們可以參考一下2016-08-08
解決springboot文件配置端口不起作用(默認(rèn)8080)
這篇文章主要介紹了解決springboot文件配置端口不起作用(默認(rèn)8080)，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2021-08-08
Java函數(shù)式編程(三)：列表的轉(zhuǎn)化
這篇文章主要介紹了Java函數(shù)式編程(二)：列表的轉(zhuǎn)化,lambda表達(dá)式不僅能幫助我們遍歷集合,并且可以進(jìn)行集合的轉(zhuǎn)化,需要的朋友可以參考下2014-09-09
通過(guò)實(shí)例講解springboot整合WebSocket
這篇文章主要介紹了通過(guò)實(shí)例講解springboot整合WebSocket，WebSocket為游覽器和服務(wù)器提供了雙工異步通信的功能，即游覽器可以向服務(wù)器發(fā)送消息，服務(wù)器也可以向游覽器發(fā)送消息。,需要的朋友可以參考下2019-06-06
這篇文章主要為大家詳細(xì)介紹了java生成驗(yàn)證碼工具類(lèi)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2018-03-03