nginx中的阻塞和非阻塞设置

雨点打透心脏的1/2处 2022-06-18 00:56 278阅读 0赞

纵然对于select,epoll这2个模型，既可以使用阻塞模式的socket也可以使用非阻塞的

虽然，但是这2个模型的消息通知可以防止accetp,recv在阻塞模式下的进入阻塞状态，却不能防止NGINX主动发出的connect和send进入阻塞状态

特别是NGINX是单线程模型，任何调用的阻塞状态都会造成整个线程阻塞甚至挂起，这对NGINX来说是完全不能接受的

因此在ngx\_open\_listening\_sockets函数中，对所有listen socket，除非是IOCP或者UNIX\_AIO模型，都把这个socket设置成非阻塞模式，代码如下：

if (!(ngx\_event\_flags & NGX\_USE\_AIO\_EVENT)) \{  
if (ngx\_nonblocking(s) == -1) \{  
ngx\_log\_error(NGX\_LOG\_EMERG, log, ngx\_socket\_errno,  
ngx\_nonblocking\_n " %V failed",  
&ls\[i\].addr\_text);  
  
  
if (ngx\_close\_socket(s) == -1) \{  
ngx\_log\_error(NGX\_LOG\_EMERG, log, ngx\_socket\_errno,  
ngx\_close\_socket\_n " %V failed",  
&ls\[i\].addr\_text);  
\}  
  
  
return NGX\_ERROR;  
\}  
\}

而在ngx\_event\_accept中，也有一样的实现逻辑

/\* set a blocking mode for aio and non-blocking mode for others \*/  
  
  
if (ngx\_inherited\_nonblocking) \{  
if (ngx\_event\_flags & NGX\_USE\_AIO\_EVENT) \{  
if (ngx\_blocking(s) == -1) \{  
ngx\_log\_error(NGX\_LOG\_ALERT, ev->log, ngx\_socket\_errno,  
ngx\_blocking\_n " failed");  
ngx\_close\_accepted\_connection(c);  
return;  
\}  
\}  
  
  
\} else \{  
if (!(ngx\_event\_flags & (NGX\_USE\_AIO\_EVENT|NGX\_USE\_RTSIG\_EVENT))) \{  
if (ngx\_nonblocking(s) == -1) \{  
ngx\_log\_error(NGX\_LOG\_ALERT, ev->log, ngx\_socket\_errno,  
ngx\_nonblocking\_n " failed");  
ngx\_close\_accepted\_connection(c);  
return;  
\}  
\}  
\}

比较特殊的是connect，unix平台的传统的做法都是让connect的socket进入非阻塞模式，NGINX也是这样，在ngx\_event\_connect\_peer中，直接设置成非阻塞模式了事

if (ngx\_nonblocking(s) == -1) \{  
ngx\_log\_error(NGX\_LOG\_ALERT, pc->log, ngx\_socket\_errno,  
ngx\_nonblocking\_n " failed");  
  
  
goto failed;  
\}

另外补充一点，win平台上的WsaAysncSelect以及WsaEventSelect会自动把套接口设置成非阻塞模式，因此不管connect,send,accept,recv都是非阻塞模式，并且有各自对应的通知消息类型