Socket select模型

 Windows socket select模型开发。

      套接字select模型是一种比较常用的IO模型。利用该模型可以使Windows socket应用程序可以同时管理多个套接字。


     使用select模型,可以使当执行操作的套接字满足可读可写条件时,给应用程序发送通知。收到这个通知后,应用程序再去调用相应的Windows socket API去执行函数调用。


     Select模型的核心是select函数。调用select函数检查当前各个套接字的状态。根据函数的返回值判断套接字的可读可写性。然后调用相应的Windows Sockets API完成数据的发送、接收等。


阻塞模式和非阻塞模式的优点和不足:


     阻塞模式套接字执行IO操作时,如果执行操作的条件未满足,线程就会阻塞在调用的函数上。程序不得不处于等待状态,但是由于并不知道客户请求何时到来,因此函数在何时返回不得而知。


    非阻塞模式套接字执行IO操作时,在任何时候函数都会立即返回。但程序员必须为此编写更多的代码。这增加了开发Windows socket应用程序的难度。另外由于不断的循环调用导致程序效率很低。


     Select模型是Windows sockets中最常见的IO模型。它利用select函数实现IO 管理。通过对select函数的调用,应用程序可以判断套接字是否存在数据、能否向该套接字写入数据。


     如:在调用recv函数之前,先调用select函数,如果系统没有可读数据那么select函数就会阻塞在这里。当系统存在可读或可写数据时,select函数返回,就可以调用recv函数接收数据了。


     可以看出使用select模型,需要两次调用函数。第一次调用select函数第二次socket API。使用该模式的好处是:可以等待多个套接字。


select函数

[cpp] view plaincopy
  1. <span style="font-size:18px;">int select (  
  2.    Int nfds,//被忽略。传入0即可。  
  3.    fd_set *readfds,//可读套接字集合。  
  4.    fd_set *writefds,//可写套接字集合。  
  5.    fd_set *exceptfds,//错误套接字集合。  
  6.    const struct timeval*timeout);//select函数等待时间。</span>  


    该函数返回处于就绪态并且已经被包含在fd_set结构中的套接字总数。如果超时则返回0

    第一个参数nfds被忽略。

    第二个参数readfds,可读性套接字集合指针。

    第三个参数writefds,可写性套接字集合指针。

    第四个参数exceptfds,检查错误套接字集合指针。

    第五个参数timeout,等待时间。


fd_set结构是一个结构体。


[cpp] view plaincopy
  1. <span style="font-size:18px;">typedef struct fd_set  
  2. {  
  3.      u_int fd_count;  
  4.      socket fd_array[FD_SETSIZE];  
  5. }fd_set;</span>  



fd_cout表示该集合套接字数量。最大为64.

fd_array套接字数组。

 

select函数中需要三个fd_set结构:

    一:准备接收数据的套接字集合,即可读性集合。

    二:准备发送数据的套接字集合,即可写性集合。

     在select函数返回时,会在fd_set结构中,填入相应的套接字。


readfds数组将包括满足以下条件的套接字:


     1:有数据可读。此时在此套接字上调用recv,立即收到对方的数据。

     2:连接已经关闭、重设或终止。

     3:正在请求建立连接的套接字。此时调用accept函数会成功。


writefds数组包含满足下列条件的套接字:

    1:有数据可以发出。此时在此套接字上调用send,可以向对方发送数据。

    2:调用connect函数,并连接成功的套接字。


exceptfds数组将包括满足下列条件的套接字:

    1:调用connection函数,但连接失败的套接字。

    2:有带外(out of band)数据可读。


select函数的使用:


    在调用select函数对套接字进行监视之前,必须将要监视的套接字分配给上述三个数组中的一个。然后调用select函数,再次判断需要监视的套接字是否还在原来的集合中。就可以知道该集合是否正在发生IO操作。


    例如:应用程序想要判断某个套接字是否存在可读的数据,需要进行如下步骤:

    1:将该套接字加入到readfds集合。

    2:以readfds作为第二个参数调用select函数。

    3:当select函数返回时,应用程序判断该套接字是否仍然存在于readfds集合。

    4:如果该套接字存在与readfds集合,则表明该套接字可读。此时就可以调用recv函数接收数据。否则,该套接字不可读。


     在调用select函数时,readfdswritefdsexceptfds三个参数至少有一个为非空。并且在该非空的参数中,必须至少包含一个套接字。否则select函数将没有任何套接字可以等待。


timeval结构体用于定义select的等待时间。


[cpp] view plaincopy
  1. <span style="font-size:18px;">structure timeval  
  2. {  
  3.    long tv_sec;//秒。  
  4.     long tv_usec;//毫秒。  
  5. };</span>  


    当timeval为空指针时,select会一直等待,直到有符合条件的套接字时才返回。


    当tv_sectv_usec之和为0时,无论是否有符合条件的套接字,select都会立即返回。


    当tv_sectv_usec之和为非0时,如果在等待的时间内有套接字满足条件,则该函数将返回符合条件的套接字。如果在等待的时间内没有套接字满足设置的条件,则select会在时间用完时返回,并且返回值为0


    为了方便使用,windows sockets提供了下列宏,用来对fd_set进行一系列操作。使用以下宏可以使编程工作简化。


    FD_CLR(s,*set);set集合中删除s套接字。


    FD_ISSET(s,*set);检查s是否为set集合的成员。


    FD_SET(s,*set);将套接字加入到set集合中。


    FD_ZERO(*set);set集合初始化为空集合。




   在开发Windows sockets应用程序时,通过下面的步骤,可以完成对套接字的可读写判断:

 

    1:使用FD_ZERO初始化套接字集合。如FD_ZERO(&readfds);

    2:使用FD_SET将某套接字放到readfds内。如:    

      FD_SET(s,&readfds);

    3:readfds为第二个参数调用select函数。select在返回时会返回所有fd_set集合中套接字的总个数,并对每个集合进行相应的更新。将满足条件的套接字放在相应的集合中。

    4:使用FD_ISSET判断s是否还在某个集合中。如:  

       FD_ISSET(s,&readfds);

     5:调用相应的Windows socket api 对某套接字进行操作。


     select返回后会修改每个fd_set结构。删除不存在的或没有完成IO操作的套接字。这也正是在第四步中可以使用FD_ISSET来判断一个套接字是否仍在集合中的原因。


     看例子,该例演示了一个服务器程序使用select模型管理套接字。

[cpp] view plaincopy
  1.  SOCKET listenSocket;  
[cpp] view plaincopy
  1. SOCKET acceptSocket;  
  2. FD_SET socketSet;  
  3. FD_SET writeSet;  
  4. FD_SET readSet;  
  5.   
  6.   
  7.   
  8. FD_ZERO(&socketSet);  
  9. FD_SET(listenSocket,&socketSet);  
  10. while(true)  
  11. {  
  12.     FD_ZERO(&readSet);  
  13.     FD_ZERO(&writeSet);  
  14.     readSet=socketSet;  
  15.     writeSet=socketSet;  
  16.   
  17.     //同时检查套接字的可读可写性。  
  18.     int ret=select(0,&readSet,&writeSet,NULL,NULL);//为等待时间传入NULL,则永久等待。传入0立即返回。不要勿用。  
  19.     if(ret==SOCKET_ERROR)  
  20.     {  
  21.         return false;  
  22.     }  
  23.     sockaddr_in addr;  
  24.     int len=sizeof(addr);  
  25.     //是否存在客户端的连接请求。  
  26.     if(FD_ISSET(listenSocket,&readSet))//在readset中会返回已经调用过listen的套接字。  
  27.     {  
  28.         acceptSocket=accept(listenSocket,(sockaddr*)&addr,&len);  
  29.         if(acceptSocket==INVALID_SOCKET)  
  30.         {  
  31.             return false;  
  32.         }  
  33.         else  
  34.         {  
  35.             FD_SET(acceptSocket,&socketSet);  
  36.         }  
  37.     }  
  38.   
  39.     for(int i=0;i<socketSet.fd_count;i++)  
  40.     {  
  41.         if(FD_ISSET(socketSet.fd_array[i],&readSet))  
  42.         {  
  43.             //调用recv,接收数据。  
  44.         }  
  45.         if(FD_ISSET(socketSet.fd_array[i]),&writeSet)  
  46.         {  
  47.             //调用send,发送数据。  
  48.         }  
  49.     }  
  50. }  

         以下展示了一个客户端程序使用select模型的用法。注意与服务器用法相区别。主要区别就是不可能有请求进来,也就不需要使用allsocketfds。仅仅对一个套接字进行判断:

[cpp] view plaincopy
  1. CRemoteFileDownloadClientDlg*pdlg=(CRemoteFileDownloadClientDlg*)ppram;  
  2.   
  3.     FD_SET readfds;  
  4.     FD_SET writefds;  
  5.   
  6.     while(pdlg->m_IsConnected)  
  7.     {  
  8.         FD_ZERO(&readfds);  
  9.         FD_ZERO(&writefds);  
  10.         FD_SET(pdlg->m_ServerSocket,&readfds);  
  11.         FD_SET(pdlg->m_ServerSocket,&writefds);  
  12.           
  13.   
  14.         int ret=select(0,&readfds,&writefds,NULL,NULL);//NULL为无限等待。0立即返回。  
  15.         if(ret>0)  
  16.         {  
  17.             if(FD_ISSET(pdlg->m_ServerSocket,&readfds));//注意与服务器此处写法相区别。  
  18.             {  
  19.                 pdlg->recvData();  
  20.             }  
  21.             if(FD_ISSET(pdlg->m_ServerSocket,&writefds))  
  22.             {  
  23.                 //可写。  
  24.                 pdlg->sendData();  
  25.             }  
  26.               
  27.         }  
  28.   
  29.     }  

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/509610.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Set实现类性能对比

Set接口的实现类: 共同的特点: 1):都不允许元素重复. 2):都不是线程安全的类. 解决方案:Set s Collections.synchronizedSet(Set对象); HashSet: 不保证元素的先后添加顺序. 底层才有的是哈希表算法,查询效率极高. 判断两个对象是否相等的规则: 1):equals比较为true. …

HugeGraph Server/Hubble安装使用

文章目录HugeGraph Server1 概述2 依赖2.1 安装JDK-1.83 部署3.1 下载tar包4 安装启动4.1 解压4.2 配置Hbase5 访问Server5.1 服务启动状态校验6 停止Server7 多图配置HugeGraph-Hubble 基于Web的可视化图形界面1.概述2.安装3 使用3.1创建图HugeGraph Server 1 概述 HugeGrap…

Mysql 集群双主双从安装使用详细讲解

文章目录下载Mysql安装单机Mysql配置Mysql集群双Master配置master1配置master2配置配置说明双Slave配置Slave1配置Slave2配置双 Master 机上创建账号&#xff0c;并授权远程复制查询Master1的状态查询Master2的状态双Slave机上执行 change master 同步Master数据Slave1 复制 Ma…

ElasticSearch 新增节点,横向扩容

文章目录查看当前ES状态新增节点配置遇到的问题查看当前ES状态 这里默认都是在Kibana进行操作 GET _cluster/health{"cluster_name" : "bjga-gz","status" : "yellow","timed_out" : false,"number_of_nodes" :…

输入和输出(IO)概述

什么是IO:(Input/Output):输入和输出. IO设备: 和电脑通信的设备. 输入设备:麦克风,扫描器,键盘,鼠标等. 输出设备:显示器,打印机,投影仪,耳机,音响等. 为什么程序需要IO呢? 案例1:打游戏操作,得分比较高,存储游戏的信息(XXX-888分). 此时需要把游戏中的数据存储起来,只能…

java中有关文件流的操作

文件流: 顾名思义,程序和文件打交道. 此时我们谈及的文件,值得是纯文本文件(txt的,不要使用Word,Excel), 在字节流中,暂时不要使用中文. FileInputStream: 文件的字节输入流 FileOutputStream: 文件的字节输出流 FileReader:文件的字符输入流 FileWriter:文件的字符输出流…

数据结构实验之二叉树一:树的同构

题目描述 给定两棵树T1和T2。如果T1可以通过若干次左右孩子互换就变成T2&#xff0c;则我们称两棵树是“同构”的。例如图1给出的两棵树就是同构的&#xff0c;因为我们把其中一棵树的结点A、B、G的左右孩子互换后&#xff0c;就得到另外一棵树。而图2就不是同构的。 图1 …

java中字符编码详解

字符编码的发展历程: 阶段1: 计算机只认识数字,我们在计算机里一切数据都是以数字来表示,因为英文符号有限, 所以规定使用的字节的最高位是0.每一个字节都是以0~127之间的数字来表示,比如A对应65,a对应97. 这就是美国标准信息交换码-ASCII. 阶段2: 随着计算机在全球的普及…

java中的包装流和缓冲流概述

处理流/包装流(相对于节点流更高级)装饰设计模式/包装模式: 1:隐藏了底层的节点流的差异,并对外提供了更方便的输入/输出功能,让我们只关心高级流的操作. 2:使用处理流包装了节点流,程序直接操作处理流,让节点流与底层的设备做IO操作. 3:只需要关闭处理流即可. 包装流如何区…

转换流和内存流

转换流:把字节流转成字符流: InputStreamReader:把字节输入流转成字符输入流. OutputStreamWriter:把字节输出流转成字符输出流. 为什么有字节转字符流,没有字符转字节流. 字节流可以操作一切文件(纯文本文件/二进制文件).字符流是用来操作中文纯文本使用的,本身是对字节流的…

windows配置gvim高效率编程(cc++)带自动补全代码

对vim的配置足以处理一般的比赛获其他编程项目要求&#xff0c;如自动缩进&#xff0c;自动补全等等。先上几张截图&#xff0c;看看效果&#xff1a; 可以看见vim简洁高效的界面和不错的缩进功能。 debug功能 一、安装gvim 下载资源并安装 百度云下载网址http://pan.baid…

Flink 1.12 CDH 6.3 集成

之前记录的&#xff1a;Flink 1.9 CDH 6.3 集成 有些下载链接可能被官方关闭了&#xff0c;这里介绍1.12版本集成&#xff0c;并把安装包下载地址换为百度网盘链接 下载安装包 链接: https://pan.baidu.com/s/112fiaaMAMMXMsyiTDh3qjg 提取码: ar5f 安装包内容 FLINK-1.12…

合并流

合并流/顺序流(SequenceInputStream): 就是把多个输入流,合并成一个流对象.

gvim常用的配置及插件 -windows

gvim常用的配置及插件 接触vim也已经有一年多了&#xff0c;期间也用过一段时间的SourceInsight&#xff0c;SourceInsight是Windows下一款不错的查看代码的软件。利用它可以迅速的了解一个大型程序的结构。后来在Linux下进行了一段时间的程序开发&#xff0c;就回到vim上了,经…

CDH 6 安装服务哈希验证失败 解决方法

当安装cdh 6&#xff0c;使用本地搭建的parcel时&#xff0c;出现了哈希验证失败的问题&#xff1a; 查看了parcel的sha值&#xff0c;与官网的一致&#xff0c;没有问题&#xff1a; #parcel sha值 [rootlocalhost bigdata]# sha1sum CDH-6.0.0-1.cdh6.0.0.p0.537114-el7.pa…

gvim配置

手把手教你把Vim改装成一个IDE编程环境(图文) By:吴垠Date:2007-09-07Version:0.5Email:lazy.fox.wu#gmail.comHomepage:http://blog.csdn.net/wooinCopyright:该文章版权由吴垠和他可爱的老婆小包子所有。可在非商业目的下任意传播和复制。对于商业目的下对本文的任何行为需…

Gvim开发环境配置笔记--Windows篇

环境&#xff1a;Windows7 旗舰版 1、安装Gvim7.3 &#xff1a; 下载地址http://www.vim.org/download.php#pc。 2、安装中文帮助&#xff1a;vimcdoc-1.8.0-setup.exe 地址http://vimcdoc.sourceforge.net/ 会自动识别gvim的安装路径&#xff0c; 安装完后&#xff0c;gvim菜单…

Grafana : 前端页面 通过API Key免登录访问Grafana

文章目录场景一是使用匿名登陆&#xff0c;最简单方便二是使用grafana颁发一个API Key。场景 平台要集成grafana&#xff0c;想绕过用户登录&#xff0c;目前知道有2个方法。 前提&#xff1a;先修改配置defaults.ini/grafana.ini允许嵌入 allow_embedding true一是使用匿名…

CentOS 使用iso镜像安装本地 yum 源

文章目录下载服务器镜像挂载iso镜像修改yum源挂载iso到系统中查看挂载状态挂载完成后清缓存安装服务测试下载服务器镜像 下载与我们服务器相同版本的服务器镜像。 查看当前服务器版本 [rootiZot101s4kxuygvttz67vjZ yum.repos.d]# cat /etc/redhat-release CentOS Linux re…

Grafana Prometheus 服务安装部署(Linux服务器监控)

文章目录一、概述二、安装Prometheus1.安装node_exporter2.安装Prometheus三、安装Grafana展示监控监控进程一、概述 Prometheus 介绍 Prometheus是一套开源的监控&报警&时间序列数据库的组合&#xff0c;起始是由SoundCloud公司开发的。随着发展&#xff0c;越来越多…