java nio channel

淩亂°似流年 2023-10-17 08:21 111阅读 0赞

Java NIO 通道类似于流，但又有一下不同：

1、既可以从通道中读取数据，也可以写数据到通道中。java .io 中的流是单向性。

2、通道数据读取可以异步。

3、通道中的数据总是要先读到一个Buffer,或者总是要从一个Buffer中写入。

总结：从通道中读取数据到Buffer缓存中,从Buffer缓存中写入数据到通道中。如下截图所示：

![Center][]

Java NIO 通道详解：

1、FileChannel:文件中读写数据

2、DatagramChannel:通过UDP 读写网络数据

3、SocketChannel:通过TCP 读写网络数据

4、ServerSocketChannel:监听新进来的TCP 连接，像Web 服务器那样。对每一个新进来的连接都会创建一个socketchannel.

示列一：文件拷贝功能（基于FileChannel）

package com.nio.filechannel;
    
    import java.io.File;
    import java.io.FileInputStream;
    import java.io.FileNotFoundException;
    import java.io.FileOutputStream;
    import java.io.IOException;
    import java.nio.ByteBuffer;
    import java.nio.channels.FileChannel;
    
    public class CopyFile {
    	public static boolean copy(String in,String out){
    		boolean target = false;
    		
    		
    		try {
    			//文件输入流
    			FileInputStream inStream = new FileInputStream(new File(in));
    			//文件输出流
    			FileOutputStream outStream = new FileOutputStream(new File(out));
    			
    			//文件输入通道
    			FileChannel inChannel =inStream.getChannel();
    			//文件输出通道
    			FileChannel outChannel=outStream.getChannel(); 			
    			//文件缓存大小1024字节
    			ByteBuffer buffer = ByteBuffer.allocate(1024);
    			
    			while(true){
    				//clear方法重置缓存区，接收读入数据
    				buffer.clear();
    				//从输入通道将数据读到缓存区
    				int result = inChannel.read(buffer);
    				//判断该输入通道是否读取输入流完毕，如果为-1，表示数据流已经读取完毕，应该终止whil 循环
    				if(result == -1){
    					target = true;
    					break;
    				}
    				//数据模式切换（读取模式--------输出模式）
    				buffer.flip();
    				//从输出通道将数据写到缓存区
    				outChannel.write(buffer);
    				
    			}
    			
    		} catch (FileNotFoundException e) {
    			// TODO Auto-generated catch block
    			System.out.println("指定文件名称不存在");
    			e.printStackTrace();
    		} catch (IOException e) {
    			// TODO Auto-generated catch block
    			System.out.println("IO 异常");
    			e.printStackTrace();
    		}		
    		return target;		
    	}
    	
    	public static void main(String[] args){
    		boolean target = copy("D:\\eula.1028.txt","D:\\a.txt");
    		if(target){
    			System.out.println("文件copy 成功");
    		}else{
    			System.out.println("文件copy 失败");
    		}
    	}
    	
    
    }

示列二：UDP数据发送功能（基于DatagramChannel）

package com.nio.channel;
    
    import java.io.IOException;
    import java.net.InetSocketAddress;
    import java.nio.ByteBuffer;
    import java.nio.channels.DatagramChannel;
    import java.nio.charset.Charset;
    
    public class UDPServer {
    
    	public static void main(String[] args) {
    		try {
    			// 打开数据包通道
    			DatagramChannel channel = DatagramChannel.open();
    			// 获取与此通道关联的数据报套接字
    			channel.socket().bind(new InetSocketAddress(8888));
    			// 分配一个新的字节缓冲区。
    			ByteBuffer buffer = ByteBuffer.allocate(1024);
    			// 判断数据包通道中是否存在数据
    			while (channel.receive(buffer) == null) {
    				try {
    					Thread.sleep(2000);
    				} catch (InterruptedException e) {
    					e.printStackTrace();
    				}
    			}
    			//反转此缓冲区(写模式---读模式)
    			buffer.flip();
    			//接受字符
    			String recStr =Charset.forName("UTF-8").newDecoder().decode(buffer).toString();
    			System.out.println(recStr);
    			channel.close();
    		} catch (IOException e) {
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		}
    
    	}
    
    }

package com.nio.channel;
    
    import java.io.IOException;
    import java.net.InetSocketAddress;
    import java.nio.ByteBuffer;
    import java.nio.channels.DatagramChannel;
    
    public class UDPClient {
    
    	public static void main(String[] args) {
    		// TODO Auto-generated method stub
    		try {// 打开数据包通道
    			DatagramChannel channel = DatagramChannel.open();
    			// 将 byte 数组写入缓冲区中
    			ByteBuffer buffer = ByteBuffer.wrap("左青龙右白虎，南朱雀北玄武".getBytes("UTF-8"));
    			// 绑定与服务UDP通道关联的数据报套接字
    			channel.send(buffer, new InetSocketAddress("127.0.0.1", 8888));
    			channel.close();
    		} catch (IOException e) {
    			e.printStackTrace();
    		}
    
    	}
    
    }

[Center]: https://img-blog.csdn.net/20160810112954494?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQv/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/Center