使用非阻塞ServerSocketChannel、SocketChannel代替ServerSock

1. 來源：http://blog.sina.com.cn/s/blog_81c2545a01011afh.html  

1.  在使用傳統的ServerSocket和Socket的時候不少時候程序是會阻塞的  

2.   

3. 好比 serversocket.accept() , socket.getInputStream().read() 的時候都會阻塞 accept()方法除非等到客戶端socket的鏈接或者被異常中斷 不然會一直等待下去  

4.   

5. read()方法也是如此 除非在輸入流中有了足夠的數據不然該方法也會一直等待下去知道數據的到來.在ServerSocket與Socket的方式中服務器端每每要爲每個客戶端(socket)分配一個線程,而每個線程都有可能處於長時間的阻塞狀態中.而過多的線程也會影響服務器的性能.在JDK1.4引入了非阻塞的通訊方式,這樣使得服務器端只須要一個線程就能處理全部客戶端socket的請求.  

6.   

7. 下面是幾個須要用到的核心類  

8.   

9. ServerSocketChannel: ServerSocket 的替代類, 支持阻塞通訊與非阻塞通訊.   

10. SocketChannel: Socket 的替代類, 支持阻塞通訊與非阻塞通訊.   

11. Selector: 爲ServerSocketChannel 監控接收客戶端鏈接就緒事件, 爲 SocketChannel 監控鏈接服務器就緒, 讀就緒和寫就緒事件.   

12. SelectionKey: 表明 ServerSocketChannel 及 SocketChannel 向 Selector 註冊事件的句柄. 當一個 SelectionKey 對象位於Selector 對象的 selected-keys 集合中時, 就表示與這個 SelectionKey 對象相關的事件發生了.在SelectionKey 類中有幾個靜態常量   

13. SelectionKey.OP_ACCEPT       ->客戶端鏈接就緒事件 等於監聽serversocket.accept()返回一個socket   

14. SelectionKey.OP_CONNECT   ->準備鏈接服務器就緒          跟上面相似,只不過是對於socket的至關於監聽了 socket.connect()   

15. SelectionKey.OP_READ            ->讀就緒事件,  表示輸入流中已經有了可讀數據, 能夠執行讀操做了   

16. SelectionKey.OP_WRITE          ->寫就緒事件   

17.    

18.   

19. 下面是服務器端:  

20.   

21. Selector selector = Selector.open();         //靜態方法 實例化selector  

22. ServerSocketChannel serverChannel = ServerSocketChannel.open();  

23. serverChannel.configureBlocking(false);  //設置爲非阻塞方式,若是爲true 那麼就爲傳統的阻塞方式  

24. serverChannel.socket().bind(new InetSocketAddress(port));  //綁定IP 及 端口  

25. serverChannel.register(selector, SelectionKey.OP_ACCEPT); //註冊 OP_ACCEPT事件  

26.   

27. new ServerThread().start(); //開啓一個線程 處理全部請求  

28.   

29. ServerThread中的run方法  

30.   

31. view plainprint?  

32. public void run()     

33.   {     

34.    while(true)     

35.    {     

36.     try     

37.     {     

38.      selector.select();     

39.      Set<SelectionKey> keys = selector.selectedKeys();     

40.      Iterator<SelectionKey> iter = keys.iterator();     

41.      SocketChannel sc ;     

42.      while(iter.hasNext())     

43.      {     

44.       SelectionKey key = iter.next();     

45.       if(key.isAcceptable());  // 新的鏈接     

46.        else if(key.isReadable()) ;// 可讀          

47.        iter.remove(); //處理完事件的要從keys中刪去           

48.      }     

49.     catch (Exception e)     

50.     {     

51.      e.printStackTrace();     

52.     }     

53.    }     

54.   }     

55.   

56. 其中在 isAcceptable()中經過        ServerSocketChannel ssc = (ServerSocketChannel) key.channel(); SocketChannel  sc = ssc.accept(); 獲得客戶端的SocketChannel  

57.   

58. 在isReadable()中SocketChannel   sc = (SocketChannel) key.channel(); 獲得SocketChannel .   

59.   

60. 在SocketChannel 對象中能夠用write() read() 進行讀寫操做 只不過操做的對象再也不是byte[] String之類 而是ByteBuffer  

61.   

62.    

63.   

64. 客戶端基本同樣  

65.   

66.   selector = Selector.open();  

67.   channel = SocketChannel.open(new InetSocketAddress(port));  

68.   channel.configureBlocking(false);  

69.   channel.register(selector,SelectionKey.OP_CONNECT);  

70.   new ClientThread().start();  

71.   

72. run方法  

73.   

74.     while (true)  

75.     {  

76.      selector.select();  

77.      Set<SelectionKey> keys = selector.selectedKeys();  

78.      Iterator<SelectionKey> iter = keys.iterator();  

79.      while(iter.hasNext())  

80.      {  

81.       SelectionKey key = iter.next();  

82.   

83.       if(key.isConnectable());//鏈接成功&正常  

84.   

85.       else  if(key.isReadable())//可讀  

86.   

87.       iter.remove();  

88.   

89.     }  

90.   

91. 能夠經過key.channel();方法獲得當前的socketchannel對象  

92. 總結其實這裏將阻塞變爲非阻塞實際是用一個while死循環來處理的  

93. 首先經過seleector.select()從新獲得事件只要有事件不管是什麼 都交給循環體去處理 在循環體中分別進行不一樣的處理  

94. 而多個socket經過一個seleector進行贊成管理  

95. while(一直等待, 直到有接收鏈接就緒事件, 讀就緒事件或寫就緒事件發生){             //阻塞  

96.               if(有客戶鏈接) 

97.                    接收客戶的鏈接;                                                    //非阻塞  

98.               if(某個 Socket 的輸入流中有可讀數據)  

99.                  從輸入流中讀數據;                                                 //非阻塞  

100.               if(某個 Socket 的輸出流能夠寫數據)  

101.                    向輸出流寫數據;                                                    //非阻塞  

102.        }  

103.   

104. 相似這樣  以上處理流程採用了輪詢的工做方式, 當某一種操做就緒時, 就執行該操做, 不然就查看是否還有其餘就緒的操做能夠執行. 線程不會由於某一個操做尚未就緒, 就進入阻塞狀態, 一直傻傻地在那裏等待這個操做就緒.