1. 程式人生 > >5. 彤哥說netty系列之Java NIO核心元件之Channel

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

最後,也歡迎來我的工從號彤哥讀原始碼系統地學習原始碼&架構的知識。

相關推薦

5. netty系列Java NIO核心元件Channel

你好,我是彤哥,本篇是netty系列的第五篇。 簡介 上一章我們一起學習瞭如何使用Java原生NIO實現群聊系統,這章我們一起來看看Java NIO的核心元件之一——Channel。 思維轉變 首先,我想說的最重要的一個點是,學習NIO思維一定要從BIO那種一個連線一個執行緒的模式轉變成多個連線(Chan

6. netty系列Java NIO核心元件Buffer

——日拱一卒,不期而至! 你好,我是彤哥,本篇是netty系列的第六篇。 簡介 上一章我們一起學習了Java NIO的核心元件Channel,它可以看作是實體與實體之間的連線,而且需要與Buffer互動,這一章我們就來學習一下Buffer的特性。 概念 Buffer用於與Channel互動時使用,通過上一

7. netty系列Java NIO核心元件Selector

——日拱一卒,不期而至! 你好,我是彤哥,本篇是netty系列的第七篇。 簡介 上一章我們一起學習了Java NIO的核心元件Buffer,它通常跟Channel一起使用,但是它們在網路IO中又該如何使用呢,今天我們將一起學習另一個NIO核心元件——Selector,沒有它可以說就幹不起來網路IO。 概念

Java NIO 三大元件 Buffer

NIO大三元件 之Buffer 一、什麼是Buffer Buffer是用於特定原始型別的資料的容器。 它的實質就是一組陣列,用於儲存不同型別的資料。 二、緩衝區的型別 緩衝區型別除了Boolean值型別外,其餘基本型別都含有。 NIO中定義的抽象緩衝區物件如下(均繼承至Buffer抽象類): ByteBuf

一文理解:Java NIO 核心元件

背景知識 同步、非同步、阻塞、非阻塞 首先,這幾個概念非常容易搞混淆,但NIO中又有涉及,所以總結一下。 同步:API呼叫返回時呼叫者就知道操作的結果如何了(實際讀取/寫入了多少位元組)。 非同步:相對於同步,API呼叫返回時呼叫者不知道操作的結果,後面才

一文讓你徹底理解 Java NIO 核心元件

背景知識 同步、非同步、阻塞、非阻塞 首先,這幾個概念非常容易搞混淆,但NIO中又有涉及,所以總結一下[1]。 同步:API呼叫返回時呼叫者就知道操作的結果如何了(實際讀取/寫入了多少位元組)。 非同步:相對於同步,API呼叫返回時呼叫者不知道操作的結果,後面才會回撥通知結果

Java NIO 核心元件學習筆記

背景知識 同步、非同步、阻塞、非阻塞 首先,這幾個概念非常容易搞混淆,但NIO中又有涉及,所以總結一下。 同步:API呼叫返回時呼叫者就知道操作的結果如何了(實際讀取/寫入了多少位元組)。 非同步:相對於同步,API呼叫返回時呼叫者不知道操作的結果,後面才會回撥通

4. netty系列Java NIO實現群聊(自己跟自己聊上癮了)

你好,我是彤哥,本篇是netty系列的第四篇。 歡迎來我的公從號彤哥讀原始碼系統地學習原始碼&架構的知識。 簡介 上一章我們一起學習了Java中的BIO/NIO/AIO的故事,本章將帶著大家一起使用純純的NIO實現一個越聊越上癮的“群聊系統”。 業務邏輯分析 首先,我們先來分析一下群聊的功能點:

java NIO 快取區核心空間、使用者空間和虛擬地址

  IO是基於快取區來做的,所謂的輸入和輸出就是從快取區中移入和移出資料。以IO輸入為例,首先是使用者空間程序向核心請求某個磁碟空間資料,然後核心將磁碟資料讀取到核心空間的buffer中,然後使用者空間的程序再將核心空間buffer中的資料讀取到自身的buffer中,然後程序就可

Java NIO程式設計例項三Selector

Java NIO主要包含三個概念,即緩衝區(Buffer)、通道(Channel)和選擇器(Selector)。前面的文章已經介紹了緩衝區和通道,本文則講述最複雜的選擇器Selector。 本文是本系列的第三篇文章,關於緩衝區Buffer可以看第一篇: ht

Java io學習java.nio.file的Path類和Files類

1.Path 類 將一個路徑封裝成物件,該路徑可以是相對路徑也可以是絕對路徑。 //定義一個Path物件 Path path= Paths.get("E:\\ja

Java NIO框架Netty教程(六)-Java NIO Selector模式

看到標題,您可能覺得,這跟Netty有什麼關係呢?確實,如果你完全是使用Netty的,那麼可能你可以完全不需要了解Selector。但是,不得不提的是,Netty底層關於NIO的實現也是基於Java的Selector的,是對Selector的封裝。所以,我個人認為理解

Java NIO Java NIO Overview(譯)

看到一個國外的作者寫的關於java的文章還不錯,於是便翻譯過來了,再加上自己的一些理解 Java NIO主要由下面三個核心元件構成: Channels(通道) Buffers(緩衝) Selectors(選擇器) 除了上面三個,java n

JDK1.7 java.nio.file.Files 讀取檔案只要一行

JDK1.7中引入了新的檔案操作類java.nio.file這個包,其中有個Files類它包含了很多有用的方法來操作檔案,比如檢查檔案是否為隱藏檔案,或者是檢查檔案是否為只讀檔案。開發者還可以使用Fi

Java NIO通俗程式設計選擇器Selector(四)

最後一步就是根據不同的事件,編寫相應的處理程式碼:/* * 根據不同的事件做處理 * */ protected void process(SelectionKey key) throws IOException{ // 接收請求 if (key.isAcceptable()) {

Java NIO:Buffer、Channel 和 Selector

style clear 準備 創建 compact 必須 ntb sta locking Buffer 一個 Buffer 本質上是內存中的一塊,我們可以將數據寫入這塊內存,之後從這塊內存獲取數據。 java.nio 定義了以下幾個 Buffer 的實現,這個圖讀者應該也在

Java NIO核心概念總結篇

最近學習Java NIO的相關知識,為了以後方便複習記錄下主要知識點。 參考來源:某視訊中的講解以及一些博文,見文章結尾。 一、Java NIO基本介紹 Java NIO(New IO,也有人叫:Non Blocking  IO)是從Java1.4版本開始引入的一個新的

Java NIO 中通道(Channel)的使用

通道(Channel)的使用說明 /** * <pre> * 一、通道(Channel):用於源節點與目標節點的連線。在 Java NIO 中負責緩衝區中資料的傳輸。 * Channel 本身不儲存資

Urule開源版系列4——Core包核心介面規則解析過程

> Urule執行規則檔案,是如何進行的,通過一個請求doTest來探一下 com.bstek.urule.console.servlet.respackage.PackageServletHandler.doTest()方法執行測試規則,接受3個引數: data-測試資料;files- 規則檔名稱及

Hadoop基礎 - Hadoop核心元件HDFS工作原理

HDFS 1.HDFS是Hadoop的儲存元件是一個檔案系統,用於儲存和管理檔案,通過統一的名稱空間(類似於本地檔案系統的目錄樹)。是分散式的,伺服器叢集中各個節點都有自己的角色和職責。HDFS為高吞吐量做了優化,尤其在讀寫大檔案(GB級別或更大)時執行最佳。為了維持高吞吐量,HDFS利用超大資