未加星标

Linux网络编程:I/O复用之select详解

字体大小 | |
[系统(linux) 所属分类 系统(linux) | 发布者 店小二04 | 时间 2017 | 作者 红领巾 ] 0人收藏点击收藏
一、I/O复用概述 I/O复用概念:

解决进程或线程阻塞到某个 I/O 系统调用而出现的技术,使进程不阻塞于某个特定的 I/O 系统调

I/O复用使用的场合:

1.当客户处理多个描述符(通常是交互式输入、网络套接字)时,必须使用I/O复用。

2.tcp服务器既要处理监听套接字,又要处理已连接套接字,一般要使用 I/O复用。

3.如果一个服务器既要处理tcp又要处理udp,一般要使用 I/O复用。

4 .如果一个服务器要处理多个服务或多个服务时,一般要使用 I/O复用。

I/O复用常 用函数 :

select、poll

二、select()函数 select函数介绍:

int select(int maxfd , fd_set * readset ,fd_set * writeset , fd_set * exceptset ,const struct timeval * timeout );

功能:轮询扫描 多个描述符 中的 任一描述符 是否发生响应,或 经过一段时间 后唤醒

参数:

参数 名称 说明 maxfd 指定要检测的描述符的范围 所检测描述符最大值+1 readset 可读描述符集 监测该集合中的任意描述符是否有数据可读 writeset 可写描述符集 监测该集合中的任意描述符是否有数据可写 exceptset 异常描述符集 监测该集合中的任意描述符是否发生异常 timeout 超时时间 超过规定时间后唤醒

返回值:

0:超时

-1:出错

>0:准备好的文件描述符数量

头文件:

#include <sys/select.h>

#include <sys/time.h>

超时时间 :

//该结构体表示等待超时的时间

struct timeval{

long tv_sec;//秒

long tv_usec;//微秒

};

//比如等待10.2秒

struct timeval 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);

select()函数整体使用框架:

例子:检测 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可读及相应的处理代码

}

}

}

三、select函数的应用对比

我们通过udp 同时收发 的例子来说明select的妙处。

对于udp同时收发立马想到的是 一个线程收 、 另一个线程发 ,下面的代码就是通过多线程来实现

#include <string.h>

#include <stdio.h>

#include <stdlib.h>

#include <unistd.h>

#include <sys/select.h>

#include <sys/time.h>

#include <sys/socket.h>

#include <netinet/in.h>

#include <arpa/inet.h>

#include <pthread.h>

//接收线程:负责接收消息并显示

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;

}

运行结果:


Linux网络编程:I/O复用之select详解

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

#include <string.h>

#include <stdio.h>

#include <stdlib.h>

#include <unistd.h>

#include <sys/select.h>

#include <sys/time.h>

#include <sys/socket.h>

#include <netinet/in.h>

#include <arpa/inet.h>

int main(int argc,char *argv[])

{

int udpfd = 0;

struct sockaddr_in saddr;

struct sockaddr_in caddr;

bzero(&saddr,sizeof(saddr));

saddr.sin_family = AF_INET;

saddr.sin_port = htons(8000);

saddr.sin_addr.s_addr = htonl(INADDR_ANY);

bzero(&caddr,sizeof(caddr));

caddr.sin_family = AF_INET;

caddr.sin_port = htons(8000);

//创建套接字

if( (udpfd = socket(AF_INET,SOCK_DGRAM, 0)) < 0)

{

perror("socket error");

exit(-1);

}

//套接字端口绑字

if(bind(udpfd, (struct sockaddr*)&

本文系统(linux)相关术语:linux系统 鸟哥的linux私房菜 linux命令大全 linux操作系统

主题: Linux服务器SSE数据删除
tags: 描述符,lt,gt,addr,amp,#include,select,rset,int,buf,sin,struct,sizeof,udpfd,FD
分页:12
转载请注明
本文标题:Linux网络编程:I/O复用之select详解
本站链接:http://www.codesec.net/view/533161.html
分享请点击:


1.凡CodeSecTeam转载的文章,均出自其它媒体或其他官网介绍,目的在于传递更多的信息,并不代表本站赞同其观点和其真实性负责;
2.转载的文章仅代表原创作者观点,与本站无关。其原创性以及文中陈述文字和内容未经本站证实,本站对该文以及其中全部或者部分内容、文字的真实性、完整性、及时性,不作出任何保证或承若;
3.如本站转载稿涉及版权等问题,请作者及时联系本站,我们会及时处理。
登录后可拥有收藏文章、关注作者等权限...
技术大类 技术大类 | 系统(linux) | 评论(0) | 阅读(90)