青青草原综合久久大伊人导航_色综合久久天天综合_日日噜噜夜夜狠狠久久丁香五月_热久久这里只有精品

隨筆-162  評(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 春秋十二月 閱讀(7675) 評(píng)論(1)  編輯 收藏 引用 所屬分類: Opensrc

評(píng)論:
# re: nginx iocp異步連接的實(shí)現(xiàn) 2015-06-24 18:42 | 傳說博客
青青草原综合久久大伊人导航_色综合久久天天综合_日日噜噜夜夜狠狠久久丁香五月_热久久这里只有精品
  • <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>
            理论片一区二区在线| 欧美一区综合| 亚洲高清网站| 亚洲蜜桃精久久久久久久 | 亚洲欧美国产精品桃花| 午夜视频久久久久久| 久久成人精品无人区| 久久综合电影| 欧美日韩中文字幕综合视频| 国产精品网曝门| 亚洲国产一区在线观看| 亚洲欧美日韩国产另类专区| 美脚丝袜一区二区三区在线观看| 亚洲精品久久久蜜桃| 亚洲国产黄色| 亚洲精品1区2区| 亚洲欧美日韩在线播放| 欧美福利视频| 国产专区欧美精品| 亚洲手机在线| 欧美国产国产综合| 亚洲欧美国产精品va在线观看| 国产日韩精品一区观看 | 国产偷国产偷精品高清尤物| 免费91麻豆精品国产自产在线观看| 麻豆精品在线视频| 国产主播一区| 99pao成人国产永久免费视频| 久久综合狠狠综合久久激情| 亚洲私人黄色宅男| 久久久久久久国产| 极品尤物久久久av免费看| 亚洲在线网站| 一本色道久久综合狠狠躁篇怎么玩 | 欧美专区在线| 国产视频精品免费播放| 亚洲国产精品999| 久久综合一区二区| 午夜影院日韩| 欧美在线视频网站| 亚洲色图在线视频| 噜噜噜91成人网| 欧美在线视频观看免费网站| 亚洲精品一二三区| 久久av在线看| 午夜精品久久久久久99热软件| 亚洲欧洲精品一区| 欧美激情一二三区| 美女主播精品视频一二三四| 性视频1819p久久| 欧美日韩成人在线播放| 一本一本久久a久久精品综合妖精 一本一本久久a久久精品综合麻豆 | 欧美日韩精品欧美日韩精品| 蜜臀99久久精品久久久久久软件| 国产精品人人做人人爽| 亚洲乱码久久| 亚洲精品欧美极品| 99视频精品全部免费在线| 欧美三级不卡| 亚洲精品极品| 日韩亚洲欧美成人一区| 99热免费精品| 亚洲一二三四区| 午夜精品一区二区三区在线视| 亚洲一区免费网站| 欧美午夜激情视频| 久久深夜福利| 欧美电影电视剧在线观看| 亚洲自拍偷拍一区| 欧美日韩国产一区二区| 亚洲毛片视频| 亚洲永久免费观看| 国产精品九九久久久久久久| 久久噜噜亚洲综合| 国产在线播放一区二区三区| 欧美一区激情| 在线午夜精品自拍| 久久久久九九九九| 免费亚洲电影在线| 日韩手机在线导航| 国产精品国产三级国产专播品爱网 | 国产亚洲精久久久久久| 亚洲人精品午夜| 亚洲私人影吧| 国产欧美精品日韩| 亚洲精品一级| 亚洲欧美日韩成人| 国产在线国偷精品产拍免费yy| 久久国产精品久久久| 欧美国产欧美亚州国产日韩mv天天看完整| 精品成人国产| 欧美精品一区二区三区蜜臀| 久久综合九色| 国产精品一区二区三区免费观看| 欧美激情一区二区久久久| 9人人澡人人爽人人精品| 国产精品永久免费| 蜜臀久久久99精品久久久久久| 免费试看一区| 欧美日韩第一页| 欧美韩国一区| 西西人体一区二区| 影音先锋久久精品| 亚洲天堂av在线免费观看| 亚洲激情在线播放| 国产精品每日更新| 亚洲最新在线视频| 久久久精品久久久久| 国产麻豆午夜三级精品| 免费成人av在线看| 亚洲影院免费观看| 欧美一区免费| 亚洲每日更新| 韩国精品一区二区三区| 欧美在线一级视频| 亚洲免费成人| 亚洲高清二区| 日韩一区二区精品葵司在线| 国产视频不卡| 国产精品久久久一区二区| 蜜桃久久精品乱码一区二区| 亚洲永久免费视频| 亚洲老板91色精品久久| 免费在线欧美黄色| 亚洲人成在线免费观看| 国产午夜精品久久久久久免费视| 欧美美女福利视频| 欧美成人精品h版在线观看| 久久精品亚洲一区| 亚洲第一久久影院| 久久网站免费| 久久久久久网站| 亚洲欧美日韩国产一区二区| 一本色道久久88综合亚洲精品ⅰ| 伊甸园精品99久久久久久| 国产麻豆91精品| 国产精品美女久久久久久久| 欧美日韩国产限制| 欧美日韩成人激情| 欧美精品1区| 香蕉久久久久久久av网站| 中文av字幕一区| 久久婷婷国产综合国色天香| 欧美主播一区二区三区| 午夜精品久久久久久久99黑人| 狠狠色丁香久久婷婷综合_中| 国产麻豆精品视频| 国产美女精品视频| 国产欧美日韩另类一区| 国产欧美日韩亚州综合| 国产欧美视频在线观看| 国产免费一区二区三区香蕉精| 国产精品久久久久久久app| 欧美视频精品在线观看| 国产精品久久久久一区二区三区 | 亚洲无线一线二线三线区别av| 亚洲精品男同| 亚洲视频在线观看| 午夜伦欧美伦电影理论片| 亚洲欧美视频在线观看| 欧美一区二区日韩一区二区| 久久国内精品视频| 欧美aaa级| 欧美激情精品久久久久久大尺度| 欧美激情亚洲视频| 在线午夜精品| 欧美在线影院| 欧美成人激情在线| 国产精品久久国产精品99gif| 国产精品人人做人人爽| 亚洲福利视频网站| 国产精品99久久久久久久久久久久| 亚洲影院高清在线| 蜜桃视频一区| 这里只有精品视频| 欧美日韩另类国产亚洲欧美一级| 亚洲主播在线| 久久精品日韩| 欧美欧美天天天天操| 国产色产综合色产在线视频| 亚洲欧洲在线免费| 性伦欧美刺激片在线观看| 麻豆精品在线观看| 在线一区二区日韩| 久久亚洲一区二区三区四区| 欧美一区二区在线播放| 噜噜噜91成人网| 国产精品视频不卡| 亚洲卡通欧美制服中文| 欧美一区二区三区四区夜夜大片| 欧美激情一区二区三区蜜桃视频| 亚洲小说春色综合另类电影| 欧美电影在线| 国产一区二区精品久久91| 夜夜嗨av一区二区三区四季av| 久久九九久久九九| 亚洲一区二区三区精品在线观看| 欧美成人激情视频免费观看| 国产日韩三区| 性欧美大战久久久久久久久|