NIO学习笔记二

痛定思痛。 2022-09-23 14:48 166阅读 0赞

## NIO中的读和写 ##

NIO中的读和写都是和通道与缓冲区相关联的。从一个通道读取，只需创建一个缓冲区，然后让通道将数据读到这个缓冲区中。写入操作，只需创建一个缓冲区，用数据填充它，然后让通道用这些数据执行写入操作。

## 从文件中读取 ##

（1）获取通道

（2）创建缓冲区

（3）将数据从通道读入缓冲区

import java.io.FileInputStream;
    import java.io.IOException;
    import java.io.UnsupportedEncodingException;
    import java.nio.ByteBuffer;
    import java.nio.channels.FileChannel;
    
    public class NioReader {
    	public static void main(String[] args) throws UnsupportedEncodingException, IOException {
    		//关联要读取的文件
    		FileInputStream fin = new FileInputStream("e://nioTest.txt");
    		//获取通道
    		FileChannel channel = fin.getChannel();
    		//创建缓冲区
    		ByteBuffer buffer = ByteBuffer.allocate(1024);
    		//将数据从通道读入缓冲区
    		while (channel.read(buffer) != -1) {
    			buffer.flip();
    			System.out.println(new String(buffer.array(), 0, buffer.limit(), "UTF-8"));
    			buffer.clear();
    		}
    		
    		fin.close();
    	}
    }

我们不需要告诉通道要读 多少数据 到缓冲区中。每一个缓冲区都有复杂的内部统计机制，它会跟踪已经读了多少数据以及还有多少空间可以容纳更多的数据

## 写入数据到文件 ##

（1）从输出流获取一个通道

（2）创建一个缓冲区，并将数据放入缓冲区

（3）将缓存区的数据写入通道

import java.io.FileOutputStream;
    import java.io.IOException;
    import java.nio.ByteBuffer;
    import java.nio.channels.FileChannel;
    
    public class NioWriter {
    	public static void main(String[] args) throws IOException {
    		//要写入文件的内容
    		String str = "你好啊，今天的天气真好。";
    		
    		byte[] array = str.getBytes("UTF-8");
    		//关联文件
    		FileOutputStream fos = new FileOutputStream("e://nioTest2.txt");
    		//获得通道
    		FileChannel channel = fos.getChannel();
    		//创建缓冲区
    		ByteBuffer buffer = ByteBuffer.allocate(array.length);
    		
    		buffer.put(array);
    		buffer.flip();
    		//写入文件
    		channel.write(buffer);
    		//清空缓冲区
    		buffer.clear();
    		fos.close();
    	}
    }

注意在这里同样不需要告诉通道要写入多数据。缓冲区的内部统计机制会跟踪它包含多少数据以及还有多少数据要写入。

## 读写结合的例子 ##

import java.io.FileInputStream;
    import java.io.FileOutputStream;
    import java.nio.ByteBuffer;
    import java.nio.channels.FileChannel;
    
    public class CopyFile {
    	public static void main(String args[]) throws Exception {
    		String inFile = "e://infile.txt";
    		String outFile = "e://outfile.txt";
    		
    		//创建输入流和输入流，分别关联要读取的文件和要写入的文件
    		FileInputStream in = new FileInputStream(inFile);
    		FileOutputStream out = new FileOutputStream(outFile);
    		
    		//获得通道，一个用户读取数据，一个用于写入数据
    		FileChannel fcin = in.getChannel();
    		FileChannel fcout = out.getChannel();
    		//创建一个缓冲区
    		ByteBuffer buffer = ByteBuffer.allocate(1024);
    
    		while (true) {
    			//在读取数据之前重设缓冲区，使它可以接受读入的数据
    			buffer.clear();
    
    			int count = fcin.read(buffer);
    			//表示文件的数据已经全部读完，则退出循环
    			if (count == -1) {
    				break;
    			}
                            //让缓冲区可以将新读入的数据写入另一个通道
    			buffer.flip();
    			//将缓冲区的数据写入通道
    			fcout.write(buffer);
    		}
    		
    		//关闭输入和输出流
    		in.close();
    		out.close();
    	}
    }