栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

NIO基础知识

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

NIO基础知识

IO概念 BIO (Blocking I/O):

同步阻塞 I/O 模式,数据的读取写入必须阻塞在一个线程内等待其完成。在客户端连接数量不高的情况下,是没问题的。但是,当面对十万甚至百万级连接的时候,传统的 BIO 模型是无能为力的。因此,我们需要一种更高效的 I/O 处理模型来应对更高的并发量。

NIO (Non-blocking/New I/O):

NIO 是一种同步非阻塞的 I/O 模型,于 Java 1.4 中引入,对应 java.nio包,提供了 Channel , Selector,Buffer 等抽象。NIO 中的 N 可以理解为 Non-blocking,不单纯是 New。它支持面向缓冲的,基于通道的 I/O 操作方法。 NIO 提供了与传统 BIO 模型中的 Socket 和 ServerSocket 相对应的 SocketChannel 和 ServerSocketChannel 两种不同的套接字通道实现,两种通道都支持阻塞和非阻塞两种模式。对于高负载、高并发的(网络)应用,应使用 NIO 的非阻塞模式来开发

AIO (Asynchronous I/O):

AIO 也就是 NIO 2。在 Java 7 中引入了 NIO 的改进版 NIO 2,它是异步非阻塞的 IO 模型。异步 IO 是基于事件和回调机制实现的,也就是应用操作之后会直接返回,不会堵塞在那里,当后台处理完成,操作系统会通知相应的线程进行后续的操作。AIO 是异步 IO 的缩写,虽然 NIO 在网络操作中,提供了非阻塞的方法,但是 NIO 的 IO 行为还是同步的。对于 NIO 来说,我们的业务线程是在 IO 操作准备好时,得到通知,接着就由这个线程自行进行 IO 操作,IO 操作本身是同步的。目前来说 AIO 的应用还不是很广泛。

文件NIO
public static void main(String[] args) {
        try (FileOutputStream fos = new FileOutputStream("test.txt")) {
            //获取该文件输出流的通道
            FileChannel channel = fos.getChannel();
            //分配buff大小
            ByteBuffer buffer = ByteBuffer.allocate(1024);
            String str = "hello nio";
            //把数据put进buffer
            buffer.put(str.getBytes(StandardCharsets.UTF_8));
            //buffer指针指向初始位置,不然就会指向str的最后位置的下一个index
            buffer.flip();
            //channel中写入buffer数据
            channel.write(buffer);
        } catch (IOException e) {
            log.error("", e);
        }
    }
  
    public static void main(String[] args) throws IOException {
        String path = "test.txt";
        File file = new File(path);
        try (FileInputStream fis = new FileInputStream(path)) {
            FileChannel channel = fis.getChannel();
            ByteBuffer buffer = ByteBuffer.allocate((int) file.length());
            channel.read(buffer);
            log.info("content:{}", new String(buffer.array()));
        }
    }
   
    public static void main(String[] args) throws IOException {
        //获取输入输出流
        try (FileInputStream fis = new FileInputStream("test.txt");
             FileOutputStream fos = new FileOutputStream("D:\demo\test.txt")) {
            //获取流中的通道
            FileChannel sourceChannel = fis.getChannel();
            FileChannel destChannel = fos.getChannel();
            
            sourceChannel.transferTo(0, sourceChannel.size(), destChannel);
        }
    }
网络NIO
转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/424367.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号