JAVA NIO

很抱歉鸭蛙,這是一篇個(gè)人技術(shù)筆記丐一。單純地記錄, ?沒營養(yǎng)


BUFFER:

ByteBuffer

CharBuffer

DoubleBuffer

FloatBuffer

IntBuffer

LongBuffer

ShortBuffer

MappedByteBuffer,用于表示內(nèi)存映射文件


CHANNEL:

FILECHANNEL

DATAGRAMCHANNEL

SOCKETCHANNEL

SERVERSOCKETCHANNEL

涵蓋TCP茫孔、UDP IO和文件IO



SELECTOR:

在一個(gè)Thread中可以用Selector處理多個(gè)channel叮喳。如果打開了很多連接,每個(gè)連接流量很小缰贝,可以用馍悟。




CHANNEL的數(shù)據(jù)讀寫是單向的,可以異步剩晴,總是需要BUFFERBUFFER锣咒。

關(guān)于它們的簡單用例如下:

File f

Channel c = f.getChannel()

c.read(new ByteBuff())

c.flip()

scatter()?

gather()


channel之間可以直接傳輸數(shù)據(jù):

toChannel.transferFrom(position, count, fromChannel);

fromChannel.transferTo(position, count, toChannel);


Selector概念:

能夠檢測(cè)到多個(gè)channel,并能夠知曉通道是否為讀寫做好準(zhǔn)備赞弥。

為什么使用Selector:

僅用單個(gè)線程控制多個(gè)channel的優(yōu)勢(shì)明顯


Selector使用示例:

Selector selector = Selector.open();

channel.configureBlocking(false);

SelectionKey key = channel.register(selector,Selectionkey.OP_READ);

與Selector一起使用時(shí)毅整,Channel必須處于非阻塞模式下。這意味著不能將FileChannel與Selector一起使用绽左,因?yàn)镕ileChannel不能切換到非阻塞模式悼嫉。而套接字通道都可以。

可以監(jiān)聽四種不同類型的事件:

Connect

Accept

Read

Write


通道觸發(fā)了一個(gè)事件意思是該事件已經(jīng)就緒拼窥。所以戏蔑,某個(gè)channel成功連接到另一個(gè)服務(wù)器稱為“連接就緒”。一個(gè)server socket channel準(zhǔn)備好接收新進(jìn)入的連接稱為“接收就緒”鲁纠。一個(gè)有數(shù)據(jù)可讀的通道可以說是“讀就緒”总棵。等待寫數(shù)據(jù)的通道可以說是“寫就緒”。

這四種事件用SelectionKey的四個(gè)常量來表示:

SelectionKey.OP_CONNECT

SelectionKey.OP_ACCEPT

SelectionKey.OP_READ

SelectionKey.OP_WRITE



SelectionKey中包含

interest集合

ready集合

Channel

Selector

附加的對(duì)象(可選)


int interestSet = selectionKey.interestOps();


int readySet = selectionKey.readyOps();

selectionKey.isAcceptable();

selectionKey.isConnectable();

selectionKey.isReadable();

selectionKey.isWritable();


Channel? channel? = selectionKey.channel();

Selector selector = selectionKey.selector();


select()阻塞到至少有一個(gè)通道在你注冊(cè)的事件上就緒了房交。

select(long timeout)和select()一樣彻舰,除了最長會(huì)阻塞timeout毫秒(參數(shù))。

selectNow()不會(huì)阻塞候味,不管什么通道就緒都立刻返回(譯者注:此方法執(zhí)行非阻塞的選擇操作刃唤。如果自從前一次選擇操作后,沒有通道變成可選擇的白群,則此方法直接返回零尚胞。)。


Set selectedKeys = selector.selectedKeys();

selector.wakeUp()


Selector selector = Selector.open();

02channel.configureBlocking(false);

03SelectionKey key = channel.register(selector, SelectionKey.OP_READ);

04while(true) {

05intreadyChannels = selector.select();

06if(readyChannels ==0)continue;

07Set selectedKeys = selector.selectedKeys();

08Iterator keyIterator = selectedKeys.iterator();

09while(keyIterator.hasNext()) {

10SelectionKey key = keyIterator.next();

11if(key.isAcceptable()) {

12// a connection was accepted by a ServerSocketChannel.

13}elseif(key.isConnectable()) {

14// a connection was established with a remote server.

15}elseif(key.isReadable()) {

16// a channel is ready for reading

17}elseif(key.isWritable()) {

18// a channel is ready for writing

19}

20keyIterator.remove();

21}

22}


SocketChannel


打開一個(gè)SocketChannel并連接到互聯(lián)網(wǎng)上的某臺(tái)服務(wù)器帜慢。

一個(gè)新連接到達(dá)ServerSocketChannel時(shí)笼裳,會(huì)創(chuàng)建一個(gè)SocketChannel唯卖。

打開 SocketChannel

下面是SocketChannel的打開方式:

SocketChannel socketChannel = SocketChannel.open();

socketChannel.connect(new InetSocketAddress("http://jenkov.com", 80));

關(guān)閉 SocketChannel

當(dāng)用完SocketChannel之后調(diào)用SocketChannel.close()關(guān)閉SocketChannel:

socketChannel.close();





打開一個(gè)SocketChannel并連接到互聯(lián)網(wǎng)上的某臺(tái)服務(wù)器。

一個(gè)新連接到達(dá)ServerSocketChannel時(shí)躬柬,會(huì)創(chuàng)建一個(gè)SocketChannel拜轨。

打開 SocketChannel

下面是SocketChannel的打開方式:

SocketChannel socketChannel = SocketChannel.open();

socketChannel.connect(new InetSocketAddress("http://jenkov.com", 80));

關(guān)閉 SocketChannel

當(dāng)用完SocketChannel之后調(diào)用SocketChannel.close()關(guān)閉SocketChannel:

socketChannel.close();


ServerSocketChannel


Java NIO中的 ServerSocketChannel 是一個(gè)可以監(jiān)聽新進(jìn)來的TCP連接的通道, 就像標(biāo)準(zhǔn)IO中的ServerSocket一樣。ServerSocketChannel類在 java.nio.channels包中允青。

這里有個(gè)例子:

01ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();

02

03serverSocketChannel.socket().bind(newInetSocketAddress(9999));

04

05while(true){

06SocketChannel socketChannel =

07serverSocketChannel.accept();

08

09//do something with socketChannel...

10}


datagramChannel



DatagramChannel channel = DatagramChannel.open();

channel.socket().bind(new InetSocketAddress(9999));


channel.connect(new InetSocketAddress("jenkov.com", 80));



pipe


Java NIO 管道是2個(gè)線程之間的單向數(shù)據(jù)連接橄碾。Pipe有一個(gè)source通道和一個(gè)sink通道。數(shù)據(jù)會(huì)被寫到sink通道颠锉,從source通道讀取法牲。

這里是Pipe原理的圖示:


最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
  • 序言:七十年代末,一起剝皮案震驚了整個(gè)濱河市琼掠,隨后出現(xiàn)的幾起案子拒垃,更是在濱河造成了極大的恐慌,老刑警劉巖瓷蛙,帶你破解...
    沈念sama閱讀 217,406評(píng)論 6 503
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件悼瓮,死亡現(xiàn)場離奇詭異,居然都是意外死亡艰猬,警方通過查閱死者的電腦和手機(jī)谤牡,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 92,732評(píng)論 3 393
  • 文/潘曉璐 我一進(jìn)店門,熙熙樓的掌柜王于貴愁眉苦臉地迎上來姥宝,“玉大人翅萤,你說我怎么就攤上這事±奥” “怎么了套么?”我有些...
    開封第一講書人閱讀 163,711評(píng)論 0 353
  • 文/不壞的土叔 我叫張陵,是天一觀的道長碳蛋。 經(jīng)常有香客問我胚泌,道長,這世上最難降的妖魔是什么肃弟? 我笑而不...
    開封第一講書人閱讀 58,380評(píng)論 1 293
  • 正文 為了忘掉前任玷室,我火速辦了婚禮,結(jié)果婚禮上笤受,老公的妹妹穿的比我還像新娘穷缤。我一直安慰自己,他們只是感情好箩兽,可當(dāng)我...
    茶點(diǎn)故事閱讀 67,432評(píng)論 6 392
  • 文/花漫 我一把揭開白布津肛。 她就那樣靜靜地躺著,像睡著了一般汗贫。 火紅的嫁衣襯著肌膚如雪身坐。 梳的紋絲不亂的頭發(fā)上秸脱,一...
    開封第一講書人閱讀 51,301評(píng)論 1 301
  • 那天,我揣著相機(jī)與錄音部蛇,去河邊找鬼摊唇。 笑死,一個(gè)胖子當(dāng)著我的面吹牛涯鲁,可吹牛的內(nèi)容都是我干的遏片。 我是一名探鬼主播,決...
    沈念sama閱讀 40,145評(píng)論 3 418
  • 文/蒼蘭香墨 我猛地睜開眼撮竿,長吁一口氣:“原來是場噩夢(mèng)啊……” “哼!你這毒婦竟也來了笔呀?” 一聲冷哼從身側(cè)響起幢踏,我...
    開封第一講書人閱讀 39,008評(píng)論 0 276
  • 序言:老撾萬榮一對(duì)情侶失蹤,失蹤者是張志新(化名)和其女友劉穎许师,沒想到半個(gè)月后房蝉,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體,經(jīng)...
    沈念sama閱讀 45,443評(píng)論 1 314
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡微渠,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 37,649評(píng)論 3 334
  • 正文 我和宋清朗相戀三年搭幻,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片逞盆。...
    茶點(diǎn)故事閱讀 39,795評(píng)論 1 347
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡檀蹋,死狀恐怖,靈堂內(nèi)的尸體忽然破棺而出云芦,到底是詐尸還是另有隱情俯逾,我是刑警寧澤,帶...
    沈念sama閱讀 35,501評(píng)論 5 345
  • 正文 年R本政府宣布舅逸,位于F島的核電站桌肴,受9級(jí)特大地震影響,放射性物質(zhì)發(fā)生泄漏琉历。R本人自食惡果不足惜坠七,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 41,119評(píng)論 3 328
  • 文/蒙蒙 一、第九天 我趴在偏房一處隱蔽的房頂上張望旗笔。 院中可真熱鬧彪置,春花似錦、人聲如沸蝇恶。這莊子的主人今日做“春日...
    開封第一講書人閱讀 31,731評(píng)論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽艘包。三九已至的猛,卻和暖如春耀盗,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背卦尊。 一陣腳步聲響...
    開封第一講書人閱讀 32,865評(píng)論 1 269
  • 我被黑心中介騙來泰國打工叛拷, 沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留,地道東北人岂却。 一個(gè)月前我還...
    沈念sama閱讀 47,899評(píng)論 2 370
  • 正文 我出身青樓忿薇,卻偏偏與公主長得像,于是被迫代替她去往敵國和親躏哩。 傳聞我的和親對(duì)象是個(gè)殘疾皇子署浩,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 44,724評(píng)論 2 354

推薦閱讀更多精彩內(nèi)容

  • Java NIO(New IO)是從Java 1.4版本開始引入的一個(gè)新的IO API,可以替代標(biāo)準(zhǔn)的Java I...
    JackChen1024閱讀 7,555評(píng)論 1 143
  • 簡介 Java NIO 是由 Java 1.4 引進(jìn)的異步 IO.Java NIO 由以下幾個(gè)核心部分組成: Ch...
    永順閱讀 1,791評(píng)論 0 15
  • 前言: 之前的文章《Java文件IO常用歸納》主要寫了Java 標(biāo)準(zhǔn)IO要注意的細(xì)節(jié)和技巧扫尺,由于網(wǎng)上各種學(xué)習(xí)途徑筋栋,...
    androidjp閱讀 2,903評(píng)論 0 22
  • 概述 NIO主要有三大核心部分:Channel(通道),Buffer(緩沖區(qū)),Selector正驻。 傳統(tǒng)IO基于...
    時(shí)之令閱讀 3,689評(píng)論 0 8
  • (轉(zhuǎn)載說明:本文非原創(chuàng)弊攘,轉(zhuǎn)載自http://ifeve.com/java-nio-all/) Java NIO: ...
    數(shù)獨(dú)題閱讀 806評(píng)論 0 3