Channel(通道)和Buffer(缓冲)是新IO中的两个核心对象&＃xff0c;Channel是对传统的输入/输出系统的模拟&＃xff0c;在新IO系统中&＃xff0c;所有的数据都需要通过通道传输&＃xff1a;Channel与传统的InputStream,OutputStream最大的区别在于它提供了一个map()方法&＃xff0c;通过该map()方法可以直接将“一块数据”映射到内存中。如果说传统的输入/输出系统是面向流的处理&＃xff0c;则新IO则是面向块的处理。
Buffer可以被理解成一个容器&＃xff0c;它的本质是一个数组&＃xff0c;发送到Channel中的所有对象都必须首先发到Buffer中&＃xff0c;而从Channel中读取的数据也必须先放到Buffer中
ByteBuffer类还有一个子类&＃xff1a;MappedByteBuffer&＃xff0c;它用于表示Channel将磁盘文件的部分或全部内容映射到内存中后得到的结果&＃xff0c;通常MappedByteBuffer对象由Channel的map()方法返回。
容量(capacity):缓冲区的容量(capacity)表示该Buffer的最大数据容量&＃xff0c;即最多可以存储多少数据。缓冲区的容量不可能为负值&＃xff0c;创建后不能改变
界限(limit):第一个不应该被读出或者写入的缓冲区位置索引。也就是说&＃xff0c;位于limit后的数据既不可以被读&＃xff0c;也不可被写。
位置(position):用于指明下一个可以被读出的或者写入的缓冲区位置索引(类似于IO流中的记录指针)。当刚刚新建一个Buffer对象时&＃xff0c;其position为0&＃xff1b;如果从Channel中读取了2个数据到该Buffer中&＃xff0c;则position为2&＃xff0c;指向Buffer中第3个位置。
当Buffer装入数据结束后&＃xff0c;调用Buffer的flip()方法&＃xff0c;该方法将limit设置为position所在的位置&＃xff0c;并将position设为0&＃xff0c;这就使得Buffer的读写指针又移到了开始位置。也就是说&＃xff0c;Buffer调用flip()方法之后&＃xff0c;Buffer为输出数据做好准备&＃xff1b;当 Buffer输出数据结束后&＃xff0c;Buffer调用clear()方法&＃xff0c;clear()方法不是清空Buffer的数据&＃xff0c;它仅仅将position置为0&＃xff0c;将limit置为capacity&＃xff0c;这样为再次向Buffer中装入数据做好准备。
flip()为从Buffer中取出数据做好准备
clear()为再次向Buffer中装入谁做好准备
package hb.nio;
import java.nio.CharBuffer;
public class BufferTest {
public static void main(String[] args) {
CharBuffer buff &＃61; CharBuffer.allocate(8);
//容量为8
System.out.println("capacity &＃xff1a;" &＃43; buff.capacity());
//在没有加入数据的时候&＃xff0c;可以读写长度为8
System.out.println("limit &＃xff1a;" &＃43; buff.limit());
//在没有加入数据的时候&＃xff0c;position当前位置为0
System.out.println("position &＃xff1a;" &＃43; buff.position());
buff.put("a");
buff.put("b");
buff.put("c");
//加入数据之后position会向后移动&＃xff0c;位置为3
System.out.println("加入三个元素之后&＃xff0c;position &＃xff1a;" &＃43; buff.position());
//调用flip()方法
buff.flip();
//可读写的长度是3
System.out.println("执行flip()方法&＃xff0c;limit&＃xff1a;" &＃43; buff.limit());
//取出第一个元素
System.out.println("第一个元素&＃xff08;position&＃61;0&＃xff09;: " &＃43; buff.get());
System.out.println("取出第一个元素后&＃xff0c;position&＃xff1a;"&＃43;buff.position());
//调用clear()方法
buff.clear();
System.out.println("执行clear()后,limit&＃61;"&＃43;buff.limit());
System.out.println("执行clear()后,position&＃61;"&＃43;buff.position());
System.out.println("执行clear()后,缓冲区域的数据没有被清除:"&＃43;buff.get(2));
System.out.println("执行绝对读取后&＃xff0c;position&＃61;"&＃43;buff.position());
}
}
package hb.nio;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.RandomAccessFile;
import java.nio.ByteBuffer;
import java.nio.CharBuffer;
import java.nio.channels.FileChannel;
import java.nio.charset.Charset;
import java.nio.charset.CharsetDecoder;
public class RandomFileChannelTest {
public static void main(String[] args) {
File f &＃61; new File("c:\\MyClient.java");
try {
FileInputStream fis &＃61; new FileInputStream(f);
FileChannel fileChannel &＃61; fis.getChannel();
ByteBuffer bb &＃61; fileChannel.map(FileChannel.MapMode.READ_ONLY, 0, f.length());
while (bb.hasRemaining()) {
System.out.print((char) bb.get());
}
} catch (FileNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
// try {
// RandomAccessFile fis &＃61; new RandomAccessFile(f, "rw");
// // FileInputStream fis &＃61; new FileInputStream(f);
// FileChannel fileChannel &＃61; fis.getChannel();
//
// ByteBuffer bb &＃61; ByteBuffer.allocate(1024);
//
// while (fileChannel.read(bb) !&＃61; -1) {
// bb.flip();
// Charset charset &＃61; Charset.forName("GBK");
// CharsetDecoder decoder &＃61; charset.newDecoder();
// CharBuffer charBuffer &＃61; decoder.decode(bb);
// System.out.print(charBuffer);
// // System.out.println(bb);
// bb.clear();
// }
//
// } catch (FileNotFoundException e) {
// // TODO Auto-generated catch block
// e.printStackTrace();
// } catch (Exception e) {
// // TODO Auto-generated catch block
// e.printStackTrace();
// }
}
}
京公网安备 11010802041100号