《网络编程》I/O 多路复用

1. 该套接字接收缓冲区中的数据字节数 不小于 套接字接收缓冲区低水位标记的当前大小。对这样的套接字执行读操作不会阻塞并将返回一个大于 0 的值。可以通过 SO_RCVLOWAT 套接字选项设置该套接字的低水位标记；
2. 该连接的读半部分关闭（即一端已接收到 FIN 的 TCP 连接）。对这样的套接字的读操作将不阻塞并返回 0（即 EOF 字符）；
3. 该套接字是一个监听套接字且已完成的连接数不为 0 。对这样的套接字的 accept 通常不会阻塞；
4. 其上有一个套接字错误待处理。对这样的套接字的读操作将不阻塞并返回 -1（即返回一个错误），并把 errno 设置为确切的错误条件；

1. 该套接字发送缓冲区中的可用空间字节数 不小于 套接字发送缓冲区低水位标记的当前大小，并且或该套接字已连接，或该套接字不需要连接（如 UDP 套接字）。这意味着若把这样的套接字设置为非阻塞，写操作将不阻塞并返回一个正值；
2. 该链接的写半部关闭。对这样的套接字的写操作将产生 SIGPIPE 信号；
3. 使用非阻塞式 connect 的套接字已建立连接，或connect 已经连接失败；
4. 其上有一个套接字错误待处理。对这样的套接字的写操作将不阻塞并返回 -1，同时把 errno 设置成确切的错误条件；

1. 若对端 TCP 发送数据，那么套接字变为可读，并且 read 返回一个大于 0 的值；
2. 若对端 TCP 发送一个 FIN ，那么套接字变为可读，并且 read 返回 0（即 EOF 字符）；
3. 若对端 TCP 发送一个 RST，那么套接字变为可读，并且 read 返回 -1，而 errno 中含有确切的错误代码；

#include	"unp.h"

void
str_cli(FILE *fp, int sockfd)
{
	int			maxfdp1;
	fd_set		rset;
	char		sendline[MAXLINE], recvline[MAXLINE];

	FD_ZERO(&rset);/* 初始化 */
	for ( ; ; ) {
		FD_SET(fileno(fp), &rset);/* 打开标准文件指针 fp 描述符位 */
		FD_SET(sockfd, &rset);/* 打开套接字 sockfd 位 */
		maxfdp1 = max(fileno(fp), sockfd) + 1;
		Select(maxfdp1, &rset, NULL, NULL, NULL);

		if (FD_ISSET(sockfd, &rset)) {	/* socket is readable */
			if (Readline(sockfd, recvline, MAXLINE) == 0) /* 若返回时套接字可读，则先读入从服务器回射的文本，并显示到标准输出 */
				err_quit("str_cli: server terminated prematurely");
			Fputs(recvline, stdout);
		}

		if (FD_ISSET(fileno(fp), &rset)) {  /* input is readable */
			if (Fgets(sendline, MAXLINE, fp) == NULL) /* 若返回时标准输入可读，就先用 fgets 读入文本行，再用 writen 把它写到套接字中 */
				return;		/* all done */
			Writen(sockfd, sendline, strlen(sendline));
		}
	}
}

shutdown 函数 

1. close 把描述符的引用计数减 1，仅在该计数变为 0 时才关闭套接字。然而使用 shutdown 函数可以不管引用计数就激发 TCP 的正常连接终止序列；
2. close 终止读和写两个方向的数据传送，而 shutdown 函数可以只关闭读或写的一端，或两端都关闭； 

/*
 * 函数功能：关闭套接字上的输入或输出；
 * 返回值：若成功则返回0，若出错返回-1；
 * 函数原型：
 */
#include <sys/socket.h>
int shutdown(int sockfd, int how);
/*
 * 说明：
 * sockfd表示待操作的套接字描述符；
 * how表示具体操作，取值如下：
 * （1）SHUT_RD     关闭读端，即不能接收数据
 * （2）SHUT_WR     关闭写端，即不能发送数据
 * （3）SHUT_RDWR   关闭读、写端，即不能发送和接收数据
 *
 */

#include	"unp.h"

void
str_cli(FILE *fp, int sockfd)
{
	int			maxfdp1, stdineof;
	fd_set		rset;
	char		buf[MAXLINE];
	int		n;

	stdineof = 0;/* 表示在主循环中 select 标准输入为可读 */
	FD_ZERO(&rset);
	for ( ; ; ) {
		if (stdineof == 0)
			FD_SET(fileno(fp), &rset);
		FD_SET(sockfd, &rset);
		maxfdp1 = max(fileno(fp), sockfd) + 1;
		Select(maxfdp1, &rset, NULL, NULL, NULL);
<span style="white-space:pre">		</span>/* 当在套接字上读到 EOF 字符，若我们已在标准输入键入 EOF，则正常终止，若没有在标准输入键入 EOF，表示服务器已过早终止 */
		if (FD_ISSET(sockfd, &rset)) {	/* socket is readable */
			if ( (n = Read(sockfd, buf, MAXLINE)) == 0) {
				if (stdineof == 1)
					return;		/* normal termination */
				else
					err_quit("str_cli: server terminated prematurely");
			}

			Write(fileno(stdout), buf, n);
		}
<span style="white-space:pre">		</span>/* 当在标准输入遇到 EOF，则关闭写端，即客户端不能向服务器发送数据 */
		if (FD_ISSET(fileno(fp), &rset)) {  /* input is readable */
			if ( (n = Read(fileno(fp), buf, MAXLINE)) == 0) {
				stdineof = 1;
				Shutdown(sockfd, SHUT_WR);	/* send FIN */
				FD_CLR(fileno(fp), &rset);
				continue;
			}

			Writen(sockfd, buf, n);
		}
	}
}

poll 函数

/*
 * 函数功能：和select函数类似；
 * 函数原型：
 */
#include <poll.h>
int poll(struct pollfd fdarray[], nfds_t nfds, int timeout);
/*
 * 说明：
 * timeout == -1;   永远等待。
 * timeout == 0;    不等待，测试所有的描述符并立即返回。
 * timeout > 0;     等待timeout毫秒，当指定的描述符之一已经准备好，或指定的时间值已经超过时立即返回。
 */

struct pollfd{
int fd; /* file descriptor to check,or <0 to ignore */
short events; /* events of interest on fd */
short revents;  /* events that occurred on fd */
};