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

隨筆-162  評論-223  文章-30  trackbacks-0
   iocp是Windows NT操作系統的一種高效IO模型,對應于Linux中的epoll和FreeBSD中的kqueue,nginx對ske(select、kqueue和epoll的首寫字母組合)的支持很好,但截止到1.6.2版本,還不支持iocp。由于ske都是反應器模式,即先注冊IO事件,當IO事件發生(讀寫通知)時,在其回調內主動調用API來讀或寫數據;而iocp是前攝器模式,要先投遞IO操作,才能引發IO事件(完成通知)的發生,在其回調內數據已被動由操作系統讀或寫完成。因此,iocp的特點決定了nginx對它的支持與ske有所不同。通過hg clone http://hg.nginx.org/nginx下載的nginx源代碼,雖然實現了iocp事件模塊、異步接受連接、部分異步讀寫,但根本不能正常工作,而且不支持異步連接和SCM服務控制,筆者在參考ske模塊的實現基礎上,改進支持了如下特性:
      1. 異步接受連接時的負載均衡
      2. 正反向代理的異步連接
      3. 異步聚合讀寫
      4. 域名解析時的UDP異步接收
      5. 異步文件傳輸
      6. SCM服務控制
   由于2、4、6均為原創,其它幾點的思路皆源于ske模塊的實現(只是平臺API不同),因此本文先闡述異步連接的實現。為了兼容select事件模塊,所有iocp相關的代碼使用NGX_HAVE_IOCP宏和(或)NGX_USE_IOCP_EVENT標志包圍,其中NGX_HAVE_IOCP宏用于條件編譯,在WIN32平臺下,定義為1;當選擇的事件模塊為iocp時,全局變量ngx_event_flags才包含NGX_USE_IOCP_EVENT標志。

異步連接對端
   由ngx_event_connect_peer函數(這里省去了與異步連接無關的代碼)實現,定義在event/ngx_event_connect.c中,因為connect不支持異步連接事件的完成通知,所以要使用擴展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}
   調用ConnectEx前要先bind本地地址,不然發生WSAEINVAL錯誤;由于域名解析可能返回IPv6記錄,導致創建本地套接字的地址族為AF_INET6,因此bind時需要匹配IPv6地址,不然發生WSAEFAULT錯誤,導致nginx返回Internal Server Error錯誤給前端,因此綁定前要調用ngx_iocp_set_localaddr設定正確的本地地址,當且僅當pc->local為空或地址族不匹配時。

本地初始化與設定
   支持IPv6,實現在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對應IPv4,sin6對應IPv6,作為bind的套接字本地地址。

   sin和sin6在啟動iocp事件模塊時調用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,表示由系統自動分配出口IP地址和未占用的端口。

   本地設定由ngx_iocp_set_localaddr實現。
 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}
   對于除IPv4和IPv6外的協議族,則記錄一個錯誤日志。必要時也可擴展支持其它的協議族,例如NetBIOS(對應地址族為AF_NETBIOS),但要看ConnectEx是否支持。
posted on 2015-06-24 17:02 春秋十二月 閱讀(7675) 評論(1)  編輯 收藏 引用 所屬分類: Opensrc

評論:
# re: nginx iocp異步連接的實現 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>
            亚洲免费影院| 久久激情五月激情| 欧美伦理91i| 久久综合九色综合久99| 麻豆成人综合网| 免费观看久久久4p| 欧美理论在线播放| 国产精品v欧美精品v日韩精品| 欧美日韩成人| 国产精品一卡| 国内精品久久久久久久果冻传媒| 国产一区二区中文| 伊人精品久久久久7777| 亚洲精品偷拍| 亚洲一级免费视频| 久久频这里精品99香蕉| 毛片av中文字幕一区二区| 亚洲第一黄色网| 亚洲精品一区二区在线观看| 亚洲天堂av在线免费| 欧美一区三区三区高中清蜜桃| 免费不卡中文字幕视频| 国产精品久久久对白| 一色屋精品视频免费看| 中国av一区| 久久久久久久久一区二区| 亚洲第一黄网| 国产精品爽黄69| 999在线观看精品免费不卡网站| 日韩亚洲欧美在线观看| 久久国内精品视频| 99国产欧美久久久精品| 久久先锋影音| 国产一区二区精品久久| 中文在线资源观看网站视频免费不卡| 欧美一进一出视频| 亚洲精品久久久一区二区三区| 午夜在线电影亚洲一区| 欧美日韩精品在线观看| 国内欧美视频一区二区| 亚洲影视九九影院在线观看| 亚洲国产欧美一区| 久久综合中文色婷婷| 国产一区二区黄色| 午夜亚洲影视| 亚洲网站在线观看| 欧美日韩另类综合| 亚洲黄网站在线观看| 久久久久九九九九| 午夜日韩电影| 国产欧美69| 欧美在线一区二区| 99这里只有久久精品视频| 欧美成人免费网站| 亚洲福利免费| 欧美成人一区在线| 狂野欧美激情性xxxx| 精品福利av| 美女黄毛**国产精品啪啪| 欧美在线视频观看| 狠色狠色综合久久| 久久一本综合频道| 久久久免费观看视频| 黄色国产精品一区二区三区| 久久久久久一区| 久久久夜夜夜| 亚洲国产裸拍裸体视频在线观看乱了中文 | 免费欧美日韩国产三级电影| 亚洲一区二区少妇| 国产精品极品美女粉嫩高清在线| 99成人免费视频| 亚洲精品久久久久中文字幕欢迎你| 欧美jizzhd精品欧美喷水 | 欧美日韩亚洲综合在线| 亚洲精品你懂的| 亚洲国产三级网| 欧美日韩免费一区二区三区| 亚洲性图久久| 亚洲自拍16p| 激情综合色综合久久| 欧美高清视频在线播放| 欧美精品色网| 亚洲资源在线观看| 欧美亚洲免费高清在线观看| 亚洲国产天堂久久国产91| 亚洲电影成人| 国产精品久久亚洲7777| 久久一区二区精品| 欧美日韩成人激情| 久久久亚洲一区| 欧美久久久久久久| 久久久国产成人精品| 欧美国产成人精品| 欧美在线影院| 欧美电影免费观看| 欧美在线关看| 欧美激情区在线播放| 午夜精品偷拍| 欧美激情va永久在线播放| 亚洲综合国产| 模特精品在线| 久久国内精品视频| 欧美日本视频在线| 蜜臀av一级做a爰片久久| 国产精品大全| 亚洲国产精品成人久久综合一区| 国产精品国产三级国产专播品爱网 | 在线亚洲国产精品网站| 欧美一区二区三区成人| 在线亚洲一区观看| 毛片基地黄久久久久久天堂 | 亚洲国产欧美久久| 国产一区二区精品久久99| 亚洲精品自在在线观看| 在线日韩欧美视频| 性欧美大战久久久久久久久| 日韩一二三在线视频播| 久久视频在线免费观看| 久久成人资源| 国产精品视频yy9299一区| 亚洲激情第一区| 亚洲国产裸拍裸体视频在线观看乱了中文 | 欧美一区三区二区在线观看| 欧美一二三视频| av成人免费在线| 久久色在线播放| 久久精品99国产精品日本| 欧美亚一区二区| 99国产麻豆精品| 亚洲午夜精品久久久久久浪潮| 欧美刺激性大交免费视频| 免费观看一级特黄欧美大片| 国产综合亚洲精品一区二| 亚洲女ⅴideoshd黑人| 亚洲欧美日韩国产一区| 欧美日韩精品免费在线观看视频| 欧美a级片网| 亚洲高清在线观看| 久久深夜福利| 亚洲第一色在线| 亚洲欧洲美洲综合色网| 蜜臀av国产精品久久久久| 你懂的成人av| 亚洲国产日韩欧美一区二区三区| 久久嫩草精品久久久久| 欧美1区2区| 亚洲精品影视| 欧美日韩另类在线| 一区二区欧美视频| 香蕉久久夜色精品国产| 国产亚洲一级高清| 美女精品网站| 99riav久久精品riav| 性视频1819p久久| 极品日韩av| 欧美精品免费观看二区| 日韩一二三在线视频播| 午夜一级久久| 亚洲电影中文字幕| 欧美日韩伦理在线| 亚洲影视在线播放| 你懂的国产精品| 亚洲午夜一区| 狠狠色丁香久久婷婷综合_中| 巨乳诱惑日韩免费av| 亚洲伦理中文字幕| 久久国产直播| 亚洲精品综合精品自拍| 国产精品久久久久久久久| 久久精品中文字幕免费mv| 亚洲人成亚洲人成在线观看| 亚洲在线观看视频网站| 亚洲成人在线网站| 欧美视频在线不卡| 久久婷婷人人澡人人喊人人爽 | 欧美在线视频日韩| 亚洲福利视频二区| 国产精品天天看| 免费成人小视频| 香蕉免费一区二区三区在线观看 | 亚洲欧美中文在线视频| 在线国产日韩| 国产精品久久久久久影院8一贰佰| 久久精品国产亚洲5555| 99国产精品久久久久久久| 久久躁狠狠躁夜夜爽| 亚洲欧美国产视频| 91久久精品国产91久久性色| 国产真实精品久久二三区| 欧美mv日韩mv国产网站app| 亚洲精品视频免费观看| 国产三区二区一区久久| 欧美久久久久中文字幕| 久久久人成影片一区二区三区观看| 91久久精品美女高潮| 美女黄色成人网| 久久久久九九九九| 欧美在线视频观看| 午夜精品久久久久久久白皮肤| 亚洲免费精品|