NIO相关基础篇一

转载请注明原创出处,谢谢!java

说在前面

NIO相关知识是不少后续的一些基础知识,因此今天这篇文章仅仅是简单介绍,后续会继续有一到二篇相关NIO内容。数组

什么是NIO

Java NIO( New IO) 是从Java 1.4版本开始引入的一个新的IO API,能够替代标准的Java IO API。NIO与原来的IO有一样的做用和目的,可是使用的方式彻底不一样, NIO支持面向缓冲区的、基于通道的IO操做。 NIO将以更加高效的方式进行文件的读写操做。缓存

NIO与普通IO的主要区别

IO NIO
面向流(Stream Oriented) 面向缓冲区(Buffer Oriented)
阻塞IO(Blocking IO) 非阻塞IO(Non Blocking IO)
(无) 选择器(Selectors)
  • Channels and Buffers(通道和缓冲区):标准的IO基于字节流和字符流进行操做的,而NIO是基于通道(Channel)和缓冲区(Buffer)进行操做,数据老是从通道读取到缓冲区中,或者从缓冲区写入到通道中。
  • Asynchronous IO(异步IO):Java NIO可让你异步的使用IO,例如:当线程从通道读取数据到缓冲区时,线程仍是能够进行其余事情。当数据被写入到缓冲区时,线程能够继续处理它。从缓冲区写入通道也相似。
  • Selectors(选择器):Java NIO引入了选择器的概念,选择器用于监听多个通道的事件(好比:链接打开,数据到达)。所以,单个的线程能够监听多个数据通道。

**说明:**Asynchronous IO(异步IO)、Selectors(选择器)等后续文章会继续介绍的。网络

缓冲区(Buffer)

经过上面NIO与普通IO的主要区别也能够看到在基本的IO操做中全部的操做都是基于流进行操做的,而在NIO中全部的操做都是基于缓冲区继续操做的,全部的读写操做都是经过缓存区来进行完成,缓冲区(Buffer)是一个线性的、有序的数据集,只能容纳特定的数据类型(基本就是基本数据类型对应的Buffer或者起子类)。dom

各各数据类型的缓存区类

缓存区类 相关描述
ByteBuffer 存储字节的Buffer
CharBuffer 存储字符的Buffer
ShortBuffer 存储短整型的Buffer
IntBuffer 存储整型的Buffer
LongBuffer 存储长整型的Buffer
FloatBuffer 存储单精度浮点型Buffer
DoubleBuffer 存储双精度浮点型Buffer

**备注:**看到上面这几类是否是想起了JAVA的8种基本数据类型,惟一缺乏boolean对于的类型。异步

第一问:为何boolean不须要缓存呢? 能够查阅以前写的:java二进制相关基础,里面有描述规范中数字的内部表示和存储,boolean所占位数1bit(取值只有true或者false),因为字节(byte)是操做系统和全部I/O设备使用的基本数据类型,因此基本都是以字节或者连续的一段字节来存储表示,因此就没有boolean,感受也没有必要boolean类型的缓存操做(像RocketMQ源码里面可能把一个Int里面的某位来表示boolean,其余位继续来存储数据,欢迎关注个人公众号【匠心零度】,后续RocketMQ源码类分析的时候如何运用上述技巧进行说明等,其实上面我写的好几篇文章都是为了后续RocketMQ源码分析作准备的)。源码分析

Buffer使用

读数据:post

  • flip()方法
    • 将Buffer从写模式切换到读模式
    • 调用flip()方法会将position设回0,并将limit设置成以前position的值。
    • buf.flip();
  • buf.get()
    • 读取数据
  • Buffer.rewind()
    • 将position设回0,因此你能够重读Buffer中的全部数据
    • limit保持不变,仍然表示能从Buffer中读取多少个元素(byte、char等)
  • Buffer.mark()方法,能够标记Buffer中的一个特定position。以后能够经过调用。
  • Buffer.reset()方法,恢复到Buffer.mark()标记时的position。
  • clear()方法会:
    • 清空整个缓冲区。
    • position将被设回0,limit被设置成 capacity的值
  • compact()方法:
    • 只会清除已经读过的数据;任何未读的数据都被移到缓冲区的起始处,新写入的数据将放到缓冲区未读数据的后面。
    • 将position设到最后一个未读元素正后面,limit被设置成 capacity的值。

写数据: buf.put(127);大数据

缓冲区的基本属性

  • 容量 (capacity):表示 Buffer 最大数据容量,缓冲区容量不能为负,而且建立后不能更改。
  • 限制 (limit):第一个不该该读取或写入的数据的索引,即位于 limit 后的数据不可读写。缓冲区的限制不能为负,而且不能大于其容量。
  • 位置 (position):下一个要读取或写入的数据的索引。缓冲区的位置不能为负,而且不能大于其限制。

**备注:**标记、 位置、 限制、 容量遵照如下不变式: 0 <= position <= limit <= capacity。spa

为了更形象解释上面重要属性,准备配上简单代码以及图来进行说明就容易懂了。

//第一步,获取IntBuffer,经过IntBuffer.allocate操做
IntBuffer buf = IntBuffer.allocate(10) ;	// 准备出10个大小的缓冲区

//第二步未操做前输出属性值
System.out.println("position = " + buf.position() + ",limit = " + buf.limit() + ",capacty = " + buf.capacity()) ;

//第三步进行设置数据
buf.put(6) ;	// 设置一个数据
buf.put(16) ;	// 设置二个数据

//第四步操做后输出属性值
System.out.println("position = " + buf.position() + ",limit = " + buf.limit() + ",capacty = " + buf.capacity()) ;

//第五步将Buffer从写模式切换到读模式 postion = 0 ,limit = 本来position
buf.flip() ;	 

//第六步操做后输出属性值
System.out.println("position = " + buf.position() + ",limit = " + buf.limit() + ",capacty = " + buf.capacity()) ;
复制代码

程序输出结果:

position = 0,limit = 10,capacty = 10
position = 2,limit = 10,capacty = 10
position = 0,limit = 2,capacty = 10
复制代码

查看下图来进行说明:

通道(Channel)

通道表示打开到 IO 设备(例如:文件、套接字)的链接。若须要使用 NIO 系统,须要获取用于链接 IO 设备的通道以及用于容纳数据的缓冲区。而后操做缓冲区,对数据进行处理。Channel 负责传输, Buffer 负责存储。通道是由 java.nio.channels 包定义的。 Channel 表示 IO 源与目标打开的链接。Channel 相似于传统的“流”。只不过 Channel自己不能直接访问数据, Channel 只能与Buffer 进行交互。

通道都是操做缓存区完成所有的功能的。

Java中全部已知 Channel 实现类:

  • AbstractInterruptibleChannel
  • AbstractSelectableChannel
  • DatagramChannel
  • FileChannel
  • Pipe.SinkChannel
  • Pipe.SourceChannel
  • SelectableChannel
  • ServerSocketChannel
  • SocketChannel

经常使用的有入下几个:

  • FileChannel:用于读取、写入、映射和操做文件的通道。
  • DatagramChannel:经过 UDP 读写网络中的数据通道。
  • SocketChannel:经过 TCP 读写网络中的数据。
  • ServerSocketChannel:能够监听新进来的 TCP 链接,对每个新进来的链接都会建立一个 SocketChannel。

获取通道

获取通道的一种方式是对支持通道的对象调用getChannel() 方法。支持通道的类以下:

  • FileInputStream
  • FileOutputStream
  • RandomAccessFile
  • DatagramSocket
  • Socket
  • ServerSocket

获取通道的其余方式是使用 Files 类的静态方法 newByteChannel() 获取字节通道。或者经过通道的静态方法 open() 打开并返回指定通道。

FileChannel

  • 为了更形象解释说明的Channel,下面准备以FileChannel的一些简单代码进行说明就容易懂了。
  • 准备以FileOutputStream类为准,这两个类都是支持通道操做的。
String info[] = {"欢迎","关注","匠心零度","的","公众号","谢谢!!"} ;
File file = new File("d:" + File.separator + "testfilechannel.txt") ; 
FileOutputStream output = null ;
FileChannel fout = null;
try {
	output = new FileOutputStream(file) ;
	fout = null;
	fout = output.getChannel() ;	// 获得输出的通道
	ByteBuffer buf = ByteBuffer.allocate(1024) ; 
	for(int i=0;i<info.length;i++){
		buf.put(info[i].getBytes()) ;	// 字符串变为字节数组放进缓冲区之中
	}
	buf.flip() ;
	fout.write(buf) ;	// 输出缓冲区的内容
} catch (Exception e) {
	e.printStackTrace();
}finally{
	if(fout!=null){
		try {
			fout.close() ;
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
	if(output!=null){
		try {
			output.close() ;
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
}
复制代码

程序运行效果:

**说明:**今天只是NIO相关基础篇一,因此有不少并无涉及到,但愿上面说的这样让你们有一个新的了解,未完待续……

若是读完以为有收获的话,欢迎点赞、关注、加公众号【匠心零度】。


我的公众号,欢迎关注,查阅更多精彩历史!!!

匠心零度公众号
相关文章
相关标签/搜索