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. …

RSocket协议初识

文章目录前言RSocket是什么&#xff1f;RSocket设计目标是什么&#xff1f;RSocket与其他协议有什么区别&#xff1f;对比Http1.x对比Http2.x对比grpc对比TCP对比WebSocket结论RSocket适用于哪些场景&#xff1f;1、移动设备与服务器的连接。2、微服务场景。3、由于微服务和移动…

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…

Socket模型

两种I/O模式 一.选择模型 二.异步选择 三.事件选择 四.重叠I/O模型 五.完成端口模型 五种I/O模型的比较 两种I/O模式 1、 两种I/O模式 阻塞模式&#xff1a;执行I/O操作完成前会一直进行等待&#xff0c;不会将控制权交给程序。套接字默认为阻塞模式。可以通过多线程技术进行处…

数据结构实验之二叉树的建立与遍历

题目描述 已知一个按先序序列输入的字符序列&#xff0c;如abc,,de,g,,f,,,(其中逗号表示空节点)。请建立二叉树并按中序和后序方式遍历二叉树&#xff0c;最后求出叶子节点个数和二叉树深度。 输入 输入一个长度小于50个字符的字符串。输出 输出共有4行&#xff1a; 第1行输出…

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

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

vs2010常见错误记录

&#xff08;1&#xff09;在Debug模式下正常&#xff0c;在Release模式下程序出现异常 可能原因&#xff1a;配置的链接dll有问题&#xff0c;后缀带d和不带d混淆&#xff1b;在Release模式下类中的变量不会自动进行初始化&#xff0c;需要手动初始化&#xff1b;

java中的IO操作之File类

Java的集合框架: 类和接口存在于java.util包中. Java的IO: 类和接口存在于java.io包中. 学习方法: 文档在手,天下我有! ----------------------------------------------------------------------------------------- 讲IO操作之前,必须要先讲File类(文件/目录…

数据结构实验之二叉树三:统计叶子数

题目描述 已知二叉树的一个按先序遍历输入的字符序列&#xff0c;如abc,,de,g,,f,,, (其中,表示空结点)。请建立二叉树并求二叉树的叶子结点个数。 输入 连续输入多组数据&#xff0c;每组数据输入一个长度小于50个字符的字符串。 输出 输出二叉树的叶子结点个数。 示例输入 ab…

企业需要的C++程序员

今天对智联招聘网站和前程无忧招聘网站对“任职要求"一栏进行了相关技术要求作了简要的统计&#xff0c;主要提取的是在任职要求中明确提到的信息&#xff0c;招聘城市针对长沙和深圳&#xff0c;招聘公司为随机抽取&#xff0c;列了以下技术要求出现的次数。希望在自己的…

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分). 此时需要把游戏中的数据存储起来,只能…

求二叉树的深度

题目描述 已知一颗二叉树的中序遍历序列和后序遍历序列&#xff0c;求二叉树的深度。 输入 输入数据有多组&#xff0c;输入T组数据。每组数据包括两个长度小于<font face"\"Times" new"" roman,"" serif\""" style"…

优秀的程序员怎么做

我觉得优秀的程序员&#xff0c;不仅优秀在代码上&#xff0c;更重要在思维等方面。 我认为一个优秀程序员是谨慎的&#xff0c;在有需求与任务时&#xff0c;会不断的澄清需求与任务&#xff0c;并且多次确认想要的结果&#xff0c;而非闷头听着或者看着需求与任务列表。 我…

Linux 挂载磁盘目录

文章目录查看Linux磁盘信息格式化磁盘挂载修改重启后自动挂载fstab 文件格式介绍卸载查看Linux磁盘信息 [rootb001 ~]# fdisk -lDisk /dev/vda: 53.7 GB, 53687091200 bytes, 104857600 sectors Units sectors of 1 * 512 512 bytes Sector size (logical/physical): 512 by…

linux学习路线

很多同学接触Linux不多&#xff0c;对Linux平台的开发更是一无所知。而现在的趋势越来越表明&#xff0c;作为一个优秀的软件开发人员&#xff0c;或计算机IT行业从业人员&#xff0c;掌握Linux是一种很重要的谋生资源与手段。下来我将会结合自己的几年的个人开发经验&#xff…

java中有关文件流的操作

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

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

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

Linxu服务器文件双向同步 rsync+sersync 详细讲解

文章目录Linxu服务器文件双向同步 rsyncsersync基础信息安装rsync安装配置根据配置文件创建相应的目录、文件、防火墙规则创建需要同步的目录创建同步用户防火墙启动rsyncd服务测试异常处理sersync安装sersync配置test21配置test22配置sersync启动test21启动test22启动测试新增…

resize和reverse的区别

首先&#xff0c;两个函数的功能是有区别的&#xff1a; reserve是容器预留空间&#xff0c;但并不真正创建元素对象&#xff0c;在创建对象之前&#xff0c;不能引用容器内的元素&#xff0c;因此当加入新的元素时&#xff0c;需要用push_back()/insert()函数。 resize是…