摘要:前言非阻塞,也被称之为新,它重新定义了一些概念。缓冲通道通道选择器阻塞,几乎所有的程序员都会的字节流,字符流,输入流,输出流等分类就是针对而言的。缓冲区基本属性容量表示最大数据容量,缓冲区容量不能为负,并且创建后不能更改。
非阻塞IO,也被称之为新IO,它重新定义了一些概念。
缓冲buffer
通道 channel
通道选择器
BIO 阻塞IO,几乎所有的java程序员都会的字节流,字符流,输入流,输出流等分类就是针对BIO而言的。我们在使用BIO的时候都是建立基本的节点流然后用过滤流进行包装。
不同于BIO,NIO所有的IO操作都是通过通道读写buffer完成的。数据总是从通道读取到缓冲区中,或者从缓冲区写入到通道中。
NIO的通道类似流,但是有所不同。
既可以从通道中读取数据,又可以写数据到通道。而流的读写通常是单向的
通道就是类似与高速路,数据通过buffer传递。通道负责从buffer中读,或者写入buffer
通道可以异步读写
FileChannel 从文件中读写数据
DatagramChannel 能通过UDP读写网络中的数据
SocketChannel 能通过TCP读写网络中的数据
ServerSocketChannel可以监听新进来的TCP连接,像Web服务器那样。对每一个新进来的连接都会创建一个SocketChannel
Buffer 用来缓存数据,NIO中所有的操作都是基于缓冲区继续操作的,所有的读写操作都是通过缓存区来进行完成。缓冲区本质上是一块可以写入数据,然后可以从中读取数据的内存。这块内存被包装成NIO Buffer对象,并提供了一组方法,用来方便的访问该块内存。
ByteBuffer
CharBuffer
DoubleBuffer
FloatBuffer
IntBuffer
LongBuffer
ShortBuffer
容量 (capacity):表示 Buffer 最大数据容量,缓冲区容量不能为负,并且创建后不能更改。
限制 (limit)
位置 (position)
position和limit的含义取决于Buffer处在读模式还是写模式。不管Buffer处在什么模式,capacity都代表容量。
Buffer有一个固定的大小值,叫“capacity”。一旦Buffer满了,需要将其清空(通过读数据或者清除数据)才能继续写数据往里写数据。
写模式
当你写数据到Buffer中时,position表示当前的位置。初始的position值为0,当一个byte、long等数据写到Buffer后, position会向前移动到下一个可插入数据的Buffer单元。position最大可为capacity – 1。在写模式下,Buffer的limit表示你最多能往Buffer里写多少数据。 写模式下,limit等于Buffer的capacity。
读模式
当读取数据时,也是从某个特定位置读。当将Buffer从写模式切换到读模式,position会被重置为0。当从Buffer的position处读取数据时,position向前移动到下一个可读的位置。当切换Buffer到读模式时, limit表示你最多能读到多少数据。因此,当切换Buffer到读模式时,limit会被设置成写模式下的position值。换句话说,你能读到之前写入的所有数据(limit被设置成已写数据的数量,这个值等于在写模式下position)。
使用
使用Buffer读写数据一般遵循以下四个步骤:
写入数据到Buffer
调用flip()方法
从Buffer中读取数据
调用clear()方法或者compact()方法
当向buffer写入数据时,buffer会记录下写了多少数据。一旦要读取数据,需要通过flip()方法将Buffer从写模式切换到读模式。在读模式下,可以读取之前写入到buffer的所有数据。
一旦读完了所有的数据,就需要清空缓冲区,让它可以再次被写入。有两种方式能清空缓冲区:调用clear()或compact()方法。clear()方法会清空整个缓冲区。compact()方法只会清除已经读过的数据。任何未读的数据都被移到缓冲区的起始处,新写入的数据将放到缓冲区未读数据的后面。
使用案例如下:
import java.io.FileInputStream; import java.nio.ByteBuffer; import java.nio.channels.FileChannel; import java.nio.charset.Charset; public class TestNio { public static void main(String[] args) throws Exception { /*FileOutputStream outputStream = new FileOutputStream("E:/i.txt"); FileChannel channel = outputStream.getChannel(); ByteBuffer buffer = ByteBuffer.wrap("hahahah".getBytes()); channel.write(buffer); channel.close();*/ FileInputStream inputStream = new FileInputStream("E:/i.txt"); FileChannel channel = inputStream.getChannel(); ByteBuffer buffer = ByteBuffer.allocate(10); while (true){ // 读数据写入buffer 如果读了6个数据 那么positon limit均为6 int read = channel.read(buffer); if(read == -1) break; // 把position设置为0 写操作变为读操作(相对与buffer而言) buffer.flip(); // hasRemaining当 position和limit相等的时候为false while (buffer.hasRemaining()){ byte b = buffer.get(); System.out.println((char)b); } // clear实际上是positon 和 limit均置为0 数据实际上是未清楚的 // 读操作变为写操作(相对与buffer) buffer.clear(); } channel.close(); ByteBuffer wrap = new ByteBuffer.wrap("哈哈哈".getBytes()); // 编码处理 Charset gbk = Charset.forName("GBK"); ByteBuffer encode = gbk.encode("哈哈哈"); } }
我不能保证每一个地方都是对的,但是可以保证每一句话,每一行代码都是经过推敲和斟酌的。希望每一篇文章背后都是自己追求纯粹技术人生的态度。永远相信美好的事情即将发生。
文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。
转载请注明本文地址:https://www.ucloud.cn/yun/69310.html
摘要:流程控制首先来介绍程序的流程控制。后面跟一个代码块逻辑关系是当布尔表达式为真的时候执行代码块,为假的时候不执行。 流程控制 首先来介绍程序的流程控制。 所谓的流程控制,就是在我们前面的课程中我们已经学过了变量,数据类型,运算符,表达式,这些都是计算机编程的基本元素,但是我们程序的基本执行单元应该是语句,程序执行,执行的不是表达式,而是执行语句。就好像我们小时候先学认字儿,再学组词,但最...
摘要:前言本文为笃行日常工作记录,烂笔头系列。最终通过分析源码了解到最终的确定是一个协商的过程,而不是简单的配置生效。根据客户端上报的和服务端自身的。如果上报的小于则设置为如果上报的大于则设置为如果介于两则之间,则以上报的时间为准。 0.前言 本文为笃行日常工作记录,烂笔头系列。 源码前面,了无秘密 — by 侯杰 近期的一个C++项目里使用了Zookeeper做服务发现,期间遇到了Sess...
摘要:所以也就是说在没有的基础上,执行代码会在串池中创建一个,也会在堆内存中再出来一个。不可变性的优点安全性字符串不可变安全性的考虑处于两个方面,数据安全和线程安全。 摘要: String基本特性,String源码,为什么String不可变? 前言 基于字符串String在java中的地位,关于String的常识性知识就不多做介绍了,我们先来看一段代码 public class Test {...
摘要:返回一个路径,该路径是冗余名称元素的消除。本节教程将覆盖大部分方法。在本例中,这个数组内包含了,表示检测时不包含符号链接文件。遍历整个文件目录接受一个和作为参数。 Java面试通关手册(Java学习指南)github地址(欢迎star和pull):https://github.com/Snailclimb/Java_Guide 历史回顾: Java NIO 概览 Java NIO 之 ...
阅读 3594·2021-11-23 09:51
阅读 1958·2021-11-16 11:42
阅读 3171·2021-11-08 13:20
阅读 1074·2019-08-30 15:55
阅读 2147·2019-08-30 10:59
阅读 1213·2019-08-29 14:04
阅读 932·2019-08-29 12:41
阅读 1909·2019-08-26 12:22