#include
#include

超时时间：

//该结构体表示等待超时的时间
struct timeva l{
?long tv_sec;//秒
?long tv_usec;//微秒
};

//比如等待10.2秒
struct timeva l timeout;
timeoout.tv_sec = 10;
timeoout.tv_usec = 200000;

//将select函数的timeout参数设置为NULL则永远等待

select()函数能对多个文件描述符进行监测，如果一个参数对应一个描述符，那么select函数的4个参数最多能监测4个文件描述，那他如何实现对多个文件描述符的监测的呢？

大家想一想文件描述符基本具有3种特性（读、写、异常），如果我们统一将监测可读的描述符放入可读集合（readset），监测可写的描述符放入可写集合（writeset），监测异常的描述符放入异常集合（exceptset）。然后将这3个集合传给select函数，是不是就可监测多个描述符呢.

如何将某个描述符加入到特定的集合中呢？这时就需要了解下面的集合操作函数

/初始化描述符集
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);

例子：检测 0、4、5 描述符是否准备好读

while(1)
{
?fd_set rset;//创建一个描述符集rset
?FD_ZERO(&rset);//对描述符集rset清零
?FD_SET(0, &rset);//将描述符0加入到描述符集rset中
?FD_SET(4, &rset);//将描述符4加入到描述符集rset中
?FD_SET(5, &rset);//将描述符5加入到描述符集rset中
?
?if(select(5+1, &rset, NULL, NULL, NULL) > 0)
?{
? if(FD_ISSET(0, &rset))
? {
? ?//描述符0可读及相应的处理代码
? }
?
? if(FD_ISSET(4, &rset))
? {
? ?//描述符4可读及相应的处理代码
? }
? if(FD_ISSET(5, &rset))
? {
? ?//描述符5可读及相应的处理代码
? }
?}
}

#include
#include
#include
#include
#include
#include
#include
#include
#include
#include

//接收线程：负责接收消息并显示
void *recv_thread(void* arg)
{
?int udpfd = (int)arg;
?struct sockaddr_in addr;
?socklen_t addrlen = sizeof(addr);
?
?bzero(&addr,sizeof(addr));
?while(1)
?{
? char buf[200]? = "";
? char ipbuf[16] = "";
? recvfrom(udpfd, buf, sizeof(buf), 0, (struct sockaddr*)&addr, &addrlen);
? printf("\r\033[31m[%s]:\033[32m%s\n",inet_ntop(AF_INET,&addr.sin_addr,ipbuf,sizeof(ipbuf)),buf);
? write(1,"UdpQQ:",6);
?}
?return NULL;
}

int main(int argc,char *argv[])
{
?char buf[100] = "";
?int? udpfd = 0;
?pthread_t tid;
?struct sockaddr_in addr;
?struct sockaddr_in cliaddr;
?
?//对套接字地址进行初始化
?bzero(&addr,sizeof(addr));
?addr.sin_family = AF_INET;
?addr.sin_port? = htons(8000);
?addr.sin_addr.s_addr = htonl(INADDR_ANY);

?bzero(&cliaddr,sizeof(cliaddr));?
?cliaddr.sin_family = AF_INET;
?cliaddr.sin_port? = htons(8000);

?//创建套接口
?if( (udpfd = socket(AF_INET,SOCK_DGRAM, 0)) < 0)
?{
? perror("socket error");
? exit(-1);
?}
?
?//设置端口
?if(bind(udpfd, (struct sockaddr*)&addr, sizeof(addr)) < 0)
?{
? perror("bind error");
? close(udpfd);?
? exit(-1);
?}
?
?printf("input: \"sayto 192.168.221.X\" to sendmsg to somebody\n");
?//创建接收线程
?pthread_create(&tid, NULL, recv_thread, (void*)udpfd); //创建线程
?printf("\033[32m"); //设置字体颜色
?fflush(stdout);
?
?while(1)
?{?
? //主线程负责发送消息
? write(1,"UdpQQ:",6);//1 表示标准输出
? fgets(buf, sizeof(buf), stdin); //等??输入
? buf[strlen(buf) - 1] = '\0';? ? //确保输入的最后一位是'\0'
? if(strncmp(buf, "sayto", 5) == 0)
? {
? ?char ipbuf[INET_ADDRSTRLEN] = "";
? ?inet_pton(AF_INET, buf+6, &cliaddr.sin_addr);//给addr套接字地址再赋值.
? ?printf("\rconnect %s successful!\n",inet_ntop(AF_INET,&cliaddr.sin_addr,ipbuf,sizeof(ipbuf)));
? ?continue;
? }
? else if(strncmp(buf, "exit",4) == 0)
? {
? ?close(udpfd);
? ?exit(0);
? }
?
? sendto(udpfd, buf, strlen(buf),0,(struct sockaddr*)&cliaddr, sizeof(cliaddr));
?}
?
?return 0;
}

?运行结果：

用select来完成上述同样的功能：

#include
#include
#include
#include
#include
#include
#include
#include
#include

int main(int argc,char *argv[])
{
?int udpfd = 0;
?struct sockaddr_in saddr;
?struct sockaddr_in caddr;