Netty: NIO网络编程

devtools/2024/9/24 23:24:35/

文章目录

  • 一、NIO介绍
  • 二、NIO原理
  • 三、Buffer
    • 1、Buffer原理介绍
    • 2、Buffer实现类
    • 3、示例
    • 4、NIO和BIO的比较
  • 四、Channel
    • 1、介绍
    • 2、FileChannel介绍
    • 3、Buffer和Channel的注意事项
  • 五、Selector
  • 六、Selector、Channel和Buffer关系

一、NIO介绍

NIO介绍

二、NIO原理

  • NIO有三大核心部分： 通道（Channel）、缓冲区（Buffer）和选择器（Selector）。Channel是对原I/O体系中流的模拟，可以通过Channel完成数据的读/写操作；Buffer则用于存储数据，它是NIO与普通I/O的主要区别之一；而Selector则用于监听多个Channel的状态，以实现多路复用。

  • 在NIO的工作过程中，数据首先从Channel读取到Buffer中，或者从Buffer写入到Channel中。这个过程是异步的，因此不会阻塞线程。同时，Selector会不断地轮询注册的Channel，查看是否有已经就绪的I/O操作（例如读或写），如果有，就通知相应的线程进行处理。

  • Java NIO的非阻塞模式，是一个线程从某通道发送请求或者读取数据，但是它仅能得到目前可用的数据，如果目前没有数据可用时，就什么都不会获取，而不是保持线程阻塞，所以知道数据变的可以读取之前，该线程可以继续做其他的事情。非阻塞写也是如此，一个线程请求写入一些数据到某通道，但不需要等待它完全写入，这个线程同时可以去做别的事情。

  • 通俗理解：NIO是可以做到用一个线程来处理多个操作的。假设有10000个请求过来，根据实际情况，可以分配50或100个线程来处理。不像之前的阻塞 IO那样，非得分配10000个线程。

  • HTT2.0使用了多路复用的技术，做到同一个链接并发处理多个请求，而且并发请求的数量比HTTP1.1大了好几个数量级。

总的来说，NIO通过非阻塞I/O操作和事件驱动机制，提高了系统的并发性能和响应速度，使得处理大量连接和I/O操作变得更加高效。因此，NIO已经被越来越多地应用到大型应用服务器中，成为解决高并发与大量连接、I/O处理问题的有效方式。

三、Buffer

1、Buffer原理介绍

Java NIO的Buffer类是一个用于特定基本数据类型的容器。它是一个对象，包含一些要写入或者要读出的数据。在NIO中，所有的数据都是用Buffer处理的。在数据读写之前，需要先放入Buffer，或者从Buffer中取出。Buffer对象中提供了一组方法，可以轻松的使用内存块，此外缓冲区对象那中内置了一些机制，能够追踪和记录缓冲区的状态变化情况。

以下是Java NIO Buffer的基本使用步骤：

  • 分配Buffer：首先，你需要通过调用allocate()方法（对于ByteBuffer，CharBuffer，DoubleBuffer，FloatBuffer，IntBuffer，LongBuffer，ShortBuffer等）在JVM的堆中分配一个新的Buffer。例如，以下代码分配一个新的ByteBuffer：
ByteBuffer buffer = ByteBuffer.allocate(48);
  • 写入数据到Buffer：调用Buffer类的put()方法将数据写入Buffer。例如：
buffer.put((byte) 10);  
buffer.put((byte) 20);
  • 切换Buffer的读写模式：在写数据到Buffer后，需要调用flip()方法将Buffer从写模式切换到读模式。调用flip()方法会将position设回0，并将limit设置成之前position的值。换句话说，limit现在表示的是之前写进Buffer的元素的个数。现在Buffer准备好从写模式切换到读模式：
buffer.flip();
  • 从Buffer中读取数据：从Buffer中读取数据，你可以使用get()方法。读取数据直到hasRemaining()返回false。这表示已经到达Buffer的末尾：
while(buffer.hasRemaining()){  byte b = buffer.get();  // do something with b  
}
  • 清除Buffer：当读完Buffer中的数据后，需要清除它以便下次使用。有两种方式可以清除Buffer：调用clear()或compact()方法。clear()方法会清除整个Buffer。compact()方法只会清除已经读过的数据。任何未读的数据都被移到Buffer的起始处，新写入的数据将放到Buffer的未读数据后面。
buffer.clear(); // 清除整个Buffer

或者

buffer.compact(); // 只清除已读数据

注意，在使用Buffer时，要时刻注意Buffer的容量（capacity），位置（position）和限制（limit）。容量是Buffer能够容纳的数据元素的最大数量；位置是下一个要被读或写的元素的索引；限制是第一个不应该被读或写的元素的索引。这些值可以通过调用Buffer的相应方法来获取或设置。

以上就是Java NIO Buffer的基本使用方法。通过合理地使用Buffer，你可以有效地处理大量的数据读写操作，提高程序的性能。

2、Buffer实现类

  • 在NIO中，Buffer是一个顶层父类，它是一个抽象类，类的层级关系下图：
    在这里插入图片描述

    • ByteBuffer：存储字节数据到缓冲区。
      在这里插入图片描述

    • ShortBuffer：存储字符串数据到缓冲区。

    • CharBuffer：存储字符数据到缓冲区。

    • IntBuffer：存储整数数据到缓冲区。

    • LongBuffer：存储长整型数据到缓冲区。

    • DoubleBuffer：存储小数到缓冲区。

    • FloatBuffer：存储小数到缓冲区。

  • Buffer类定义了所有缓冲区都具有的四个属性，来提供其所包含的数据元素的信息：
    | 属性 |描述 |
    |–|–|
    |capacity | 容量，即可以容纳的最大数据量；在缓冲区创建是被设定并且不能改变 |
    |Limit| 表示缓冲区的当前终点，不能对缓冲区超过极限的位置进行操作。且极限是可以修改的|
    |position| 位置，下一个要被读或写的元素的索引，每次读写缓冲区数据时都会改变，为下次读写做准备|
    |mark| 标记|

  • Buffer类相关的方法：

//JDK1.4，引入的api
public final int capacity(); 	//返回此缓冲区的容量
public final int position();	//返回此缓冲区的位置
public final Buffer position(int newPosition);	//设置此缓冲区的位置
public final int limit();	//返回此缓冲区的限制
public final Buffer limit(int newLimit);	//设置此缓冲区的限制
public final Buffer mark();		//在此缓冲区的位置设置标记
public final Buffer reset();	//将此缓冲区的位置重置为以前标记的位置
public final clear();	//清除此缓冲区，即将各个标记恢复到初始化状态，但是数据并没有真正擦除。
public final Buffer flip();		//反转此缓冲区
public final Buffer rewind();	//重绕此缓冲区
public final int remaining();	//返回当前位置与限制之间的元素数
public final boolean hasRemaining();	//告知当前位置和限制之间是否有元素
public final boolean isReadOnly();		//告知此缓冲区是否为只读缓冲区//JDK1.6 引入的api
public abstract boolean hasArray();		//告知此缓冲区是否具有访问的底层实现数组
public abstract Object array();			//返回此缓冲区的底层实现数组
public abstract int arrayOffset();		//返回此缓冲区的底层实现数组中第一个缓冲区元素的偏移量
public abastract boolean isDirect();	//告知此缓冲区是否为直接缓冲区

3、示例

package test.nio;import java.nio.IntBuffer;
public class BasicBuffer {public static void main(String[] args) {//创建一个buffer， 容量大小为5，即可以存放5个intIntBuffer buffer = IntBuffer.allocate(5);//向buffer中存放数据for (int i = 0; i < buffer.capacity(); i++) {buffer.put(i * 2);}//从buffer中读取数据buffer.flip();while(buffer.hasRemaining()) {int i = buffer.get();System.out.println(i);}}
}

运行结果：

0
2
4
6
8Process finished with exit code 0

4、NIO和BIO的比较

  • BIO以流的方式处理数据，而NIO以块的方式处理数据，块I/O的效率比流I/O高很多。
  • BIO是阻塞的，NIO则是非阻塞的。
  • BIO基于字节流和字符流进行操作，而NIO基于Channel（通道）和Buffer（缓冲区）进行操作，数据总是从通道读取到缓冲区中，或者从缓存区写入到通道中。Selector（选择器）用于监听多个通道的事件（比如：连接请求，数据到达等），因此使用单个线程就可以监听多个客户端通道。

四、Channel

1、介绍

  • Channel提供从文件、网络读取数据的渠道，但是读取或写入的数据都必须经由Buffer。
    在这里插入图片描述

  • NIO的通道类似于流，有如下区别：

    • 通道可以同时进行读写，而流只能读或者只能写。
    • 通道可以实现异步读写数据。
    • 通道可以从缓冲读数据，也可以写数据到缓冲：
      在这里插入图片描述
    • BIO中的stream是单向的，例如FileInputStream对象只能进行读取数据的操作。

  • BIO中的stream是单向的，例如FileInputStream对象只能进行读取数据的操作，而NIO中的通道（Channel）是双向的，可以读操作，也可以写操作。

  • Channel在NIO中是一个接口

public interface Channel extends Closeable
  • 常用的Channel类有：FileChannel、DatagramChannel、ServerSocketChannel和SocketChannel（ServerSocketChannel类似ServerSocket、SocketChannel类似Socket）。
  • FileChannel用于文件的数据读写，DatagramChannel用于UDP的数据读写，ServerSocketChannel

2、FileChannel介绍

  • FileChannel主要用来对本地文件进行IO操作，常见的方法有：

    • public int read(ByteBuffer dst)，从通道读取数据并放到缓冲区中。
    • public int write(ByteBuffer src)，把缓冲区的数据写到通道中。
    • public long transferForm(ReadableByteChannel src, long position, long count),从目标通道中复制数据到当前通道。
    • public long transferTo(long position, long count, WritableByteChannel target)，把数据从当前通道复制给目标通道。

  • 通过channel向文件中写数据。
    blog.csdnimg.cn/direct/a4b5dc74278c40d88a1f791ab936b1c9.png)

package test.nio;import java.io.FileOutputStream;
import java.nio.ByteBuffer;
import java.nio.channels.FileChannel;public class NIOFileChannel {public static void main(String[] args) {String str = "hello world 今天是星期日";try {//创建一个输出流->channelFileOutputStream fileOutputStream = new FileOutputStream("d:\\file01.txt");//通过fileOutputStream获取对应的FileChannel//这个fileChannel真实类型是FileChannelImplFileChannel channel = fileOutputStream.getChannel();//创建一个缓冲区ByteBufferByteBuffer byteBuffer = ByteBuffer.allocate(1024);//将str放入byteBufferbyteBuffer.put(str.getBytes());//对byteBuffer进行flipbyteBuffer.flip();//将byteBuffer，数据写入到fileChannelchannel.write(byteBuffer);fileOutputStream.close();} catch (Exception e) {throw new RuntimeException(e);}}
}
  • 通过Channel读取本地文件数据。
    在这里插入图片描述
package test.nio;import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.nio.ByteBuffer;
import java.nio.channels.FileChannel;
public class NIOFileChannel01 {public static void main(String[] args) throws IOException {File file = new File("d:\\file01.txt");FileInputStream fileInputStream = new FileInputStream(file);FileChannel channel = fileInputStream.getChannel();//创建一个缓冲区ByteBufferByteBuffer byteBuffer = ByteBuffer.allocate((int)file.length());//将通道的数据读入到Bufferint read = channel.read(byteBuffer);//将byteBuffer的字节数据转成StringbyteBuffer.flip();String str = new String(byteBuffer.array());System.out.println(str);fileInputStream.close();}
}

结果展示：

hello world 今天是星期日Process finished with exit code 0
  • 使用一个Buffer完成文件的读取
package test.nio;import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.nio.ByteBuffer;
import java.nio.channels.FileChannel;
public class NIOFileChannel02 {public static void main(String[] args) throws IOException {FileInputStream fileInputStream = new FileInputStream("d:\\file01.txt");FileChannel channel = fileInputStream.getChannel();FileOutputStream fileOutputStream = new FileOutputStream("d:\\file02.txt");FileChannel channel1 = fileOutputStream.getChannel();ByteBuffer byteBuffer = ByteBuffer.allocate(512);while (Boolean.TRUE) {byteBuffer.clear();int read = channel.read(byteBuffer);System.out.println("read = " + read);if (read == -1) {break;}byteBuffer.flip();channel1.write(byteBuffer);}fileInputStream.close();fileOutputStream.close();}
}
  • 拷贝文件transferFrom方法
    要求：使用FileChannel（通道）和方法transferFrom，完成文件的拷贝。
package test.nio;import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.nio.channels.FileChannel;public class NIOFileChannel03 {public static void main(String[] args) throws IOException {//创建相关的流FileInputStream fileInputStream = new FileInputStream("d:\\star.png");FileOutputStream fileOutputStream = new FileOutputStream("d:\\ab.png");//获取各个流对应的fileChannelFileChannel channel = fileInputStream.getChannel();FileChannel channel1 = fileOutputStream.getChannel();//使用transform完成拷贝channel1.transferFrom(channel, 0, channel.size());//关闭相关通道和流channel.close();channel1.close();fileInputStream.close();fileOutputStream.close();}
}

3、Buffer和Channel的注意事项

五、Selector

六、Selector、Channel和Buffer关系

  • 每个channel都会对应一个Buffer。
  • Selector对应一个线程，一个线程对应多个channel（连接）。
  • 程序切换到那个Channel是由事件决定的，Event就是一个总要的概念。
  • Selector会根据不同的事件，在各个通道上切换。
  • Buffer就是一个内存块，底层是一个数组。
  • 数据的读取写入是通过Buffer。BIO中要么是输入流要么是输出流，不能双向。但是NIO的Buffer是可以读也可以写的，需要调用flip方法切换。
  • channel是双向的，可以返回底层操作系统的情况，比如Linux，底层的操作系统通道就是双向的。
    在这里插入图片描述
package test.nio;import java.nio.IntBuffer;
public class BasicBuffer {public static void main(String[] args) {//创建一个buffer， 容量大小为5，即可以存放5个intIntBuffer buffer = IntBuffer.allocate(5);for (int j = 0; j < 5; j ++) {//向buffer中存放数据for (int i = 0; i < buffer.capacity(); i++) {buffer.put(i * 2);}//从buffer中读取数据buffer.flip();while(buffer.hasRemaining()) {int i = buffer.get();System.out.println(i);}System.out.println("==============================================================================");buffer.flip();}}
}

输出结果：

0
2
4
6
8
==============================================================================
0
2
4
6
8
==============================================================================
0
2
4
6
8
==============================================================================
0
2
4
6
8
==============================================================================
0
2
4
6
8
==============================================================================Process finished with exit code 0

http://www.ppmy.cn/devtools/24956.html

相关文章

echarts开发技巧

echarts开发技巧

tooltip 提示框组件相关的行为&#xff0c;必须引入提示框组件后才能使用。 tooltip: {trigger: axis,axisPointer: {type: cross,label: {backgroundColor: #6a7985,},},//为弹出层的value值增加百分号valueFormatter: function (value) {return value %}, }, tooltip.axi…
阅读更多...
我们的手机是如何连接上网的？骨干网又是什么？

我们的手机是如何连接上网的？骨干网又是什么？

什么是骨干网&#xff08;Backbone Network&#xff09; 几台计算机连接起来&#xff0c;互相可以看到其他人的文件&#xff0c;这叫局域网。整个城市的计算机都连接起来&#xff0c;就是城域网。把城市之间连接起来的网就叫骨干网。 这些骨干网是国家批准的可以直接和国外连…
阅读更多...
Android使用ProtoBuf 适配 gradle7.5 gradle8.0

Android使用ProtoBuf 适配 gradle7.5 gradle8.0

ProtoBuf 适配 Gradle7.5 gradle-wrapper.properties 配置 distributionUrlhttps\://services.gradle.org/distributions/gradle-7.5-bin.zipProject&#xff1a;build.gradle: plugins {id com.android.application version 7.4.2 apply falseid com.android.library versio…
阅读更多...
面试笔记——线程安全

面试笔记——线程安全

sychronized的底层原理 Synchronized【对象锁】采用互斥的方式让同一时刻至多只有一个线程能持有【对象锁】&#xff0c;其它线程再想获取这个【对象锁】时就会阻塞住。 对象锁的互斥功能是由jvm提供的Monitor&#xff08;由C语言实现&#xff09;实现的&#xff0c;通过 java…
阅读更多...
Go Web 开发【Gin 框架快速开发】

Go Web 开发【Gin 框架快速开发】

1、Gin Web 快速开发 1.1、环境准备 1.1.1、导入 gin 依赖 这里就叫 gin 依赖了&#xff0c;在 Goland 命令行中输入下面的命令&#xff1a; go get -u github.com/gin-gonic/gin 1.1.2、设置代理 如果下载失败&#xff0c;最好设置一下代理&#xff0c;在 cmd 命令行中输…
阅读更多...
拦截pytorch算子,dump输入输出

拦截pytorch算子,dump输入输出

拦截pytorch算子,dump输入输出 一.代码二.输出 希望dump出pytorch每个算子的输入输出,但pytorch普通的hook机制只能拦截module.以下提供一种方法可以拦截torch.add,torch.Tensor.add这类算子.原理是通过模板替换,劫持torch和torch.Tensor中的算子.遍历next_functions调用regist…
阅读更多...
java坦克大战1.0——敌人坦克发射子弹+敌人消失+爆炸

java坦克大战1.0——敌人坦克发射子弹+敌人消失+爆炸

目录 1.敌人坦克发射子弹 1.功能分析 2.代码&#xff1a; 1.EnemyTank类&#xff1a; 2.MyPanel类 2.敌人消失 1.功能分析&#xff1a; 2.代码 1.EnemyTank类&#xff1a; 2.MyPanel类 3.Shot类 3.爆炸效果 1.功能分析 2.代码 1.Bomb类 2.MyPanel类 最终代码&…
阅读更多...
spring-security 学习笔记一 --- 基于默认配置

spring-security 学习笔记一 --- 基于默认配置

1.前言 本文主要讲解 spring-security 在不做任何配置情况下&#xff0c;它的启动流程和认证过程。 1. 准备工作 这里是基于springboot 2.2.5版本对应 spring-security 5.2.2版本演示的 &#xff08;按我下面导入即可&#xff0c;版本是它自己匹配的&#xff09; 引入依赖 &…
阅读更多...
最新文章

Copyright @ 2022~2023