Java NIO 中的 Channel 详解(上)

简介: Channel是一个通道,可以通过它读取和写入数据,它就像是水管一样,网络数据通过 Channel 进行读取和写入。通道和流的不同之处在与通道是双向的,流只是在一个方向上移动(一个流必须是 InputStream 或者 OutputStram 的子类),而且通道上可以用于读,写或者同事用于读写。因为 Channel 是全双工的,所以它可以比流更好的映射底层操作系统的 API。

Channel 概述


Channel是一个通道,可以通过它读取和写入数据,它就像是水管一样,网络数据通过 Channel 进行读取和写入。通道和流的不同之处在与通道是双向的,流只是在一个方向上移动(一个流必须是 InputStream 或者 OutputStram 的子类),而且通道上可以用于读,写或者同事用于读写。因为 Channel 是全双工的,所以它可以比流更好的映射底层操作系统的 API。


NIO 中通过 Channel 封装了对数据源的操作,通过channel 我们可以操作数据源, 但是又不关心数据源的具体数据结构。这个数据源可能是很多种,比如,可以是文件,也可是网络 socket 。 在大多数应用中,channel 与文件描述符或者 socket 是一一对应的。 channel 在字节缓冲区和位于通道另一侧的实体(通常是一个文件或套接字)之间有效的传输数据。


Channel 接口源码


public interface Channel extends Closeable {
    /**
     * Tells whether or not this channel is open.
     *
     * @return <tt>true</tt> if, and only if, this channel is open
     */
    public boolean isOpen();
    /**
     * Closes this channel.
     *
     * <p> After a channel is closed, any further attempt to invoke I/O
     * operations upon it will cause a {@link ClosedChannelException} to be
     * thrown.
     *
     * <p> If this channel is already closed then invoking this method has no
     * effect.
     *
     * <p> This method may be invoked at any time.  If some other thread has
     * already invoked it, however, then another invocation will block until
     * the first invocation is complete, after which it will return without
     * effect. </p>
     *
     * @throws  IOException  If an I/O error occurs
     */
    public void close() throws IOException;
}


与缓冲区不同,通道 api 主要是由接口指定。不同的操作系统通道实现(ChannelImplementation) 会有根本性差异,所以通道 API 仅仅描述了可以做什么。因此很自然地,通道实现机场使用操作系统本地代码。通道接口允许您以一种受控且可移植方式来访问底层的 I/O 服务。


Channel 是一个对象,可以通过它读取和写入数据。拿 NIO 与原来的 I/O 做一个比较,通道就是流,所有的数据通过 Buffer 对象来处理。您永远不会将字节直接写入通道中,相反,您是将数据写入了一个包含多个字节的缓冲区。同样,您不会直接从通道中读取字节,而是将数据从通道中读入缓冲区,再从缓冲区中获取这些字节。


Java NIO 的通道类似流,但是又有些不同:


  • 既可以通道汇总读取数据,又可以写数据到通道,但流的读写通常是单向的。


  • 通道可以异步地读写。


  • 通道中的数据总是先读取到 buffer , 或者总是需要从一个 buffer 写入。


正如上面所说, 从通道读取数据到缓冲区,从缓冲区写入数据到通道。如下图所示:


image.png


Channel 实现


下面是 Java NIO 中最重要的 Channel 实现:


  • FileChannel


  • DatagramChannel


  • SocketChannel


  • ServerSocketChannel


(1) FileChannel 从文件中读写数据


(2) DatagramChannel 能够通过 UDP 读写网络中的数据


(3) SocketChannel 能够通过 TCP 写网络中的数据


(4) ServerSocketChannel 可以监听新进来的 TCP 连接, 就像 WBE 服务那样,对每个新进来的连接都会创建一个 SocketChannel 。


正如你所看到的,这些通道涵盖了 UDP 和 TCP 网络IO,以及文件 IO。


FileChannel 介绍和实例


FileChannel 类可以实现常用的 read、write 以及 scatter、gather 操作,同时它也可以提供很多专用于文件的新方法。这些方法中许多都是我们熟悉的文件操作。


方法 操作
int read *( *ByteBuffer dst ) 从 Channel 中读取到数据到 ByteBuffer
long read *( *ByteBuffer *[] *dsts ) 将 Channel 中数据“分散”到 ByteBuffer
int write *( *ByteBuffer src ) 将 ByteBuffer 中的数据写入到 Channel 中
long write *( *ByteBuffer *[] *srcs ) 将 ByteBuffer[] 中的数据“聚集”到 Channel 中
long position () 返回此通道的文件位置
FileChannel position *( *long newPosition ) 设置此通道的文件位置
long size () 返回此通道的文件的当前大小
FileChannel truncate *( *long size ) 将此通道的文件截取为给定大小
void force *( *boolean metaData ) 强制将所有对此通道文件更新到写入到存储设备中


下面是一个使用 FileChannel 读取数据到 buffer 中的一个实例:


public class FileChannelDemo {
  // FileChannel 读取数据到 buffer 中
  public static void main(String[] args) throws IOException {
    // 创建 FileChannel
    RandomAccessFile accessFile = new RandomAccessFile("C:\a.txt", "rw");
    FileChannel fileChannel = accessFile.getChannel();
    // 创建 buffer
    ByteBuffer byteBuffer = ByteBuffer.allocate(48);
    while (fileChannel.read(byteBuffer) != -1) {
      System.out.println("读取到了: " + byteBuffer);
      byteBuffer.flip();
      while (byteBuffer.hasRemaining()) {
        System.out.println((char) byteBuffer.get());
      }
      byteBuffer.clear();
    }
    fileChannel.close();
    System.out.println("end");
  }
}


Buffer 通常的操作



将数据写入缓冲区


调用 buffer.filp() 反转读写模式


从缓冲区读取数据


调用 buffer.clear() 或 buffer.compact() 清除缓冲区内容


FileChannel 操作和详解


打开 FileChannel


使用 FileChannel 之前,必须先打开它, 但是,我们无法直接打开一个 FileChannel ,需要通过使用一个 InputStream, OutputStream 或者 RandomAccessFile 来获取一个 FileCannel 实例, 下面是通过 RandomAccessFile 打开 FileChannel 的实际例子:


RandomAccessFile accessFile = new RandomAccessFile("C:\a.txt", "rw");
FileChannel fileChannel = accessFile.getChannel();


从 FileChannel 中读取数据


调用读取数据 read() 方法之一从 File Channel 中读取数据。如:


ByteBuffer byteBuffer = ByteBuffer.allocate(48);
byteBuffer = accessFile.read(byteBuffer);


首先分配一个 Buffer , 从 FileChannel 中读取的数据将被读取到 Buffer 中。然后,调用 FileChannel.read() 方法。该方法将数据从 FileChanel 读取到 Buffer 中。read() 方法返回的 int 值表示有多少个字节读取到了 Buffer 中。如果返回 -1 , 表示到了文件末尾。


向 FileChannel 写数据


通过 FileChannel.write() 方法向 FileChannel 写数据, 该方法的一个参数是 buffer。

如:


public class FileChannelDemo2 {
  // FileChannel 读取数据到 buffer 中
  public static void main(String[] args) throws IOException {
    // 创建 FileChannel
    RandomAccessFile accessFile = new RandomAccessFile("C:\a.txt", "rw");
    FileChannel fileChannel = accessFile.getChannel();
    String newData = "new string to write to file ..." + System.currentTimeMillis();
    // 创建 buffer
    ByteBuffer byteBuffer = ByteBuffer.allocate(1024);
    byteBuffer.clear();
    byteBuffer.put(newData.getBytes());
    byteBuffer.flip();
    while (byteBuffer.hasRemaining()) {
      fileChannel.write(byteBuffer);
    }
    fileChannel.close();
    System.out.println("end");
  }
}


注意 FileChannel.wrte() 是在 while 循环中调用的,因为无法保证 write 方法一次能向 FileChannel 写入多少字节,因此需要重复调用 write() 方法,直到 Buffer 中已经没有尚未写入通道的字节。


关闭 FileChannel


用完 FileChannel 后必须将其关闭。如:

fileChannel.close();


FileChannel 的 position 方法


有的时候可能需要在 FileChannel 的投个特定位置进行数据的读/写操作。可以通过调用 position() 方法获取 FileChannel 的当前位置。也可以通过调用 position(long pos) 方法设置 FileChannel 的当前位置。


这里有两个例子:


long pos = channel.position();
channel.position(pos + 123);


如果设置在文件结束符之后,然后试图从文件通道中读取数据,读方法将返回 -1 (文件结束标识)。


如果将位置这只在文件结束符之后,然后向通道写数据,文件将撑大到当前位置并且写入数据。这可能导致 “文件空洞”, 磁盘上无理文件中写入的数据间有空隙。


FileChannel 的 size 方法


FileChannel 实例的 size 方法将返回该实例所关联文件的大小,如:


long fileSize = channel.size()


相关文章
|
5月前
|
Java 大数据
解析Java中的NIO与传统IO的区别与应用
解析Java中的NIO与传统IO的区别与应用
|
20天前
|
消息中间件 缓存 Java
java nio,netty,kafka 中经常提到“零拷贝”到底是什么?
零拷贝技术 Zero-Copy 是指计算机执行操作时,可以直接从源(如文件或网络套接字)将数据传输到目标缓冲区, 而不需要 CPU 先将数据从某处内存复制到另一个特定区域,从而减少上下文切换以及 CPU 的拷贝时间。
java nio,netty,kafka 中经常提到“零拷贝”到底是什么?
|
2月前
|
Java
让星星⭐月亮告诉你,Java NIO之Buffer详解 属性capacity/position/limit/mark 方法put(X)/get()/flip()/compact()/clear()
这段代码演示了Java NIO中`ByteBuffer`的基本操作,包括分配、写入、翻转、读取、压缩和清空缓冲区。通过示例展示了`position`、`limit`和`mark`属性的变化过程,帮助理解缓冲区的工作原理。
31 2
|
3月前
|
存储 网络协议 Java
Java NIO 开发
本文介绍了Java NIO(New IO)及其主要组件,包括Channel、Buffer和Selector,并对比了NIO与传统IO的优势。文章详细讲解了FileChannel、SocketChannel、ServerSocketChannel、DatagramChannel及Pipe.SinkChannel和Pipe.SourceChannel等Channel实现类,并提供了示例代码。通过这些示例,读者可以了解如何使用不同类型的通道进行数据读写操作。
Java NIO 开发
|
4月前
|
Java
"揭秘Java IO三大模式:BIO、NIO、AIO背后的秘密!为何AIO成为高并发时代的宠儿,你的选择对了吗?"
【8月更文挑战第19天】在Java的IO编程中,BIO、NIO与AIO代表了三种不同的IO处理机制。BIO采用同步阻塞模型,每个连接需单独线程处理,适用于连接少且稳定的场景。NIO引入了非阻塞性质,利用Channel、Buffer与Selector实现多路复用,提升了效率与吞吐量。AIO则是真正的异步IO,在JDK 7中引入,通过回调或Future机制在IO操作完成后通知应用,适合高并发场景。选择合适的模型对构建高效网络应用至关重要。
89 2
|
4月前
|
网络协议 C# 开发者
WPF与Socket编程的完美邂逅:打造流畅网络通信体验——从客户端到服务器端,手把手教你实现基于Socket的实时数据交换
【8月更文挑战第31天】网络通信在现代应用中至关重要,Socket编程作为其实现基础,即便在主要用于桌面应用的Windows Presentation Foundation(WPF)中也发挥着重要作用。本文通过最佳实践,详细介绍如何在WPF应用中利用Socket实现网络通信,包括创建WPF项目、设计用户界面、实现Socket通信逻辑及搭建简单服务器端的全过程。具体步骤涵盖从UI设计到前后端交互的各个环节,并附有详尽示例代码,助力WPF开发者掌握这一关键技术,拓展应用程序的功能与实用性。
121 0
|
5月前
|
安全 Java Linux
(七)Java网络编程-IO模型篇之从BIO、NIO、AIO到内核select、epoll剖析!
IO(Input/Output)方面的基本知识,相信大家都不陌生,毕竟这也是在学习编程基础时就已经接触过的内容,但最初的IO教学大多数是停留在最基本的BIO,而并未对于NIO、AIO、多路复用等的高级内容进行详细讲述,但这些却是大部分高性能技术的底层核心,因此本文则准备围绕着IO知识进行展开。
167 1
|
4月前
|
存储 网络协议 Java
【Netty 神奇之旅】Java NIO 基础全解析:从零开始玩转高效网络编程!
【8月更文挑战第24天】本文介绍了Java NIO,一种非阻塞I/O模型,极大提升了Java应用程序在网络通信中的性能。核心组件包括Buffer、Channel、Selector和SocketChannel。通过示例代码展示了如何使用Java NIO进行服务器与客户端通信。此外,还介绍了基于Java NIO的高性能网络框架Netty,以及如何用Netty构建TCP服务器和客户端。熟悉这些技术和概念对于开发高并发网络应用至关重要。
75 0
|
5月前
|
安全 Java
【Java】已解决java.nio.channels.OverlappingFileLockException异常
【Java】已解决java.nio.channels.OverlappingFileLockException异常
138 1
|
5月前
|
Java
【Java】已解决java.nio.channels.ClosedChannelException异常
【Java】已解决java.nio.channels.ClosedChannelException异常
419 1
下一篇
无影云桌面