• <ins id="pjuwb"></ins>
    <blockquote id="pjuwb"><pre id="pjuwb"></pre></blockquote>
    <noscript id="pjuwb"></noscript>
          <sup id="pjuwb"><pre id="pjuwb"></pre></sup>
            <dd id="pjuwb"></dd>
            <abbr id="pjuwb"></abbr>
            隨筆-159  評(píng)論-223  文章-30  trackbacks-0
               iocp是Windows NT操作系統(tǒng)的一種高效IO模型,對(duì)應(yīng)于Linux中的epoll和FreeBSD中的kqueue,nginx對(duì)ske(select、kqueue和epoll的首寫字母組合)的支持很好,但截止到1.6.2版本,還不支持iocp。由于ske都是反應(yīng)器模式,即先注冊(cè)IO事件,當(dāng)IO事件發(fā)生(讀寫通知)時(shí),在其回調(diào)內(nèi)主動(dòng)調(diào)用API來讀或?qū)憯?shù)據(jù);而iocp是前攝器模式,要先投遞IO操作,才能引發(fā)IO事件(完成通知)的發(fā)生,在其回調(diào)內(nèi)數(shù)據(jù)已被動(dòng)由操作系統(tǒng)讀或?qū)懲瓿伞R虼耍琲ocp的特點(diǎn)決定了nginx對(duì)它的支持與ske有所不同。通過hg clone http://hg.nginx.org/nginx下載的nginx源代碼,雖然實(shí)現(xiàn)了iocp事件模塊、異步接受連接、部分異步讀寫,但根本不能正常工作,而且不支持異步連接和SCM服務(wù)控制,筆者在參考ske模塊的實(shí)現(xiàn)基礎(chǔ)上,改進(jìn)支持了如下特性:
                  1. 異步接受連接時(shí)的負(fù)載均衡
                  2. 正反向代理的異步連接
                  3. 異步聚合讀寫
                  4. 域名解析時(shí)的UDP異步接收
                  5. 異步文件傳輸
                  6. SCM服務(wù)控制
               由于2、4、6均為原創(chuàng),其它幾點(diǎn)的思路皆源于ske模塊的實(shí)現(xiàn)(只是平臺(tái)API不同),因此本文先闡述異步連接的實(shí)現(xiàn)。為了兼容select事件模塊,所有iocp相關(guān)的代碼使用NGX_HAVE_IOCP宏和(或)NGX_USE_IOCP_EVENT標(biāo)志包圍,其中NGX_HAVE_IOCP宏用于條件編譯,在WIN32平臺(tái)下,定義為1;當(dāng)選擇的事件模塊為iocp時(shí),全局變量ngx_event_flags才包含NGX_USE_IOCP_EVENT標(biāo)志。

            異步連接對(duì)端
               由ngx_event_connect_peer函數(shù)(這里省去了與異步連接無關(guān)的代碼)實(shí)現(xiàn),定義在event/ngx_event_connect.c中,因?yàn)閏onnect不支持異步連接事件的完成通知,所以要使用擴(kuò)展API ConnectEx。 
             1ngx_int_t ngx_event_connect_peer(ngx_peer_connection_t *pc)
             2{
             3    int                rc;
             4    ngx_int_t          event;
             5    ngx_err_t          err;
             6    ngx_uint_t         level,family;
             7    ngx_socket_t       s;
             8    ngx_event_t       *rev, *wev;
             9    
            10    s = ngx_socket(family = pc->sockaddr->sa_family, SOCK_STREAM, 0);
            11              
            12    #if (NGX_HAVE_IOCP)
            13    if((pc->local==NULL||pc->local->sockaddr->sa_family != family) 
            14        && (ngx_event_flags & NGX_USE_IOCP_EVENT)){
            15        if(ngx_iocp_set_localaddr(pc->log,family,&pc->local) != NGX_OK)
            16            goto failed;    
            17    }

            18    #endif
            19       
            20    
            21    #if (NGX_HAVE_IOCP)
            22    if(ngx_event_flags&NGX_USE_IOCP_EVENT){        
            23        LPWSAOVERLAPPED   ovlp;
            24        ovlp = (LPWSAOVERLAPPED)&wev->ovlp;
            25        ngx_memzero(ovlp,sizeof(WSAOVERLAPPED));
            26        wev->ovlp.type = NGX_IOCP_CONNECT;
            27        rc = ngx_connectex(s,pc->sockaddr,pc->socklen,NULL,0,NULL,ovlp) ? 0 : -1;
            28    
            29    }
            else
            30        rc = connect(s, pc->sockaddr, pc->socklen);
            31    #else
            32      rc = connect(s, pc->sockaddr, pc->socklen);
            33    #endif
            34    
            35    if (rc == -1{
            36        err = ngx_socket_errno;
            37        if (err != NGX_EINPROGRESS
            38    #if (NGX_WIN32)
            39        /* Winsock returns WSAEWOULDBLOCK (NGX_EAGAIN) */
            40        && err != NGX_EAGAIN
            41    #if (NGX_HAVE_IOCP)
            42        && err != WSA_IO_PENDING
            43    #endif
            44    #endif
            45            ){
            46            
            47            ngx_log_error(level, c->log, err, "connect() to %V failed", pc->name);
            48            ngx_close_connection(c);
            49            pc->connection = NULL;
            50          
            51            return NGX_DECLINED;
            52        }

            53    }

            54    
            55}
               調(diào)用ConnectEx前要先bind本地地址,不然發(fā)生WSAEINVAL錯(cuò)誤;由于域名解析可能返回IPv6記錄,導(dǎo)致創(chuàng)建本地套接字的地址族為AF_INET6,因此bind時(shí)需要匹配IPv6地址,不然發(fā)生WSAEFAULT錯(cuò)誤,導(dǎo)致nginx返回Internal Server Error錯(cuò)誤給前端,因此綁定前要調(diào)用ngx_iocp_set_localaddr設(shè)定正確的本地地址,當(dāng)且僅當(dāng)pc->local為空或地址族不匹配時(shí)。

            本地初始化與設(shè)定
               支持IPv6,實(shí)現(xiàn)在event/modules/ngx_iocp_module.c。
               地址變量定義如下。
            1static struct sockaddr_in  sin;
            2#if (NGX_HAVE_INET6)
            3static struct sockaddr_in6  sin6;
            4#endif
            5static ngx_addr_t           local_addr;
               sin對(duì)應(yīng)IPv4,sin6對(duì)應(yīng)IPv6,作為bind的套接字本地地址。

               sin和sin6在啟動(dòng)iocp事件模塊時(shí)調(diào)用ngx_iocp_init初始化。   
             1static ngx_int_t ngx_iocp_init(ngx_cycle_t *cycle, ngx_msec_t timer)
             2{
             3    
             4  sin.sin_family = AF_INET;
             5  sin.sin_port = 0;
             6  sin.sin_addr.s_addr = INADDR_ANY;
             7    
             8#if (NGX_HAVE_INET6)
             9    sin6.sin6_family = AF_INET6;
            10    sin6.sin6_port = 0;
            11    sin6.sin6_addr = in6addr_any;
            12#endif
            13    
            14  local_addr.name.len = sizeof("INADDR_ANY"- 1;
            15  local_addr.name.data = (u_char *)"INADDR_ANY";    
            16    
            17}
               不論IP地址或端口,都指定為0,表示由系統(tǒng)自動(dòng)分配出口IP地址和未占用的端口。

               本地設(shè)定由ngx_iocp_set_localaddr實(shí)現(xiàn)。
             1ngx_int_t ngx_iocp_set_localaddr(ngx_log_t *log, in_port_t family, ngx_addr_t **local)
             2{
             3    struct sockaddr *sa;
             4    socklen_t len;
             5    
             6    if(AF_INET == family){            
             7        sa = &sin;
             8        len = sizeof(struct sockaddr_in);        
             9    }

            10#if (NGX_HAVE_INET6)
            11    else if(AF_INET6 == family){
            12        sa = &sin6;
            13        len = sizeof(struct sockaddr_in6);
            14    }

            15#endif
            16    else{
            17        ngx_log_error(NGX_LOG_ALERT, log, 0"not supported address family");
            18        return NGX_ERROR;        
            19    }

            20
            21    local_addr.sockaddr = sa;
            22    local_addr.socklen = len;
            23    *local = &local_addr;
            24
            25    return NGX_OK;
            26}
               對(duì)于除IPv4和IPv6外的協(xié)議族,則記錄一個(gè)錯(cuò)誤日志。必要時(shí)也可擴(kuò)展支持其它的協(xié)議族,例如NetBIOS(對(duì)應(yīng)地址族為AF_NETBIOS),但要看ConnectEx是否支持。
            posted on 2015-06-24 17:02 春秋十二月 閱讀(7630) 評(píng)論(1)  編輯 收藏 引用 所屬分類: Opensrc

            評(píng)論:
            # re: nginx iocp異步連接的實(shí)現(xiàn) 2015-06-24 18:42 | 傳說博客
            久久香蕉一级毛片| 93精91精品国产综合久久香蕉 | 欧美黑人激情性久久| 久久久久se色偷偷亚洲精品av | 久久99精品久久久久久秒播| 久久久精品一区二区三区| 亚洲精品蜜桃久久久久久| 色婷婷久久综合中文久久蜜桃av| 伊人久久大香线蕉AV一区二区| 日韩精品久久久肉伦网站| 久久精品国产亚洲AV香蕉| 久久精品国产2020| 亚洲国产欧洲综合997久久| 人妻无码αv中文字幕久久琪琪布| 成人午夜精品无码区久久| 久久久久国产一级毛片高清版| 国产精品久久永久免费| 色妞色综合久久夜夜| 欧美综合天天夜夜久久| 亚洲天堂久久精品| 午夜精品久久久久9999高清| 九九精品99久久久香蕉| 亚洲婷婷国产精品电影人久久| 亚洲а∨天堂久久精品| 2021国内精品久久久久久影院| 久久精品亚洲一区二区三区浴池 | 久久国产精品99精品国产987| 欧美大战日韩91综合一区婷婷久久青草 | 久久久久99精品成人片直播| 久久免费美女视频| 最新久久免费视频| 国产韩国精品一区二区三区久久| 久久国产影院| 国产精品一区二区久久精品无码| 久久久久无码精品国产| 色播久久人人爽人人爽人人片aV| 精品久久久无码21p发布| 色综合久久最新中文字幕| 亚洲午夜无码久久久久小说| 精品久久一区二区| 精品国产乱码久久久久久人妻|