NioSocket簡(jiǎn)單復(fù)習(xí)
創(chuàng)新互聯(lián)主營(yíng)電白網(wǎng)站建設(shè)的網(wǎng)絡(luò)公司,主營(yíng)網(wǎng)站建設(shè)方案,app軟件開(kāi)發(fā)公司,電白h5小程序定制開(kāi)發(fā)搭建,電白網(wǎng)站營(yíng)銷推廣歡迎電白等地區(qū)企業(yè)咨詢
重要概念
NioSocket里面的三個(gè)重要概念:Buffer、Channel、Selector
使用步驟
使用NioSocket實(shí)現(xiàn)通信大概如以下步驟:
實(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<SelectionKey> keyIter = selector.selectedKeys().iterator(); while (keyIter.hasNext()){ SelectionKey key = keyIter.next(); new Thread(new HttpHandler(key)).run(); keyIter.remove(); } } } }
以上代碼的邏輯大致遵循著NioSocket的大概用法,其中serverSocketChannel使用register方法注冊(cè)到selector僅是OP_ACCEPT,使用其他操作就會(huì)操作。但是并不是說(shuō)不能進(jìn)行其他操作,而是其他操作稍后實(shí)現(xiàn)。
在serverSocketChannel.configureBlocking(false)后,非阻塞模式啟動(dòng)。Server接收到請(qǐng)求后就會(huì)將記錄了請(qǐng)求信息的key交給HttpHandler做詳細(xì)處理,處理完就把key從迭代器里面remove掉??梢钥吹匠鰜?lái),HttpServer對(duì)請(qǐng)求里面的信息一概不知,這樣才能成為一個(gè)出色的管理層,它管理著HttpHandler來(lái)處理請(qǐng)求。
既然選用了NioSocket這樣的New IO,HttpHandler必然是多線程的實(shí)現(xiàn)(否則還有什么意義)。
創(chuàng)建HttpHandler來(lái)處理請(qǐng)求
對(duì)于來(lái)自HttpServer的不加工信息,HttpHandler必須要做全套,因此需要HttpHandler自己考慮好有沒(méi)有中文亂碼、Buffer大小是多少等等。HttpHandler大概框架如下即可:
class HttpHandler implements Runnable{ private int bufferSize = 1024; private String localCharset = "UTF-8"; private SelectionKey key; public HttpHandler(SelectionKey key){ this.key = key; } public void handleAccept() throws IOException{} public void handleRead() throws IOException{} @Override public void run() { try { if(key.isAcceptable()){ handleAccept(); } if(key.isReadable()){ handleRead(); } }catch (IOException ex){ ex.printStackTrace(); } } }
如上框架簡(jiǎn)單明了,重載run實(shí)現(xiàn)多線程,handleAccept和handleRead用于詳細(xì)地處理相關(guān)操作,bufferSize規(guī)定Buffer大小,localCharset的設(shè)定提前防止中文亂碼。
需要注意的是HttpServer里面,我們只注冊(cè)了OP_ACCEPT這個(gè)操作,那么在HttpHandler里面只有isAcceptable()判定為真,那么handleRead()怎么辦呢?我們會(huì)在handleAccept()注冊(cè)好的:
public void handleAccept() throws IOException{ SocketChannel clientChannel = ((ServerSocketChannel)key.channel()).accept(); clientChannel.configureBlocking(false); clientChannel.register( key.selector(), SelectionKey.OP_READ, ByteBuffer.allocate(bufferSize) ); }
在handleAccept里面,我們先取得key里面的請(qǐng)求信息,如對(duì)應(yīng)客戶端的SocketChannel (SocketChannel需要ServerSocketChannel接受了后才有),接著就可以為SocketChannel注冊(cè)O(shè)P_READ操作了,帶上指定大小的Buffer。注冊(cè)后,key可是isReadable()了,接下來(lái)則是在handleRead中對(duì)key進(jìn)行解剖處理:(代碼有點(diǎn)長(zhǎng),但大多是控制臺(tái)輸出和對(duì)字符串的拼接操作,看官可放心食用。)
public void handleRead() throws IOException{ SocketChannel sc = (SocketChannel)key.channel(); ByteBuffer buffer = (ByteBuffer)key.attachment(); buffer.clear(); if (sc.read(buffer) == -1){ sc.close(); }else { buffer.flip(); String receiveString = Charset.forName(localCharset).newDecoder().decode(buffer).toString(); String[] requestMessage = receiveString.split("\r\n"); for (String s: requestMessage){ System.out.println(s); if (s.isEmpty()){ break; } } String[] firstLine = requestMessage[0].split(" "); System.out.println(); System.out.println("Method:\t"+ firstLine[0]); System.out.println("url:\t"+firstLine[1]); System.out.println("HTTP Version:\t" + firstLine[2]); System.out.println(); StringBuilder sendString = new StringBuilder(); sendString.append("HTTP/1.1 200 OK\r\n"); sendString.append("Content-Type:text/html;Charset="+localCharset+"\r\n"); sendString.append("\r\n"); sendString.append("<html><head><title>SHOW</title></head></body>"); sendString.append("Received:<br/>"); for (String s : requestMessage){ sendString.append(s + "<br/>"); } sendString.append("</body></html>"); buffer = ByteBuffer.wrap(sendString.toString().getBytes(localCharset)); sc.write(buffer); sc.close(); } }
handleRead開(kāi)頭先獲取到對(duì)應(yīng)的SocketChannel和ByteBuffer,就這兩個(gè)最為關(guān)鍵,SocketChannel負(fù)責(zé)與客戶端的鏈接和傳輸數(shù)據(jù),而ByteBuffer充當(dāng)數(shù)據(jù)運(yùn)輸?shù)妮d體。
而后則是簡(jiǎn)單的判斷連接狀態(tài),若是連接,將相關(guān)信息輸出到控制臺(tái),并拼接出HTTP頭的字符串發(fā)送至客戶端。
效果如圖:
以上就是本文的全部?jī)?nèi)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持創(chuàng)新互聯(lián)。
網(wǎng)頁(yè)標(biāo)題:Java使用NioSocket手動(dòng)實(shí)現(xiàn)HTTP服務(wù)器
標(biāo)題鏈接:http://bm7419.com/article24/jccgje.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供網(wǎng)站設(shè)計(jì)、企業(yè)建站、定制開(kāi)發(fā)、服務(wù)器托管、自適應(yīng)網(wǎng)站、營(yíng)銷型網(wǎng)站建設(shè)
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請(qǐng)盡快告知,我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如需處理請(qǐng)聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時(shí)需注明來(lái)源: 創(chuàng)新互聯(lián)