linux 下 select 编程

  linux 下的 select 知识点 unp 的第六章已经描述的很清楚,我们这里简单的说下 select 的作用,并给出 select 的客户端实例。我们知道 select 是IO 多路复用的一个最简单支持,poll 和 epoll 是 select 的升级版。在 UNIX 网络编程第五章读书笔记 我们遇到这样一个问题:当客户端阻塞在 fgets() 等待客户输入的时候,服务器端断开连接。而客户端却不能及时知道,只有在客户输入完毕并发送到服务器的时候才知道连接已经断开,但是此时可能已经过了很长时间了。如果我们想及时知道服务器断开连接怎么办呢?

  我们知道不管是 fgets() 等待客户输入还是 read() 从套接口读取数据,都是 IO 操作。我们不能阻塞在某个 IO 操作中一个,这样其他 IO 操作会无法进行,即使其他 IO 操作上有数据了我们也无法及时读取。select 的原理是这样的:我们将这些 IO 操作所要操作的文件描述符放到一起(比如一个数组中),然后阻塞在 select() 函数上,为什么要阻塞在这里呢?其实这时的 select 实在不停的遍历这个数组,查看其中的文件描述符上是否可读/可写,一旦可读/可写,select 返回,停止阻塞。然后我们对可读/可写的文件描述如做相应的操作即可。下面是 select 函数的原型:

  int select(nfds, readfds, writefds, exceptfds, timeout)

  nfds 是指定 select() 要遍历的最大文件描述符 + 1,readfds 就是放文件描述的数组,这个数组里面关心的是该数组中文件描述符的读事件,wretefds 也是放文件描述符的数组,这个数组里面关心的是该数组中文件爱你描述符的写事件,exceptfds 也是放文件描述符的数组,这个数组关心的是该数组中文件描述符的出错事件。timeout 是 select 阻塞的时间。如果设置为 0,那么将永远阻塞下去直到有事件发生。否则的话就会在阻塞 timeout 毫秒之后返回,无论关心的文件描述符是否有事件发生。select 返回有事件发生的文件描述符个数,失败返回小于 0  的数。

  下面是 select 应用在客户端实例代码:

  1 #include <sys/socket.h>
  2 #include <netinet/in.h>
  3 #include <stdio.h>
  4 #include <error.h>
  5 #include <unistd.h>
  6 #include <string.h>
  7 #include <stdlib.h>
  8 #include <sys/wait.h>
  9 #include <signal.h>
 10 #include <sys/select.h>
 11 #include <sys/time.h>
 12
 13 #define MAXLINE 15
 14 #define SA struct sockaddr
 15
 16 void str_cli(FILE *fp, int sockfd)
 17 {
 18     char sendline[MAXLINE], recvline[MAXLINE],buf[MAXLINE];
 19     int writenbytes;
 20     fd_set    rset;//关心读事件的文件描述符结合
 21     int maxfdpl, stdineof;
 22     int counts = 0, n;
 23     //集合所有位清零
 24     FD_ZERO(&rset);
 25     for(;;)
 26     {
 27         //将集合中 (fp) 描述符相应的位置开关打开,表示关心这个描述符
 28         FD_SET(fileno(fp), &rset);
 29         //将集合中 sockfd 描述符相应的位置开关打开,表示关心这个描述符
 30         FD_SET(sockfd, &rset);
 31         //设定为最大描述符 + 1
 32         maxfdpl = (sockfd > fileno(fp) ? sockfd : fileno(fp)) + 1;
 33         //会阻塞在这里
 34         if((counts = select(maxfdpl, &rset , NULL, NULL, NULL)) > 0)
 35         {
 36             //sockfd 描述符上是否有可读事件发生(即服务器端发送数据过来了)
 37             if(FD_ISSET(sockfd, &rset))
 38             {
 39                 if((n = read(sockfd, buf, MAXLINE)) == 0)
 40                 {
 41                     if(stdineof = 1)
 42                         return;
 43                     else
 44                     {
 45                         printf("str_cli:server terminated prematurely!\n");
 46                         exit(0);
 47                     }
 48                 }
 49                 if( (n = write(fileno(stdout), buf, n)) != n)
 50                 {
 51                     printf("str_cli:write() error!\n");
 52                     exit(0);
 53                 }
 54             }
 55             // fp 描述符上是否有可读事件发生(即用户输入了数据)
 56             if(FD_ISSET(fileno(fp), &rset))
 57             {
 58
 59                 if((n = read(fileno(fp), buf, MAXLINE)) == 0)
 60                 {
 61                     stdineof = 1;
 62                     shutdown(sockfd, SHUT_WR);
 63                     FD_CLR(fileno(fp), &rset);
 64                     continue;
 65                 }
 66                 write(sockfd, buf, n);
 67             }
 68         }
 69     }
 70 }
 71 int main(int argc, char **argv)
 72 {
 73     int sockfd;
 74     struct sockaddr_in servaddr;
 75     if(argc != 2)
 76     {
 77         printf("useage: tcpcli <IPaddress>");
 78         exit(0);
 79     }
 80     if((sockfd = socket(AF_INET, SOCK_STREAM, 0)) < 0)
 81     {
 82         printf("socket() error!");
 83         exit(0);
 84     }
 85     bzero(&servaddr, sizeof(servaddr));
 86     servaddr.sin_family = AF_INET;
 87     servaddr.sin_port = htons(9806);
 88
 89     if(inet_pton(AF_INET, argv[1], &servaddr.sin_addr) < 0)
 90     {
 91         printf("inet_pton() error!");
 92         exit(0);
 93     }
 94     if(connect(sockfd, (SA *) &servaddr, sizeof(servaddr)) < 0)
 95     {
 96         printf("inet_pton() error!");
 97         exit(0);
 98     }
 99     str_cli(stdin, sockfd);
100     exit(0);
101 }

  先运行下,表示连接正常:

  

  再看下进程:

  

  在终端运行 sudo kill -9 6073 杀死服务器端子进程,再查看进程信息:

    

  客户端能立即知道:

  

  看,这就是 select 的作用咯!

  

时间: 2024-08-28 17:14:10

linux 下 select 编程的相关文章

linux 下 poll 编程

poll 与 select 很类似,都是对描述符进行遍历,查看是否有描述符就绪.如果有就返回就绪文件描述符的个数将.poll 函数如下: #include <poll.h> int poll(struct pollfd *fdarray, unsigned long nfds, int timeout) 第一个参数指向结构数组第一个元素的指针,每个数组都是一个 pollfd 结构iouyonghu制定额是某个给定描述符的条件. struct pollfd { int fd; short eve

Linux下Socket编程

http://blog.chinaunix.net/uid-20733992-id-3450058.html 原文地址:Linux下Socket编程 作者:yulianliu1218 Linux下Socket编程 什么是Socket Socket接口是TCP/IP网络的API,Socket接口定义了许多函数或例程,程序员可以用它们来开发TCP/IP网络上的应用程序.要学Internet上的TCP/IP网络编程,必须理解Socket接口. Socket接口设计者最先是将接口放在Unix操作系统里面

Linux下select函数的使用

Linux下select函数的使用 转载:http://www.cnblogs.com/hjslovewcl/archive/2011/03/16/2314330.html 一.Select 函数详细介绍 Select在Socket编程中还是比较重要的,可是对于初学Socket的人来说都不太爱用Select写程序,他们只是习惯写诸如connect. accept.recv或recvfrom这样的阻塞程序(所谓阻塞方式block,顾名思义,就是进程或是线程执行到这些函数时必须等待某个事件的发 生,

根据《linux兵书》目录 在kali上操作 第8章 Linux下的编程

第8章  浑水摸鱼:Linux下的编程 175 8.1  Linux下常用的开发工具 176 8.1.1  GCC 176 8.1.2  CVS 176 8.1.3  Perl 176 8.1.4  Linux上的Delphi--Kylix 177 8.2  Linux下的Vi文本编辑器 177 8.2.1  Vi编辑器介绍 178 8.2.2  启动Vi编辑器 179 8.2.3  显示Vi中的行号 180 8.2.4  光标移动操作 181 8.2.5  屏幕命令 182 8.2.6  文本

Linux下Socket编程的端口问题( Bind error: Address already in use )

Linux下Socket编程的端口问题( Bind error: Address already in use ) 在进行linux网络编程时,每次修改了源代码并再次编译运行时,常遇到下面的地使用错误: Bind error: Address already in use 虽然用Ctrl+C强制结束了进程,但错误依然存在,用netstat -an |grep 5120和ps aux |grep 5120都还能看到刚才用Ctrl+C“强制结束”了的进程,端口还是使用中,只好每次用kill结束进程,

Linux下Shell编程

Linux的shell编程 1.什么是shell? 当一个用户登录Linux系统之后,系统初始化程序init就为每一个用户运行一个称为shell(外壳)的程序. shell就是一个命令行解释器,它为用户提供了一个向Linux内核发送请求以便运行程序的界面系统级程序,用户可以用shell来启动.挂起.停止甚至是编写一些程序.一般的Linux系统都将bash作为默认的shell. 2.几种流行的shell 目前流行的shell有ash.bash.ksh.csh.zsh等,可以用下面的命令来查看she

Linux下shell编程实例

1. 判断一文件是不是块或字符设备文件,如果是将其拷贝到 /dev 目录下 read -p "input a file:" filename if [ -b $filename -o -c $filename ] then cp $filename /dev/ fi 2.编写一个脚本,进行简单的减法运算,要求提示输入变量 #!/bin/bash read -p "input a number:" num1 read -p "input another nu

linux下Bash编程组合测试及编写脚本(五)

linux下Bash编程组合测试及编写综合脚本(五) 1.Bash编程组合测试条件 -a: 与关系 -o: 或关系 !: 非关系 表示方法1:[ $# -gt 100 -a $# -le 500 ] 表示方法2:[ $# -gt 100 ] && [ $# -le 500 ] 2.编写一个任意添加与删除用户的脚本,要求如下: 2.1:如果脚本选项是--add:,将添加用户; 如果选项是--del,将删除用户,如果是--help显示帮助信息 2.2:脚本选项后面的参数可任意指定多个用户并且用

linux下多线程编程

最近研究mysql源码,各种锁,各种互斥,好在我去年认真学了<unix环境高级编程>, 虽然已经忘得差不多了,但是学过始终是学过,拿起来也快.写这篇文章的目的就是总结linux 下多线程编程,作为日后的参考资料. 本文将介绍linux系统下多线程编程中,线程同步的各种方法.包括: 互斥量(mutex) 读写锁 条件变量 信号量 文件互斥 在介绍不同的线程同步的方法之前,先简单的介绍一下进程和线程的概念, 它们的优缺点,线程相关的API,读者——写者问题和哲学家就餐问题. 基础知识 1. 进程和