狂奔 lion
          

          自強不息
          
			
          
				
					
	
          
		
          
			NIO學習之Web服務(wù)器示例
		
          
		1 根據(jù)cpu core數(shù)量確定selector數(shù)量 
          
2 用一個selector服務(wù)accept，其他selector按照core-1分配線程數(shù)運行 
          
3 accept selector作為生產(chǎn)者把獲得的請求放入隊列 
          
4 某個selector作為消費者從blocking queue中取出請求socket channel，并向自己注冊 
          
5 當獲得read信號時，selector建立工作任務(wù)線程worker，并提交給系統(tǒng)線程池 
          
6 worker線程排隊后在線程池中執(zhí)行，把協(xié)議頭讀入緩沖區(qū)，然后解析，處理，響應(yīng)，關(guān)閉連接 
          

          

          import java.io.FileInputStream;
          
          import java.io.IOException;
          
          import java.net.InetSocketAddress;
          
          import java.nio.ByteBuffer;
          
          import java.nio.channels.ClosedChannelException;
          
          import java.nio.channels.SelectionKey;
          
          import java.nio.channels.Selector;
          
          import java.nio.channels.ServerSocketChannel;
          
          import java.nio.channels.SocketChannel;
          
          import java.util.Date;
          
          import java.util.Iterator;
          
          import java.util.Set;
          
          import java.util.concurrent.ExecutorService;
          
          import java.util.concurrent.Executors;
          
          import java.util.concurrent.LinkedBlockingQueue;
          

          
          public class NioServer {
          
              private static NioServer svr = new NioServer();
          
              private final int numProcessors = Runtime.getRuntime().availableProcessors();
          
              private static LinkedBlockingQueue<SocketChannel> queue = new LinkedBlockingQueue<SocketChannel>();
          
              private static ExecutorService es = Executors.newFixedThreadPool(3);
          
    
          
              private NioServer(){}
          
    
          
              public static NioServer getInstance(){return svr;}
          
    
          
              public void init(){
          
                  try {
          
                      for(int i=0;i<numProcessors - 1;i++){
          
                Thread tk           = new Thread(new Talker());
          
                tk.start();
          
            }
          
            
          
            Selector acceptSelector           = Selector.open();
          

          
            ServerSocketChannel ssc           = ServerSocketChannel.open();
          
            ssc.configureBlocking(          false);
          

          
            InetSocketAddress isa           = new InetSocketAddress("127.0.0.1", 8080);
          
            ssc.socket().bind(isa);
          

          
            ssc.register(acceptSelector, SelectionKey.OP_ACCEPT);
          

          
                      while (acceptSelector.select() > 0) {
          
                Set          <SelectionKey> readyKeys = acceptSelector.selectedKeys();
          
                Iterator          <SelectionKey> i = readyKeys.iterator();
          

          
                          while (i.hasNext()) {
          
                    SelectionKey sk           = i.next();
          
                    i.remove();
          
                              if (sk.isAcceptable()) {
          
                        ServerSocketChannel nextReady           = (ServerSocketChannel) sk
          
                                .channel();
          
                        SocketChannel s           = nextReady.accept();
          
                        s.configureBlocking(          false);
          
                        queue.offer(s);
          
                    }
          
                }
          
            }
          
        }           catch (Exception e) {
          
            e.printStackTrace();
          
        }
          
    }
          
    
          
              private static class Talker implements Runnable{
          
                  private Selector se = null;
          

          
        
          
                  public Talker(){
          
                      try {
          
                          this.se = Selector.open();
          
            }           catch (IOException e) {
          
                e.printStackTrace();
          
            }
          
        }
          
        
          
                  public void addChannelIfAvailable(){
          
                      try {
          
                          if(queue.isEmpty())
          
                              return;
          
                SocketChannel sc           = queue.poll();
          
                sc.register(se, SelectionKey.OP_READ);
          
            }           catch (ClosedChannelException e) {
          
                e.printStackTrace();
          
            }
          
        }
          
        
          
                  public void run() {
          
                      try {
          
                          while (true) {
          
                              int skOps = se.select(20);
          
                    addChannelIfAvailable();
          
                              if(skOps <= 0){
          
                                  continue;
          
                    }
          
                    
          
                    Set          <SelectionKey> readyKeys = se.selectedKeys();
          
                    Iterator          <SelectionKey> i = readyKeys.iterator();
          
                              while (i.hasNext()) {
          
                        SelectionKey sk           = i.next();
          
                        i.remove();
          
                        
          
                                  if (sk.isValid() && sk.isReadable()) {
          
                            SocketChannel sc           = (SocketChannel) sk.channel();
          
                            sc.configureBlocking(          false);
          
                            
          
                            Worker worker           = new Worker(sc);
          
                            es.execute(worker);    
          
                        }
          
                    }
          
                    Thread.sleep(          300);
          
                }
          
            }           catch (IOException e) {
          
                e.printStackTrace();
          
            }           catch (InterruptedException e) {
          
                e.printStackTrace();
          
            }
          
        }
          
    }
          
    
          
              private static class Worker implements Runnable{
          
        ByteBuffer bb           = ByteBuffer.allocateDirect(1024);
          
        SocketChannel sc           = null;
          
        
          
                  public Worker(SocketChannel sc){
          
            Thread.currentThread().setName(          this.toString());
          
                      this.sc = sc;
          
        }
          
        
          
                  public void run() {
          
                      try {
          
                          try{
          
                    sc.read(bb);
          
                }          catch(IOException e){
          
                    e.printStackTrace();
          
                    sc.finishConnect();
          
                    sc.close();
          
                              return;
          
                }
          
                bb.flip();
          
                          byte[] bs = new byte[bb.limit()];
          
                bb.get(bs);
          
                bb.clear();
          
                
          
                StringBuilder sb           = new StringBuilder();
          
                sb.append(          "HTTP/1.1 200 OK").append("\n").append("Date:" + new Date()).append("\n");
          
                sb.append(          "Server:NIO Server By Yi Yang\n\n");
          
                bb.put(sb.toString().getBytes());
          
                
          
                bb.flip();
          
                sc.write(bb);
          
                bb.clear();
          
                
          
                FileInputStream is           = new FileInputStream("E:/test.html");
          
                is.getChannel().transferTo(          0, 1024, sc);
          
                
          
                is.close();
          
                sc.finishConnect();
          
                sc.close();
          
            }           catch (IOException e) {
          
                e.printStackTrace();
          
            }
          
        }
          
    }
          
    
          
              public static void main(String[] args) throws Exception {
          
        NioServer server           = NioServer.getInstance();
          
        server.init();
          
    }
          
}
          

          ===============06/27/10 
          
如何解析header？，以行為單位讀取，按照header敏感的關(guān)鍵字進行匹配 對于首行取得對方調(diào)用的方法GET/POST 地址 和協(xié)議版本 
          
然后根據(jù)用戶的配置，和解析地址請求，獲得響應(yīng)的servlet，并把通過反射+默認構(gòu)造函數(shù)構(gòu)造這個servlet，解析地址參數(shù)等設(shè)置到對象httpservletrequest和httpservletresponse中，然后通過反射invoke對應(yīng)的get/post/put/delete等方法，并把封裝的兩個對象作為參數(shù)傳進去，同時在response的header中傳遞一個cookie作為session的依據(jù)。
          


           @2008 楊一. 版權(quán)所有. 保留所有權(quán)利

		
          
			posted on 2010-06-25 19:19 楊一 閱讀(1970) 評論(0)  編輯  收藏  所屬分類: Java SE 
		
          
	
          
	
	


	


          
	    
    




          








          

				
			
          
			
          
				
					
          
	
          
		
          <2010年6月>
          
	
          日一二三四五六
          303112345
          6789101112
          13141516171819
          20212223242526
          27282930123
          45678910
          

          

					

          導(dǎo)航
          

					
					

          公告
          
	本人在blogjava上發(fā)表的文章及隨筆除特別聲明外均為原創(chuàng)或翻譯，作品受知識產(chǎn)權(quán)法保護并被授權(quán)遵從 知識分享協(xié)議:署名-非商業(yè)性使用-相同方式共享 歡迎轉(zhuǎn)載,請在轉(zhuǎn)載時注明作者姓名(楊一)及出處(www.aygfsteel.com/yangyi)
          
/////////////////////////////////////////
          

我的訪問者 
 

					

          常用鏈接
          


          留言簿(5)
          


		
          隨筆分類(55)
          
		
				
			
	
		
          隨筆檔案(55)
          
		
				
			
	
		
          相冊
          
		
				
			
	
		
          Java
          
		
				
			
	
		
          其他技術(shù)
          
		
				
			
	
		
          生活
          
		
				
			
	


          最新隨筆
          




          搜索
          



          積分與排名
          



          最新評論
	
          

          
	
			
		

          


          閱讀排行榜
          



          評論排行榜
          


				
			
          			
			

	

          自強不息

          
用心 - 珍惜時間，勇于創(chuàng)造
          

    







          
        
	




主站蜘蛛池模板：
玛纳斯县|
青田县|
泰来县|
团风县|
濮阳县|
渭南市|
北辰区|
汾西县|
马尔康县|
皮山县|
衡东县|
宿松县|
南陵县|
循化|
咸宁市|
浙江省|
西昌市|
东港市|
乃东县|
普兰店市|
安宁市|
页游|
鄂伦春自治旗|
民乐县|
新巴尔虎左旗|
扶沟县|
金阳县|
保山市|
和田县|
东乡族自治县|
彭泽县|
哈尔滨市|
石门县|
凌云县|
中方县|
崇仁县|
林口县|
集安市|
眉山市|
浙江省|
武山县|