5. 彤哥说netty系列之Java NIO核心组件之Channel

你好,我是彤哥,本篇是netty系列的第五篇。

简介

上一章我们一起学习了如何使用Java原生NIO实现群聊系统,这章我们一起来看看Java NIO的核心组件之一——Channel。

思维转变

首先,我想说的最重要的一个点是,学习NIO思维一定要从BIO那种一个连接一个线程的模式转变成多个连接(Channel)共用一个线程来处理的这种思维。

1个Connection = 1个Socket = 1个Channel,这几个概念可以看作是等价的,都表示一个连接,只不过是用在不同的场景中。

如果单从阻塞/非阻塞的角度来看的话,IO可以分成两大类,一类是Blocking IO,一类是Non-blocking IO,像IO五种模型中的后四种其实都可以看作是非阻塞型IO,只是各自使用的手段不相同罢了。

在Java中,我们说的非阻塞IO或者说NIO(New IO)主要是指多路复用IO,底层可以使用select/poll/epoll等技术实现。

另外,在Java1.7的时候引入了NIO2,这个主要是指异步IO模型,也就是我们常说的AIO,底层完全使用异步回调的方式来实现。

但是,由于AIO这项技术在linux操作系统上还不太成熟,所以我们通常也不会说太多关于这方面的内容。

在后面我们学习Netty的时候会再次讲到这三种IO模型,可以看到Netty是完全支持三种IO的,但是它把OIO(BIO)和AIO都给deprecated了,也进一步说明了AIO的不成熟性。

好了,扯了一下思维转变的问题,下面正式进入今天的内容——Java NIO核心组件之Channel

Channel

概念

我们先来看看Java中对于Channel的定义,位于java.nio.channels.Channel类的注释上:

A nexus for I/O operations.
本文来源工从号彤哥读源码
A channel represents an open connection to an entity such as a hardware device, a file, a network socket, or a program component that is capable of performing one or more distinct I/O operations, for example reading or writing.

第一句,它是IO操作的一种连接。

nexus, the means of connection between things linked in series.

第二句,Channel代表到实体的开放连接,这个实体可以是硬件,文件,网络套接字,或者程序组件,并且可以执行一个或多个不同的IO操作,例如,读或写。

简单点讲,Channel就是实体与实体之间的连接,比如,操作文件可以使用FileChannel,操作网络可以使用SocketChannel等。

与流的区别

BIO是面向流(Stream)编程的,流又分成InputStream和OutputStream,那么Channel和Stream有什么区别呢?

  • Channel可以同时支持读和写,而Stream只能支持单向的读或写(所以分成InputStream和OutputStream)
  • Channel支持异步读写,Stream通常只支持同步
  • Channel总是读向(read into)Buffer,或者写自(write from)Buffer(有点绕,以Channel为中心,从Channel中读出数据到Buffer,从Buffer中往Channel写入数据)

实现方式

下面列举了JDK中比较重要的实现方式:

  • FileChannel:操作文件
  • DatagramChannel:UDP协议支持
  • SocketChannel:TCP协议支持
  • ServerSocketChannel:监听TCP协议Accept事件,之后创建SocketChannel

例子

public class FileChannelTest {
    public static void main(String[] args) throws IOException {
        // 从文件获取一个FileChannel
        FileChannel fileChannel = new RandomAccessFile("D:\\object.txt", "rw").getChannel();
        // 声明一个Byte类型的Buffer
        ByteBuffer buffer = ByteBuffer.allocate(10);
        // 将FileChannel中的数据读出到buffer中,-1表示读取完毕
        // buffer默认为写模式,本文来源工从号彤哥读源码
        // read()方法是相对channel而言的,相对buffer就是写
        while ((fileChannel.read(buffer)) != -1) {
            // buffer切换为读模式
            buffer.flip();
            // buffer中是否有未读数据
            while (buffer.hasRemaining()) {
                // 未读数据的长度
                int remain = buffer.remaining();
                // 声明一个字节数组
                byte[] bytes = new byte[remain];
                // 将buffer中数据读出到字节数组中
                buffer.get(bytes);
                // 打印出来
                System.out.println(new String(bytes, StandardCharsets.UTF_8));
            }
            // 清空buffer,为下一次写入数据做准备
            // clear()会将buffer再次切换为写模式
            buffer.clear();
        }
    }
}

可以看到,Channel与Buffer是息息相关的。注意这里的读写方法,调用者是谁就以谁为核心,channel.read()就表示从channel读出数据,buffer.get()就表示从buffer读出数据,这跟传统编程的角度不太一样的地方。

总结

今天我们学习了Java NIO核心组件之Channel,它与传统BIO中的流很类似但又有所区别,且经常与Buffer联合起来使用,Buffer又是什么呢?请听下回分解。

参考

挺不错的一个网站:

http://tutorials.jenkov.com/java-nio/channels.html

最后,也欢迎来我的工从号彤哥读源码系统地学习源码&架构的知识。

原文地址:https://www.cnblogs.com/tong-yuan/p/11968419.html

时间: 2024-10-17 01:12:33

5. 彤哥说netty系列之Java NIO核心组件之Channel的相关文章

6. 彤哥说netty系列之Java NIO核心组件之Buffer

--日拱一卒,不期而至! 你好,我是彤哥,本篇是netty系列的第六篇. 简介 上一章我们一起学习了Java NIO的核心组件Channel,它可以看作是实体与实体之间的连接,而且需要与Buffer交互,这一章我们就来学习一下Buffer的特性. 概念 Buffer用于与Channel交互时使用,通过上一章的学习我们知道,数据从Channel读取到Buffer,或者从Buffer写入Channel. Buffer本质上是一个内存块,可以向里面写入数据,或者从里面读取数据,在Java中它被包装成了

7. 彤哥说netty系列之Java NIO核心组件之Selector

<p align="right">--日拱一卒,不期而至!</p> 你好,我是彤哥,本篇是netty系列的第七篇. 简介 上一章我们一起学习了Java NIO的核心组件Buffer,它通常跟Channel一起使用,但是它们在网络IO中又该如何使用呢,今天我们将一起学习另一个NIO核心组件--Selector,没有它可以说就干不起来网络IO. 概念 我们先来看两段Selector的注释,见类java.nio.channels.Selector. 注释I A mul

3. 彤哥说netty系列之Java BIO NIO AIO进化史.md

你好,我是彤哥,本篇是netty系列的第三篇. 欢迎来我的公从号彤哥读源码系统地学习源码&架构的知识. 先说两个事 (1)上周五的那篇文章发重复了,是定时任务设置错误导致,给大家带来干扰,这里说声抱歉. (2)之前的问卷调查结果出来了,认为先讲案例的票数较多,所以后面的文章都是先讲案例,再以案例展开讲解组件. 简介 上一章我们介绍了IO的五种模型,实际上Java只支持其中的三种,即BIO/NIO/AIO. 本文将介绍Java中这三种IO的进化史,并从使用的角度剖析它们背后的故事. Java BI

2. 彤哥说netty系列之IO的五种模型

你好,我是彤哥,本篇是netty系列的第二篇. 欢迎来我的公从号彤哥读源码系统地学习源码&架构的知识. 简介 本文将介绍linux中的五种IO模型,同时也会介绍阻塞/非阻塞与同步/异步的区别. 何为IO模型 对于一次IO操作,数据会先拷贝到内核空间中,然后再从内核空间拷贝到用户空间中,所以一次read操作,会经历两个阶段: (1)等待数据准备 (2)数据从内核空间拷贝到用户空间 基于以上两个阶段就产生了五种不同的IO模式. 阻塞IO 从进程发起IO操作,一直等待上述两个阶段完成. 两阶段一起阻塞

(四:NIO系列) Java NIO Selector

出处:Java NIO Selector 1.1. Selector入门 1.1.1. Selector的和Channel的关系 Java NIO的核心组件包括: (1)Channel(通道) (2)Buffer(缓冲区) (3)Selector(选择器) 其中Channel和Buffer比较好理解 ,联系也比较密切,他们的关系简单来说就是:数据总是从通道中读到buffer缓冲区内,或者从buffer写入到通道中. 选择器和他们的关系又是什么? 选择器(Selector) 是 Channel(通

Java NIO 之 Socket Channel

在Java NIO中用Channel来对程序与进行I/O操作主体的连接关系进行抽象,这些IO主体包括如文件.Socket或其他设备.简而言之,指代了一种与IO操作对象间的连接关系. 按照Channel接口的定义,Channel只有open和closed两种状态,只有在channel处于open状态下对其操作时才有效,而对closed的channel进行操作会导致抛出异常.相应的Channel接口也仅有isOpen()和close()两种方法. 在Socket编程中,常用的Channel类是Ser

Java NIO之通道Channel

channel与流的区别: 流基于字节,且读写为单向的. 通道基于快Buffer,可以异步读写.除了FileChannel之外都是双向的.   channel的主要实现: FileChannel DatagramChannel:UDP读写 SocketChannel:TCP读写 ServerSocketChannel 支持scatter/gather(分散和聚集) 分散(scatter)从Channel中读取是指在读操作时将读取的数据写入多个buffer中.因此,Channel将从Channel

Java NIO中的Channel接口

Channel  通道,可以将指定文件的部分或全部直接映射成Buffer. 不能直接读写Channel中的数据,Channel只能与ByteBuffer交互. 读数据时,把Channel中的数据映射到ByteBuffer中取出数据使用. 写数据时,把数据放到Buffer中,再把ByteBuffer中的数据写到Channel中. Channel是一个接口,常用的实现类有: FileChannel    用于文件读写 DatagramChannel    用于UDP通信的Channel Server

学习 java netty (一) -- java nio

前言:最近在研究java netty这个网络框架,第一篇先介绍java的nio. java nio在jdk1.4引入,其实也算比较早的了,主要引入非阻塞io和io多路复用.内部基于reactor模式. nio核心: - buffer - channel - selector buffer: 类似网络编程中的缓冲区,有 ByteBuffer 字节 CharBuffer 字符 IntBuffer DoubleBuffer- 常用的有ByteBuffer和CharBuffer java nio buf