NioSocket簡單復(fù)習(xí)

創(chuàng)新互聯(lián)建站憑借專業(yè)的設(shè)計(jì)團(tuán)隊(duì)扎實(shí)的技術(shù)支持、優(yōu)質(zhì)高效的服務(wù)意識(shí)和豐厚的資源優(yōu)勢(shì),提供專業(yè)的網(wǎng)站策劃、成都網(wǎng)站建設(shè)、
網(wǎng)站設(shè)計(jì)、網(wǎng)站優(yōu)化、軟件開發(fā)、網(wǎng)站改版等服務(wù),在成都10余年的網(wǎng)站建設(shè)設(shè)計(jì)經(jīng)驗(yàn),為成都上千余家中小型企業(yè)策劃設(shè)計(jì)了網(wǎng)站。
重要概念
NioSocket里面的三個(gè)重要概念:Buffer、Channel、Selector
- Buffer為要傳輸?shù)臄?shù)據(jù)
- Channel為傳輸數(shù)據(jù)的通道
- Selector為通道的分配調(diào)度者
使用步驟
使用NioSocket實(shí)現(xiàn)通信大概如以下步驟:
- ServerSocketChannel可以通過configureBlocking方法來設(shè)置是否采用阻塞模式,設(shè)置為false后就可以調(diào)用register注冊(cè)Selector,阻塞模式下不可以用Selector。
- 注冊(cè)后,Selector就可以通過select()來等待請(qǐng)求,通過參數(shù)設(shè)置等待時(shí)長,若傳入?yún)?shù)0或者不傳入?yún)?shù),將會(huì)采用阻塞模式直到有請(qǐng)求出現(xiàn)。
- 接收到請(qǐng)求后Selector調(diào)用selectedKeys方法,返回SelectedKey集合。
- SelectedKey保存了處理當(dāng)前請(qǐng)求的Channel和Selector,并提供了不同的操作類型。四種操作屬性:SelectedKey.OP_ACCEPT、SelectedKey.OP_CONNECT、SelectedKey.OP_READ、SelectedKey.OP_WRITE。
- 通過SelectedKey的isAcceptable、isConnectable、isReadable和isWritable來判斷操作類型,并處理相應(yīng)操作。
- 在相應(yīng)的Handler中提取SelectedKey中的Channel和Buffer信息并執(zhí)行相應(yīng)操作。
實(shí)現(xiàn)HTTP
創(chuàng)建HttpServer類作為程序的主要入口
public class HttpServer {
public static void main(String[] args) throws Exception{
ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();
serverSocketChannel.socket().bind(new InetSocketAddress((8080)));
serverSocketChannel.configureBlocking(false);
Selector selector = Selector.open();
// It must be ACCEPT, or it will throw exception
serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);
while(true){
if (selector.select(3000) == 0){
continue;
}
Iterator keyIter = selector.selectedKeys().iterator();
while (keyIter.hasNext()){
SelectionKey key = keyIter.next();
new Thread(new HttpHandler(key)).run();
keyIter.remove();
}
}
}
}
標(biāo)題名稱:Java使用NioSocket手動(dòng)實(shí)現(xiàn)HTTP服務(wù)器-創(chuàng)新互聯(lián)
鏈接地址:
http://www.weahome.cn/article/dpcihg.html