javanio中select與channel的區(qū)別是什么

今天就跟大家聊聊有關java nio中select與channel的區(qū)別是什么,可能很多人都不太了解,為了讓大家更加了解,小編給大家總結(jié)了以下內(nèi)容,希望大家根據(jù)這篇文章可以有所收獲。

成都創(chuàng)新互聯(lián)公司成立與2013年,先為珠暉等服務建站,珠暉等地企業(yè),進行企業(yè)商務咨詢服務。為珠暉企業(yè)網(wǎng)站制作PC+手機+微官網(wǎng)三網(wǎng)同步一站式服務解決您的所有建站問題。

什么是NIO?

線程在處理數(shù)據(jù)時,如果線程還處于將數(shù)據(jù)從channel讀到buffer的這段時間內(nèi),線程可以去做別的事情,等數(shù)據(jù)都讀到buffer了,線程再回來處理讀到的數(shù)據(jù)

channel是什么?

類比流的概念。與流的區(qū)別在于

1.channel是可讀可寫的,但是一個流要么寫要么讀

2.chanel可以異步的讀和寫

3.數(shù)據(jù)總是從channel中讀到buffer,或者從buffer中寫到channel

流的讀取或?qū)懸话闶且淮涡缘牟僮?,?shù)據(jù)在讀取過程中不會有緩存,這也就意味著沒有辦法自己隨便移動到想要讀取的位置,要實現(xiàn)這個功能也就只能先緩存

java中的channel有哪些?

FileChannel:連接文件的channel,通過文件對象的getChannel方法即可獲取

FileChannel的write()方法不保證一次會寫到channel中的字節(jié)數(shù);另外它不能被設置為非阻塞,永遠只能設置成阻塞模式

1.DatagramChannel:處理UDP協(xié)議連接,通過DatagramChannel.open()然后再獲取socket執(zhí)行綁定即可端口

2.SocketChannel:它是一個已經(jīng)建立連接的TCP網(wǎng)絡socket,用來處理TCP協(xié)議連接,通過SocketChannel.open()再調(diào)用自身的connet即可建立

3.ServerSocketChannel:用來監(jiān)聽TCP連接的建立,通過ServerSocketChannel.open()可以建立,隨后就可以綁定需要監(jiān)聽的端口,并等待連接的到來,每個已建立的連接都會返回一個SocketChannel

非阻塞模式下,等待連接到來的accept方法會立馬返回,注意判斷SocketChannel是不是null;另外可能有多個連接建立,所以監(jiān)聽一般會放在一個while循環(huán)里面

Buffer是什么?

用來方便操作內(nèi)存塊中數(shù)據(jù)的一個包裝類。它有3個屬性

1.capacity:表示Buffer能容納的數(shù)據(jù)量,滿了就不能再寫

2.position:讀或者寫開始的位置

3.limit:寫模式下表示能往buffer中寫的數(shù)據(jù)量,最大值是capacity;讀模式下表示能從buffer中獲取的數(shù)據(jù)量,之前buffer中寫了多少,就能讀多少

從寫模式轉(zhuǎn)換到讀模式需要用flip()完成,調(diào)用完成之后,limit會被設置成position當時的值,而positon會被設置成0;
讀取數(shù)據(jù)完畢轉(zhuǎn)換成寫需要調(diào)用clear或者compact方法,其中clear會置position為0,limit為capacity,compact則會把原有的數(shù)據(jù)拷貝到開始的位置,然后其后的位置設置為position,limit則是capacity

mark和reset用法:在執(zhí)行讀取的時候,先mark住當前的位置,執(zhí)行讀取完成之后reset就回到原讀取數(shù)據(jù)之前的位置了

怎么讀取數(shù)據(jù)到多個Buffer?

創(chuàng)建一個數(shù)組用來放要寫的數(shù)據(jù),或者將要讀到的數(shù)據(jù),再執(zhí)行讀寫操作即可,但是這種方式不適合讀取變長消息

Buffer[] bArr = {head,body};
channel.read(bArr); //讀 ,如果head本身會放自身容量的數(shù)據(jù)然后再往body中塞
Buffer[] wArr={head,body}
channel.write(wArr);//寫

Selector是干啥的?

用來監(jiān)控多個channel的事件,比如channel的連接建立、數(shù)據(jù)到達等等

實際上可以只用一個線程來管理所有的channel

selector使用示例

//創(chuàng)建selector
Selector selector = Selector.open();
//使用Selector必須設置為false,同時意味著FileChannel是不能用Selector
channel.configureBlocking(false);
// SelectionKey一共有4種值,分別代表4個事件:connect、accept、read、write
// 通過方法 interestOps 可以得到注冊時對channel感興趣的事件,具體獲取方式為 interestSet & SelectionKey.OP_ACCEPT 得到的結(jié)果即是否為ACCEPT事件
//通過這種方式即實現(xiàn)了注冊,表明當前channel需要監(jiān)聽的是 read 事件,如果對多個事件感興趣,那么可以使用 SelectionKey.OP_READ | SelectionKey.OP_WRITE 方式實現(xiàn)
//注冊方法還可以添加另一個參數(shù),attach,用來附加更多的信息給channel,比如將Buffer給channel
SelectionKey key = channel.register(selector, SelectionKey.OP_READ);
while(true) {
//select()對channel注冊的事件如果一個都沒有好,那么阻塞住,返回值表示事件已經(jīng)發(fā)生的chanel的個數(shù);
//selectNow()則不阻塞,沒有準備好就返回0
int readyChannels = selector.select();
if(readyChannels == 0) continue;
//用來獲取準備好的channel
Set<SelectionKey> selectedKeys = selector.selectedKeys();
Iterator<SelectionKey> keyIterator = selectedKeys.iterator();
while(keyIterator.hasNext()) {
SelectionKey key = keyIterator.next();
if(key.isAcceptable()) {
//SeverSocketChannel接受了一個新的連接
} else if (key.isConnectable()) {
//和遠程已經(jīng)建立了連接
} else if (key.isReadable()) {
//channel可讀
} else if (key.isWritable()) {
//channel可寫
}
//必須手動執(zhí)行
keyIterator.remove();
}
}

wakeup:如果channel當前剛好阻塞在select,會立馬返回

看完上述內(nèi)容,你們對java nio中select與channel的區(qū)別是什么有進一步的了解嗎?如果還想了解更多知識或者相關內(nèi)容,請關注創(chuàng)新互聯(lián)行業(yè)資訊頻道,感謝大家的支持。

當前題目:javanio中select與channel的區(qū)別是什么
URL網(wǎng)址:http://bm7419.com/article18/iihsgp.html

成都網(wǎng)站建設公司_創(chuàng)新互聯(lián),為您提供建站公司、域名注冊、定制網(wǎng)站、云服務器、全網(wǎng)營銷推廣Google

廣告

聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)

h5響應式網(wǎng)站建設