select (Unix)

select是ぜ用よう于I/O多た路みち转接的てき一いち个系けい统调用よう函数かんすう。

在ざいC程ほど序じょ中ちゅう，该系统调用よう在ざい sys/select.h 或ある unistd.h 中ちゅう声明せいめい，语法如下：

int select(int nfds, fd_set* readfds, fd_set* writefds, fd_set* errorfds, struct timeval* timeout);

参さん数すう	描述
nfds	sets的てき文ぶん件けん描述符ふ的てき最大さいだい值
readfds	`fd_set` 类型，包含ほうがん了りょう需要じゅよう检查是ぜ否いや可か读的描述符ふ，输出时表示ひょうじ哪些描述符ふ可か读。可か为 `NULL`。
writefds	`fd_set` 类型，包含ほうがん了りょう需要じゅよう检查是ぜ否いや可か写うつし的てき描述符ふ，输出时表示ひょうじ哪些描述符ふ可か写うつし。可か为 `NULL`。
errorfds	`fd_set` 类型，包含ほうがん了りょう需要じゅよう检查是ぜ否ひ出で错的描述符ふ，输出时表示ひょうじ哪些描述符ふ出で错。可か为 `NULL`。
timeout	`struct timeval` 类型的てき结构体たい，表示ひょうじ等とう待まち检查完成かんせい的てき最さい长时间。

为了维护fd_set类型的てき参さん数すう，会かい使用しよう下面かめん四よん个宏ひろし：FD_SET(), FD_CLR(), FD_ZERO() 和かず FD_ISSET()。

返かえし回かい值：

      这个函数かんすう将はた返かえし回かい描述符ふ集しゅう的てき个数， 如果超ちょう时返かえし回かい为0，错误则返回かい-1。

参看さんかん：

select(2)
poll(2)

select与あずかepoll的てき区く别

	epoll	select
概がい述じゅつ	epoll是ぜ个模かたぎ块，由よし三さん个系けい统调用よう组成，内ない核かく中ちゅう由よし用よう文ぶん件けん系けい统实现	select是ぜ个系けい统调用よう
结构体たい定てい义	typedef union epoll_data { void ptr; int fd; __uint32_t u32; __uint64_t u64; } epoll_data_t; struct epoll_event { __uint32_t events; // epoll 监听的てき事件じけん类型 epoll_data_t data; / User data variable */ };	struct timeval{ long tv_sec;//second long tv_usec;//minisecond } typedef struct fd_set { u_int fd_count; int fd_array[FD_SETSIZE]; } //fd_array可かSIZE*8个socket
可用かよう的てき事件じけん	EPOLLIN ：表示ひょうじ对应的てき文ぶん件けん描述符ふ可か以读； EPOLLOUT：表示ひょうじ对应的てき文ぶん件けん描述符ふ可か以写； EPOLLPRI：表示ひょうじ对应的てき文ぶん件けん描述符ふ有ゆう紧急的てき数すう据すえ可か读； EPOLLERR：表示ひょうじ对应的てき文ぶん件けん描述符ふ发生错误； EPOLLHUP：表示ひょうじ对应的てき文ぶん件けん描述符ふ被ひ挂断； EPOLLET： ET的てきepoll工作こうさく模も式しき；	fd_set有ゆう三さん种类型がた： readfds, writefds, exceptionfds
操作そうさ函数かんすう	三さん个系统调用よう：epoll_create epoll_ctl epoll_wait	一いち个系统调用よう：select 四よん个宏: FD_ZERO FD_SET FD_CLR FD_ISSET
运行模も式しき	边沿触发 (ET)、状じょう态触发 (LT)	状じょう态触发
运行过程	int fd = epoll_create(1); // 创建一いち个 epoll 实例，参まいり数すう可か以是任意にんい正せい整数せいすう struct epoll_event events[xxxB];// epoll 实例将はた发生的てき事件じけん写うつし入にゅう该数组 while(1){ int nfds = epoll_wait( ); // 等とう待まち事件じけん发生 for(int i=0; i<nfds; i++){ … }//end for }//end while	struct timeval tv; fd_set rfds; tv={5,0}; // 设置超ちょう时 while(1){ FD_ZERO(&rfds); if (!select()) continue; for(int i=0;i<maxfds; i++){ ... } // 结束 for 循环 } // 结束 while 循环
优点	1）epoll_wait返かえし回かい的てき都と是ぜ有效ゆうこう数すう据すえ，可か直接ちょくせつ从struct epoll_event[]中ちゅう获取事件じけん，效率こうりつ高だか。
缺点けってん		每次まいじselect有数ゆうすう据すえ要よう遍あまね历全部ぶsocket
注意ちゅうい事ごと项	每次まいじ取と事件じけん后きさき，要よう重じゅう新しん注ちゅう册さつ此socket的てき事件じけんepoll。(epoll_ctl)	每次まいじselect之の前ぜん要よう重じゅう置おけrfds的てき值。(FD_ZERO)

说明：以上いじょう无论epoll_create, fd_set都と受限于系统中单个进程能のう够打开的文ぶん件けん句柄くがら数かず。

示しめせ例れい

#include <stdio.h>
#include <stdlib.h>
#include <string.h>

#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <netdb.h>

#include <sys/select.h>
#include <fcntl.h>
#include <unistd.h>
#include <errno.h>

#define PORT "9421"

/* function prototypes */
void die(const char*);

int main(int argc, char **argv)
{
	int sockfd, new, maxfd, on = 1, nready, i;

	struct addrinfo *res0, *res, hints;

	char buffer[BUFSIZ];

	fd_set master, readfds;

	ssize_t nbytes;

	(void)memset(&hints, '\0', sizeof(struct addrinfo));

	hints.ai_family = AF_INET;
	hints.ai_socktype = SOCK_STREAM;
	hints.ai_protocol = IPPROTO_TCP;
	hints.ai_flags = AI_PASSIVE;

	if(-1 == (getaddrinfo(NULL, PORT, &hints, &res0)))
		die("getaddrinfo()");

	for(res = res0; res; res = res->ai_next)
	{
		if(-1 == (sockfd = socket(res->ai_family, res->ai_socktype, res->ai_protocol)))
		{
			perror("socket()");
			continue;
		}

		if(-1 == (setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR, (char*)&on, sizeof(int))))
		{
			perror("setsockopt()");
			continue;
		}

		if(-1 == (bind(sockfd, res->ai_addr, res->ai_addrlen)))
		{
			perror("bind");
			continue;
		}

		break;

	}

	if(-1 == sockfd)
		exit(EXIT_FAILURE);

	freeaddrinfo(res0);

	if(-1 == (listen(sockfd, 32)))
		die("listen()");

	if(-1 == (fcntl(sockfd, F_SETFD, O_NONBLOCK)))
		die("fcntl()");

	FD_ZERO(&master);
	FD_ZERO(&readfds);
	
	FD_SET(sockfd, &master);

	maxfd = sockfd;

	while(1)
	{
		memcpy(&readfds, &master, sizeof(master));

		(void)printf("running select()\n");

		if(-1 == (nready = select(maxfd+1, &readfds, NULL, NULL, NULL)))
			die("select()");

		(void)printf("Number of ready descriptor: %d\n", nready);

		for(i=0; i<=maxfd && nready>0; i++)
		{
			if(FD_ISSET(i, &readfds))
			{
				nready--;

				if(i == sockfd)
				{
					(void)printf("Trying to accept() new connection(s)\n");

					if(-1 == (new = accept(sockfd, NULL, NULL)))
					{
						if(EWOULDBLOCK != errno)
							die("accept()");

						break;
					}
					
					else
					{

						if(-1 == (fcntl(new, F_SETFD, O_NONBLOCK)))
							die("fcntl()");

						FD_SET(new, &master);

						if(maxfd < new)
							maxfd = new;
					}
				}

				else
				{
					(void)printf("recv() data from one of descriptors(s)\n");

					nbytes = recv(i, buffer, sizeof(buffer), 0);
					if(nbytes <= 0)
					{
						if(EWOULDBLOCK != errno)
							die("recv()");

						break;
					}

					buffer[nbytes] = '\0';
					printf("%s", buffer);
					
					(void)printf("%zi bytes received.\n", nbytes);

					close(i);
					FD_CLR(i, &master);

				}
			}

		}

	}

	return 0;
}

void die(const char *msg)
{
	perror(msg);
	exit(EXIT_FAILURE);
}

参まいり见

外部がいぶ链接

select(2) – Linux程ほど序じょ员手て册さつ页 – 系けい统调用よう（System Calls）
select_tut(2) – Linux系けい统调用よう（System Calls）手て册さつ页