I/O多路复用详解

ゝ一世哀愁。 2024-04-19 13:43 0阅读 0赞

一、五种I/O模型

1、阻塞I/O模型

最流行的I/O模型是阻塞I/O模型，缺省情形下，所有套接口都是阻塞的。我们以数据报套接口为例来讲解此模型（我们使用UDP而不是TCP作为例子的原因在于就UDP而言，数据准备好读取的概念比较简单：要么整个数据报已经收到，要么还没有。然而对于TCP来说，诸如套接口低潮标记等额外变量开始活动，导致这个概念变得复杂）。

进程调用recvfrom，其系统调用直到数据报到达且被拷贝到应用进程的缓冲区中或者发生错误才返回，期间一直在等待。我们就说进程在从调用recvfrom开始到它返回的整段时间内是被阻塞的。

2、非阻塞I/O模型

进程把一个套接口设置成非阻塞是在通知内核：当所请求的I/O操作非得把本进程投入睡眠才能完成时，不要把本进程投入睡眠，而是返回一个错误。也就是说当数据没有到达时并不等待，而是以一个错误返回。

3、I/O复用模型

调用select或poll，在这两个系统调用中的某一个上阻塞，而不是阻塞于真正I/O系统调用。 阻塞于select调用，等待数据报套接口可读。当select返回套接口可读条件时，调用recevfrom将数据报拷贝到应用缓冲区中。

4、信号驱动I/O模型

首先开启套接口信号驱动I/O功能, 并通过系统调用sigaction安装一个信号处理函数（此系统调用立即返回，进程继续工作，它是非阻塞的）。当数据报准备好被读时，就为该进程生成一个SIGIO信号。随即可以在信号处理程序中调用recvfrom来读数据报，井通知主循环数据已准备好被处理中。也可以通知主循环，让它来读数据报。

5、异步I/O模型

告知内核启动某个操作，并让内核在整个操作完成后(包括将数据从内核拷贝到用户自己的缓冲区)通知我们。这种模型与信号驱动模型的主要区别是：  
           信号驱动I/O：由内核通知我们何时可以启动一个I/O操作，  
           异步I/O模型：由内核通知我们I/O操作何时完成。

二、I/O复用的典型应用场合：

1、当客户处理多个描述字（通常是交互式输入和网络套接口）时，必须使用I/O复用。

2、如果一个服务器要处理多个服务或者多个协议（例如既要处理TCP，又要处理UDP），一般就要使用I/O复用。

三、支持I/O复用的系统调用

目前支持I/O复用的系统调用有select、pselect、poll、epoll：

1、select函数

该函数允许进程指示内核等待多个事件中的任何一个发生，并仅在有一个或多个事件发生或经历一段指定的时间后才唤醒它。

格式为：

[view source][]

[print][] [?][Link 1]

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">1</span></code></td> 
   <td><code><span style="font-size:medium;">#include &lt;sys/select.h&gt; </span></code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">2</span></code></td> 
   <td><code><span style="font-size:medium;">#include &lt;sys/time.h&gt; </span></code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">4</span></code></td> 
   <td><span style="font-size:medium;"><code><strong><span style="color:#808080;">int</span></strong></code> <code>select(</code><code><strong><span style="color:#808080;">int</span></strong></code> <code>maxfdp1, fd_set *readset, fd_set *writeset, fd_set *exceptset, </code><code><strong><span style="color:#006699;">const</span></strong></code> <code><strong><span style="color:#006699;">struct</span></strong></code> <code>timeval *timeout); </code></span></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">6</span></code></td> 
   <td><span style="font-size:medium;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>返回：就绪描述字的正数目，0－超时，-1－出错</code></span></td> 
  </tr> 
 </tbody> 
</table>

我们从该函数的最后一个参数开始介绍，它告知内核等待所指定描述字中的任何一个就绪可花多少时间。其timeval结构用于指定这段时间的秒数和微秒数。

struct timeval\{

long tv\_sec;   //seconds

long tv\_usec;  //microseconds

\};

这个参数有三种可能：

（1）永远等待下去：仅在有一个描述字准备好I/O时才返回。为此，我们把该参数设置为空指针。

（2）等待一段固定时间：在有一个描述字准备好I/O时返回，但是不超过由该参数所指向的timeval结构中指定的秒数和微秒数。

（3）根本不等待：检查描述字后立即返回，这称为轮询。为此，该参数必须指向一个timeval结构，而且其中的定时器值必须为0。

中间的三个参数readset、writeset和exceptset指定我们要让内核测试读、写和异常条件的描述字。如果我们对某一个的条件不感兴趣，就可以把它设为空指针。struct fd\_set可以理解为一个集合，这个集合中存放的是文件描述符，可通过以下四个宏进行设置：

void FD\_ZERO(fd\_set \*fdset);           //清空集合

void FD\_SET(int fd, fd\_set \*fdset);   //将一个给定的文件描述符加入集合之中

void FD\_CLR(int fd, fd\_set \*fdset);   //将一个给定的文件描述符从集合中删除

int FD\_ISSET(int fd, fd\_set \*fdset);   // 检查集合中指定的文件描述符是否可以读写 ?

目前支持的异常条件只有两个：

（1）某个套接口的带外数据的到达。

（2）某个已置为分组方式的伪终端存在可从其主端读取的控制状态信息。

第一个参数maxfdp1指定待测试的描述字个数，它的值是待测试的最大描述字加1（因此我们把该参数命名为maxfdp1），描述字0、1、2...maxfdp1-1均将被测试。

一个应用select的例子：

[view source][]

[print][] [?][Link 1]

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">002</span></code></td> 
   <td><span style="font-size:medium;"><code>&nbsp;&nbsp;</code><code><span style="color:#008200;">*TCP回射服务器客户端程序 </span></code></span></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">004</span></code></td> 
   <td><code><span style="font-size:medium;">#include &lt;stdio.h&gt; </span></code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">005</span></code></td> 
   <td><code><span style="font-size:medium;">#include &lt;stdlib.h&gt; </span></code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">006</span></code></td> 
   <td><code><span style="font-size:medium;">#include &lt;unistd.h&gt; </span></code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">007</span></code></td> 
   <td><code><span style="font-size:medium;">#include &lt;sys/socket.h&gt; </span></code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">008</span></code></td> 
   <td><code><span style="font-size:medium;">#include &lt;sys/types.h&gt; </span></code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">009</span></code></td> 
   <td><code><span style="font-size:medium;">#include &lt;netinet/in.h&gt; </span></code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">010</span></code></td> 
   <td><code><span style="font-size:medium;">#include &lt;netdb.h&gt; </span></code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">011</span></code></td> 
   <td><code><span style="font-size:medium;">#include &lt;string.h&gt; </span></code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">012</span></code></td> 
   <td><code><span style="font-size:medium;">#include &lt;math.h&gt; </span></code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">013</span></code></td> 
   <td><code><span style="font-size:medium;">#include &lt;sys/select.h&gt; </span></code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">014</span></code></td> 
   <td><code><span style="font-size:medium;">#include &lt;sys/time.h&gt; </span></code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">016</span></code></td> 
   <td><code><span style="font-size:medium;">#define SERVER_PORT 3333&nbsp; //服务器端口号 </span></code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">018</span></code></td> 
   <td><span style="font-size:medium;"><code><strong><span style="color:#006699;">void</span></strong></code> <code>str_cli(</code><code><strong><span style="color:#808080;">FILE</span></strong></code> <code>*fp, </code><code><strong><span style="color:#808080;">int</span></strong></code> <code>sockfd) </code></span></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">020</span></code></td> 
   <td><span style="font-size:medium;"><code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code><strong><span style="color:#808080;">int</span></strong></code> <code>maxfdp1, stdineof; </code></span></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">022</span></code></td> 
   <td><span style="font-size:medium;"><code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code><strong><span style="color:#808080;">char</span></strong></code> <code>buf[BUFSIZ]; </code></span></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">025</span></code></td> 
   <td><span style="font-size:medium;"><code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>stdineof = 0; </code></span></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">028</span></code></td> 
   <td><span style="font-size:medium;"><code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code><strong><span style="color:#006699;">while</span></strong></code><code>(1) </code></span></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">030</span></code></td> 
   <td><span style="font-size:medium;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code><strong><span style="color:#006699;">if</span></strong></code><code>( stdineof == 0 ) </code></span></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">031</span></code></td> 
   <td><span style="font-size:medium;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>FD_SET(fileno(fp),&amp;rset); </code></span></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">032</span></code></td> 
   <td><span style="font-size:medium;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>FD_SET(sockfd, &amp;rset); </code></span></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">034</span></code></td> 
   <td><span style="font-size:medium;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>maxfdp1 = ((fileno(fp) &gt; sockfd) ? fileno(fp) : sockfd) + 1; </code></span></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">036</span></code></td> 
   <td><span style="font-size:medium;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>select(maxfdp1, &amp;rset, NULL, NULL, NULL); </code></span></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">038</span></code></td> 
   <td><span style="font-size:medium;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code><strong><span style="color:#006699;">if</span></strong></code><code>( FD_ISSET(sockfd, &amp;rset) ) </code></span></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">040</span></code></td> 
   <td><span style="font-size:medium;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code><strong><span style="color:#006699;">if</span></strong></code><code>( (n = read(sockfd, buf, BUFSIZ)) == 0 ) </code></span></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">041</span></code></td> 
   <td><span style="font-size:medium;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code><strong><span style="color:#006699;">if</span></strong></code><code>( stdineof == 1 ) </code></span></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">042</span></code></td> 
   <td><span style="font-size:medium;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code><strong><span style="color:#006699;">return</span></strong></code><code>; </code></span></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">044</span></code></td> 
   <td><span style="font-size:medium;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code><strong><span style="color:#ff1493;">perror</span></strong></code><code>(</code><code><span style="color:#0000ff;">"server terminated prematurely"</span></code><code>); </code></span></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">045</span></code></td> 
   <td><span style="font-size:medium;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>write(fileno(stdout), buf, n); </code></span></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">048</span></code></td> 
   <td><span style="font-size:medium;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code><strong><span style="color:#006699;">if</span></strong></code><code>( FD_ISSET(fileno(fp), &amp;rset)) </code></span></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">050</span></code></td> 
   <td><span style="font-size:medium;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code><strong><span style="color:#006699;">if</span></strong></code><code>( (n = read(fileno(fp), buf, BUFSIZ)) == 0 ) </code></span></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">052</span></code></td> 
   <td><span style="font-size:medium;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>stdineof = 1; </code></span></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">053</span></code></td> 
   <td><span style="font-size:medium;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>shutdown(sockfd, SHUT_WR); </code></span></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">054</span></code></td> 
   <td><span style="font-size:medium;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>FD_CLR(fileno(fp), &amp;rset); </code></span></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">055</span></code></td> 
   <td><span style="font-size:medium;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code><strong><span style="color:#006699;">continue</span></strong></code><code>; </code></span></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">057</span></code></td> 
   <td><span style="font-size:medium;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>write(sockfd, buf, n); </code></span></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">064</span></code></td> 
   <td><span style="font-size:medium;"><code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code><strong><span style="color:#808080;">int</span></strong></code> <code>sockfd[5]; </code></span></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">065</span></code></td> 
   <td><span style="font-size:medium;"><code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code><strong><span style="color:#006699;">struct</span></strong></code> <code>sockaddr_in servaddr; </code></span></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">066</span></code></td> 
   <td><span style="font-size:medium;"><code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code><strong><span style="color:#006699;">struct</span></strong></code> <code>hostent&nbsp; *hp; </code></span></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">067</span></code></td> 
   <td><span style="font-size:medium;"><code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code><strong><span style="color:#808080;">char</span></strong></code> <code>buf[BUFSIZ]; </code></span></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">071</span></code></td> 
   <td><span style="font-size:medium;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code><strong><span style="color:#ff1493;">printf</span></strong></code><code>(</code><code><span style="color:#0000ff;">"Please input %s &lt;hostname&gt;\n"</span></code><code>, argv[0]); </code></span></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">079</span></code></td> 
   <td><span style="font-size:medium;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code><span style="color:#008200;">//创建socket </span></code></span></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">080</span></code></td> 
   <td><span style="font-size:medium;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code><strong><span style="color:#006699;">if</span></strong></code><code>( (sockfd[i] = socket(AF_INET, SOCK_STREAM,0)) &lt; 0 ) </code></span></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">082</span></code></td> 
   <td><span style="font-size:medium;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code><strong><span style="color:#ff1493;">printf</span></strong></code><code>(</code><code><span style="color:#0000ff;">"Create socket error!\n"</span></code><code>); </code></span></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">086</span></code></td> 
   <td><span style="font-size:medium;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code><span style="color:#008200;">//设置服务器地址结构 </span></code></span></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">087</span></code></td> 
   <td><span style="font-size:medium;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>bzero(&amp;servaddr, </code><code><strong><span style="color:#006699;">sizeof</span></strong></code><code>(servaddr)); </code></span></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">088</span></code></td> 
   <td><span style="font-size:medium;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>servaddr.sin_family = AF_INET; </code></span></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">089</span></code></td> 
   <td><span style="font-size:medium;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code><strong><span style="color:#006699;">if</span></strong></code><code>( (hp = gethostbyname(argv[1])) != NULL ) </code></span></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">091</span></code></td> 
   <td><span style="font-size:medium;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>bcopy(hp-&gt;h_addr, (</code><code><strong><span style="color:#006699;">struct</span></strong></code> <code>sockaddr*)&amp;servaddr.sin_addr, hp-&gt;h_length); </code></span></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">093</span></code></td> 
   <td><span style="font-size:medium;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code><strong><span style="color:#006699;">else</span></strong></code> <code><strong><span style="color:#006699;">if</span></strong></code><code>(inet_aton(argv[1], &amp;servaddr.sin_addr) &lt; 0 ) </code></span></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">095</span></code></td> 
   <td><span style="font-size:medium;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code><strong><span style="color:#ff1493;">printf</span></strong></code><code>(</code><code><span style="color:#0000ff;">"Input Server IP error!\n"</span></code><code>); </code></span></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">098</span></code></td> 
   <td><span style="font-size:medium;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>servaddr.sin_port = htons(SERVER_PORT); </code></span></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">100</span></code></td> 
   <td><span style="font-size:medium;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code><span style="color:#008200;">//连接服务器 </span></code></span></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">101</span></code></td> 
   <td><span style="font-size:medium;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code><strong><span style="color:#006699;">if</span></strong></code><code>( connect(sockfd[i],(</code><code><strong><span style="color:#006699;">struct</span></strong></code> <code>sockaddr*)&amp;servaddr, </code><code><strong><span style="color:#006699;">sizeof</span></strong></code><code>(servaddr)) &lt; 0 ) </code></span></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">103</span></code></td> 
   <td><span style="font-size:medium;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code><strong><span style="color:#ff1493;">printf</span></strong></code><code>(</code><code><span style="color:#0000ff;">"Connect server failure!\n"</span></code><code>); </code></span></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">107</span></code></td> 
   <td><span style="font-size:medium;"><code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>str_cli(stdin, sockfd[0]); </code></span></td> 
  </tr> 
 </tbody> 
</table>

注：本章内容摘自＜Unix 网络编程＞第六章。

2、pselect函数

pselect函数是由POSIX发明的，如今许多Unix变种都支持它。

[view source][]

[print][] [?][Link 1]

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">2</span></code></td> 
   <td><code><span style="font-size:medium;">#include &lt;signal.h&gt; </span></code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">3</span></code></td> 
   <td><code><span style="font-size:medium;">#include &lt;time.h&gt; </span></code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">5</span></code></td> 
   <td><span style="font-size:medium;"><code><strong><span style="color:#808080;">int</span></strong></code> <code>pselect(</code><code><strong><span style="color:#808080;">int</span></strong></code> <code>maxfdp1, fd_set *readset, fd_set *writeset, fd_set *exceptset, </code><code><strong><span style="color:#006699;">const</span></strong></code> <code><strong><span style="color:#006699;">struct</span></strong></code> <code>timespec *timeout, </code><code><strong><span style="color:#006699;">const</span></strong></code> <code>sigset_t *sigmask); </code></span></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code><span style="font-size:medium;">6</span></code></td> 
   <td><span style="font-size:medium;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>返回：就绪描述字的个数，0－超时，-1－出错</code></span></td> 
  </tr> 
 </tbody> 
</table>

pselect相对于通常的select有两个变化：

1、pselect使用timespec结构，而不使用timeval结构。timespec结构是POSIX的又一个发明。

struct timespec\{

time\_t tv\_sec;     //seconds

long    tv\_nsec;    //nanoseconds

\};

这两个结构的区别在于第二个成员：新结构的该成员tv\_nsec指定纳秒数，而旧结构的该成员tv\_usec指定微秒数。

2、pselect函数增加了第六个参数：一个指向信号掩码的指针。该参数允许程序先禁止递交某些信号，再测试由这些当前被禁止的信号处理函数设置的全局变量，然后调用pselect，告诉它重新设置信号掩码。

关于第二点，考虑下面的例子，这个程序的SIGINT信号处理函数仅仅设置全局变量intr\_flag并返回。如果我们的进程阻塞于select调用，那么从信号处理函数的返回将导致select返回EINTR错误。然而调用select时，代码看起来大体如下：

[view source][]

转载于:https://my.oschina.net/alphajay/blog/5219

[view source]: http://my.oschina.net/alphajay/admin/#viewSource
[print]: http://my.oschina.net/alphajay/admin/#printSource
[Link 1]: http://my.oschina.net/alphajay/admin/#about