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利用超大資