<rt id="bn8ez"></rt>
<label id="bn8ez"></label>
  • 

    • <span id="bn8ez"></span>
    

    <label id="bn8ez"><meter id="bn8ez"></meter></label>
    

    
    

    




    







												


        

    狂奔 lion
    

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

    

    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敏感的關鍵字進行匹配 對于首行取得對方調用的方法GET/POST 地址 和協議版本 
    
然后根據用戶的配置，和解析地址請求，獲得響應的servlet，并把通過反射+默認構造函數構造這個servlet，解析地址參數等設置到對象httpservletrequest和httpservletresponse中，然后通過反射invoke對應的get/post/put/delete等方法，并把封裝的兩個對象作為參數傳進去，同時在response的header中傳遞一個cookie作為session的依據。
    


     @2008 楊一. 版權所有. 保留所有權利

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


	


    
	    
    




    








    

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

    

					

    導航
    

					
					

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

我的訪問者 
 

					

    常用鏈接
    


    留言簿(5)
    


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


    最新隨筆
    




    搜索
    



    積分與排名
    



    最新評論
	
    

    
	
			
		

    


    閱讀排行榜
    



    評論排行榜
    


				
			
    			
			

	

    自強不息

    
用心 - 珍惜時間，勇于創造
    

    







    
        
	



主站蜘蛛池模板：
4虎永免费最新永久免费地址|
亚洲综合精品香蕉久久网97|
亚洲伊人久久大香线蕉影院|
久久精品免费一区二区三区|
亚洲中文字幕无码一区|
亚洲精品成a人在线观看夫|
免费看黄视频网站|
亚洲性无码av在线|
aⅴ免费在线观看|
18亚洲男同志videos网站|
久久久久久久久久国产精品免费|
亚洲中文字幕视频国产|
四虎精品免费永久免费视频|
国产免费小视频在线观看|
国产精品亚洲天堂|
免费一级做a爰片性色毛片|
色窝窝亚洲AV网在线观看|
国产精品免费_区二区三区观看|
亚洲欧美国产欧美色欲|
国产色婷婷精品免费视频|
在线观看亚洲电影|
国产一区二区三区免费在线观看
|
免费欧洲毛片A级视频无风险|
亚洲国产美女精品久久久|
日韩精品免费电影|
另类小说亚洲色图|
亚洲七七久久精品中文国产|
97在线免费视频|
亚洲电影中文字幕|
6080午夜一级毛片免费看6080夜福利|
亚洲精品自拍视频|
午夜宅男在线永久免费观看网|
亚洲国产精品日韩av不卡在线|
婷婷亚洲天堂影院|
a级毛片免费完整视频|
亚洲视频精品在线|
999在线视频精品免费播放观看|
亚洲欧美日韩中文字幕在线一区|
国产女高清在线看免费观看|
最近国语视频在线观看免费播放
|
亚洲中文字幕无码中文字在线|