狂奔 lion
          

          自強(qiáng)不息
          
			
          
				
					
	
          
		
          
			NIO學(xué)習(xí)之Web服務(wù)器示例
		
          
		1 根據(jù)cpu core數(shù)量確定selector數(shù)量 
          
2 用一個(gè)selector服務(wù)accept，其他selector按照core-1分配線程數(shù)運(yùn)行 
          
3 accept selector作為生產(chǎn)者把獲得的請(qǐng)求放入隊(duì)列 
          
4 某個(gè)selector作為消費(fèi)者從blocking queue中取出請(qǐng)求socket channel，并向自己注冊(cè) 
          
5 當(dāng)獲得read信號(hào)時(shí)，selector建立工作任務(wù)線程worker，并提交給系統(tǒng)線程池 
          
6 worker線程排隊(duì)后在線程池中執(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)鍵字進(jìn)行匹配 對(duì)于首行取得對(duì)方調(diào)用的方法GET/POST 地址 和協(xié)議版本 
          
然后根據(jù)用戶的配置，和解析地址請(qǐng)求，獲得響應(yīng)的servlet，并把通過(guò)反射+默認(rèn)構(gòu)造函數(shù)構(gòu)造這個(gè)servlet，解析地址參數(shù)等設(shè)置到對(duì)象httpservletrequest和httpservletresponse中，然后通過(guò)反射invoke對(duì)應(yīng)的get/post/put/delete等方法，并把封裝的兩個(gè)對(duì)象作為參數(shù)傳進(jìn)去，同時(shí)在response的header中傳遞一個(gè)cookie作為session的依據(jù)。
          


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

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


	


          
	    
    




          








          

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

          

					

          導(dǎo)航
          

					
					

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

我的訪問(wèn)者 
 

					

          常用鏈接
          


          留言簿(5)
          


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


          最新隨筆
          




          搜索
          



          積分與排名
          



          最新評(píng)論
	
          

          
	
			
		

          


          閱讀排行榜
          



          評(píng)論排行榜
          


				
			
          			
			

	

          自強(qiáng)不息

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

    







          
        
	




主站蜘蛛池模板：
馆陶县|
彭泽县|
青冈县|
云阳县|
平凉市|
广水市|
深水埗区|
巨野县|
腾冲县|
泾阳县|
北宁市|
绥滨县|
宁化县|
义乌市|
清苑县|
延庆县|
黑水县|
武汉市|
浮山县|
富川|
中江县|
五常市|
青川县|
梨树县|
垫江县|
南陵县|
阳江市|
阳泉市|
囊谦县|
平潭县|
扶风县|
陵川县|
巴东县|
墨脱县|
怀仁县|
伊金霍洛旗|
子长县|
彰化市|
油尖旺区|
濉溪县|
富阳市|