Netty BIO/NIO/AIO介绍

简介: Netty BIO/NIO/AIO介绍

概念介绍
1、 BIO(blocking I/O):同步阻塞IO,也即是传统的I/O。

2、 NIO (non-blocking IO): 也即是New I/O,使用它可以提供非阻塞式的高伸缩性网络。

3、AIO 即 NIO2.0, 叫做异步不阻塞的 IO。 AIO 引入异步通道的概念, 采用了 Proactor 模式, 简化了程序编写,有效的请求才启动线程, 它的特点是先由操作系统完成后才通知服务端程序启动线程去处理, 一般适用于连接。

NIO的三大神器
NIO弥补了原来的同步阻塞I/O的不足,它在标准java代码中提供了高速的 、面向块的I/O。通过定义包含数据的类,以及通过以块的形式处理这些数据,NIO不适用本机代码就可以利用低级优化, 这是与BIO的本质区别。NIO主要包含三大组件应用:Buffer缓冲区、Channel通道、多路复用器Selector。

   Buffer缓冲区

    Buffer就是一个对象,它包含一些要写入的或者要读出的数据。NIO中加入了Buffer对象,这也是体现了与传统IO的一个重要区别。在NIO中,所有的数据都是用Buffer缓冲区来处理的。在读取数据时,它是直接读到缓冲区中;再写入数据时,也是写入到缓冲区中。任何时候访问NIO数据,都是通过缓冲区进行操作。

    Buffer缓冲区实质上是一个数组,通常它是一个ByteBuffer(字节数组),当然也可以使用其他类的数组。但是一个缓冲区不仅仅是一个数组,缓冲区提供了对数据结构化访问以及维护读写位置(limit)等信息。最常用的ByteBuffer,一个ByteBuffer 提供了一组功能操作byte数组。

    ByteBuffer:字节缓冲区   

    CharBuffer:字符缓冲区       

    ShortBuffer:短整型缓冲区

    IntBuffer:整形缓冲区

    LongBuffer:长整型缓冲区

    FloatBuffer:浮点型缓冲区

    DoubleBuffer:双精度浮点型缓冲区

继承关系图:

    Channel通道

    Channel通道,它类似一个自来水管一样的模型,网络数据通过Channel读取和写入。通道与流的区别是通道是双向的。流只是一个方向的移动。而Channel可以用于读、写或者二者同时进行。

Channel主要分为两大类:用于网络读写的SelectableChannel 和用于文件操作的FileChannel。

而我们使用的ServerSocketChannel 和 SocketChannel 都是 SelectableChannel的子类。

     多路复用器Selector

    多路复用器提供了选择已经就绪的任务的能力。简单的说,Selector会不断的轮询注册​​​注册在其上的Channel,如果某个Channel上边发生了读或者写的事件,这个Channel就处于就绪状态,会被Selector轮询出来。然后通过SelectionKey可以获取就绪的Channel集合,进行I/O操作。一个多路复用器可以同时轮询多个Channel,JDK使用了epoll()代替了原来的select的实现。这就意味着只需要一个线程就可以接入成千上万的客户端。

    NIO服务端通信序列图:如下



     详解NIO客户端主要的创建过程:

1、打开ServerSocketChannel,用于监听客户端链接,它是所有客户端链接的父管道。

ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();
2、绑定需要监听的接口,设置链接模式为非阻塞模式

serverSocketChannel.socket().bind(new InetSocketAddress(InetAddress.getByName("IP"),port));
serverSocketChannel.configureBlocking(false);
3、创建Reactor线程,创建多路复用器并启动线程。

Selector selector = Selector.open();
new Thread(new ReactorTask()).start();
4、将ServerSocketChannel 注册到复用selector上

SelectionKey key = serverSocketChannel.register(selector,SelectionKey.OP_ACCEPT,ioHandler);

相关文章
|
22小时前
|
Java Linux 应用服务中间件
【编程进阶知识】高并发场景下Bio与Nio的比较及原理示意图
本文介绍了在Linux系统上使用Tomcat部署Java应用程序时,BIO(阻塞I/O)和NIO(非阻塞I/O)在网络编程中的实现和性能差异。BIO采用传统的线程模型,每个连接请求都会创建一个新线程进行处理,导致在高并发场景下存在严重的性能瓶颈,如阻塞等待和线程创建开销大等问题。而NIO则通过事件驱动机制,利用事件注册、事件轮询器和事件通知,实现了更高效的连接管理和数据传输,避免了阻塞和多级数据复制,显著提升了系统的并发处理能力。
9 0
|
2月前
|
缓存 Java UED
BIO、NIO、AIO有什么区别
【8月更文挑战第16天】BIO、NIO、AIO有什么区别
50 4
|
2月前
|
Java
"揭秘Java IO三大模式:BIO、NIO、AIO背后的秘密!为何AIO成为高并发时代的宠儿,你的选择对了吗?"
【8月更文挑战第19天】在Java的IO编程中,BIO、NIO与AIO代表了三种不同的IO处理机制。BIO采用同步阻塞模型,每个连接需单独线程处理,适用于连接少且稳定的场景。NIO引入了非阻塞性质,利用Channel、Buffer与Selector实现多路复用,提升了效率与吞吐量。AIO则是真正的异步IO,在JDK 7中引入,通过回调或Future机制在IO操作完成后通知应用,适合高并发场景。选择合适的模型对构建高效网络应用至关重要。
49 2
|
2月前
|
网络协议 C# 开发者
WPF与Socket编程的完美邂逅:打造流畅网络通信体验——从客户端到服务器端,手把手教你实现基于Socket的实时数据交换
【8月更文挑战第31天】网络通信在现代应用中至关重要,Socket编程作为其实现基础,即便在主要用于桌面应用的Windows Presentation Foundation(WPF)中也发挥着重要作用。本文通过最佳实践,详细介绍如何在WPF应用中利用Socket实现网络通信,包括创建WPF项目、设计用户界面、实现Socket通信逻辑及搭建简单服务器端的全过程。具体步骤涵盖从UI设计到前后端交互的各个环节,并附有详尽示例代码,助力WPF开发者掌握这一关键技术,拓展应用程序的功能与实用性。
84 0
|
2月前
|
存储 网络协议 Java
【Netty 神奇之旅】Java NIO 基础全解析:从零开始玩转高效网络编程!
【8月更文挑战第24天】本文介绍了Java NIO,一种非阻塞I/O模型,极大提升了Java应用程序在网络通信中的性能。核心组件包括Buffer、Channel、Selector和SocketChannel。通过示例代码展示了如何使用Java NIO进行服务器与客户端通信。此外,还介绍了基于Java NIO的高性能网络框架Netty,以及如何用Netty构建TCP服务器和客户端。熟悉这些技术和概念对于开发高并发网络应用至关重要。
56 0
|
存储 缓存 NoSQL
跟着源码学IM(十一):一套基于Netty的分布式高可用IM详细设计与实现(有源码)
本文将要分享的是如何从零实现一套基于Netty框架的分布式高可用IM系统,它将支持长连接网关管理、单聊、群聊、聊天记录查询、离线消息存储、消息推送、心跳、分布式唯一ID、红包、消息同步等功能,并且还支持集群部署。
13459 1
|
5月前
|
消息中间件 Oracle Dubbo
Netty 源码共读(一)如何阅读JDK下sun包的源码
Netty 源码共读(一)如何阅读JDK下sun包的源码
117 1
|
10月前
|
NoSQL Java Redis
跟着源码学IM(十二):基于Netty打造一款高性能的IM即时通讯程序
关于Netty网络框架的内容,前面已经讲了两个章节,但总归来说难以真正掌握,毕竟只是对其中一个个组件进行讲解,很难让诸位将其串起来形成一条线,所以本章中则会结合实战案例,对Netty进行更深层次的学习与掌握,实战案例也并不难,一个非常朴素的IM聊天程序。 原本打算做个多人斗地主练习程序,但那需要织入过多的业务逻辑,因此一方面会带来不必要的理解难度,让案例更为复杂化,另一方面代码量也会偏多,所以最终依旧选择实现基本的IM聊天程序,既简单,又能加深对Netty的理解。
149 1
|
5月前
|
编解码 前端开发 网络协议
Netty Review - ObjectEncoder对象和ObjectDecoder对象解码器的使用与源码解读
Netty Review - ObjectEncoder对象和ObjectDecoder对象解码器的使用与源码解读
109 0
|
5月前
|
编解码 安全 前端开发
Netty Review - StringEncoder字符串编码器和StringDecoder 解码器的使用与源码解读
Netty Review - StringEncoder字符串编码器和StringDecoder 解码器的使用与源码解读
193 0