网络编程----select 模型总结

为什么要使用select模型?

答:解决基本C/S模型中,accept()recv()send()阻塞的问题

select模型与C/S模型的不同点
  • C/S模型中accept()会阻塞一直傻等socket来链接
  • select模型只解决accept()傻等的问题,不解决recv(),send()执行阻塞问题
其实select模型解决了 实现多个客户端链接,与多个客户端分别通信
两个模型都存在recv(),send()执行阻塞问题
  • 由于服务器端,客户端不需要(客户端只有一个socket,可以通过加线程解决同时recv和send)

select模型逻辑

  1. 将所有的socket(服务器端+客户端)装进一个数组中
  2. 通过select()遍历socket数组
  3. 取出有相应的socket放进另一个数组(都是有响应的socket)
  4. 对装有响应的socket数组集中处理
  5. 服务器socket响应:客户端链接,调用accept()
  6. 客户端socket响应:客户端通信,调用send()或recv()

图片描述


select()

fd_set

作用:定义一个用来装socket的结构体

#ifndef FD_SETSIZE
#define FD_SETSIZE      64   /*默认64个*/
#endif /* FD_SETSIZE */

typedef struct fd_set {
        u_int fd_count;               /* how many are SET? */
        SOCKET  fd_array[FD_SETSIZE];   /* an array of SOCKETs */
} fd_set;

默认装socket大小为64,可以通过在winsock2.h头文件前声明宏,给一个更大的值

#define FD_SETSIZE 128
#include <WinSock2.h>

因为原理就是不停遍历检测,越多效率越低,延迟越大,所以合适大小最好。
select模型应用,就是小用户量访问

四个操作fd_set的操作宏
操作宏作用代码
FD_ZERO将客户端socket集合清零FD_ZERO(&clientSockets);
FD_SET添加一个socket(超过默认值大小不再处理)FD_SET(socketListen,&clientSockets);
FD_CLR从集合中删除指定的socket,一定要close,手动释放FD_CLR(socketListen, &clientSockets);closesocket(socketListen);
FD_ISSET查询socket是否在集合中,不存在返回0,存在返回非0int a = FD_ISSET(socketListen, &clientSockets);
select()函数

作用:监视socket集合,如果某个socket发生响应(链接或者收发数据),通过返回值以及参数告诉我们哪个socket有响应

int WSAAPI select(
  int           nfds,   /*填0*/
  fd_set        *readfds, /*检查是否有可读的socket*/
  fd_set        *writefds, /*检查是否有可写的socket*/
  fd_set        *exceptfds, /*检查socket上的异常错误*/
  const timeval *timeout
);
参数1:忽略填0

为了兼容Berkeley sockets

参数2:指向一组socket数组,用来保存有响应的数组
  • 只针对recv()、accept()
  • 这个用来保存有响应的数组初始化为包含所有的socket,通过select函数投放给系统,系统遍历数组后,只将有响应的socket再赋值回来,调用后,这个参数只剩下有请求的socket
参数3:指向一组socket数组,用来保存可发送的数组
  • 可以给哪些客户端socket发送消息,针对send
  • 这个用来保存可发送的数组初始化为包含所有的socket,通过select函数投放给系统,系统遍历数组后,只将可发送的socket再赋值回来,调用后,这个参数只剩下可发送的socket
参数4:检查socket上的异常错误

用法和参数2、3一样,将有异常错误的socket装进来,反馈给我们

/*得到异常socket上的具体错误码*/
getsockopt(socket, SOL_SOCKET, SO_ERROR, buf, buflen);

如果调用这个函数(针对这个getsockopt函数)没有错误,返回0,否则返回SOCKET_ERROR,并且可以调用WSAGetLastError来得到错误代码。

参数5:最大等待时间

一个结构体

struct timeval {
        long    tv_sec;         /* seconds */
        long    tv_usec;        /* and microseconds */
};

当客户端没有响应时,select可以选择等一段时间,不等,等到有socket响应,三种方式

tv_sectv_usec作用
00不等待,立刻返回
34等待3秒4微秒没有消息再返回

NULL :死等,直到有socket响应

返回值
  • 0:在等待时间没有客户端socket响应,continue进行下一次等待
  • >0:有客户端socket响应‘
  • SOCKET_ERROR:发送错误

select模型代码
    fd_set allsockets;
    //清零
    FD_ZERO(&allSockets);
    //服务器装进去
    FD_SET(socketServer, &allSockets);
    while (1)
    {
        fd_set readSockets = allSockets;
        fd_set writeSockets = allSockets;
        fd_set errorSockets = allSockets;

        //时间段
        struct timeval st;
        st.tv_sec = 3;
        st.tv_usec = 0;

        //select
        int nRes = select(0, &readSockets, &writeSockets, &errorSockets, &st);
        if (0 == nRes) //没有响应的socket
        {
            continue;
        }
        else if (nRes > 0)
        {
            //处理错误
            for (u_int i = 0; i < errorSockets.fd_count; i++)
            {
                char str[100] = { 0 };
                int len = 99;
                if (SOCKET_ERROR == getsockopt(errorSockets.fd_array[i], SOL_SOCKET, SO_ERROR, str, &len))
                {
                    printf("无法得到错误信息\n");
                }
                printf("%s\n", str);    
            }

            for (u_int i = 0; i < writeSockets.fd_count; i++)
            {
                //printf("服务器%d,%d:可写\n", socketServer, writeSockets.fd_array[i]);
                if (SOCKET_ERROR == send(writeSockets.fd_array[i], "ok", 2, 0))
                {
                    int a = WSAGetLastError();
                }
            }

            //有响应
            for (u_int i = 0; i < readSockets.fd_count; i++)
            {
                if (readSockets.fd_array[i] == socketServer)
                {
                    //accept
                    SOCKET socketClient = accept(socketServer, NULL, NULL);
                    if (INVALID_SOCKET == socketClient)
                    {
                        //链接出错
                        continue;
                    }
                    
                    FD_SET(socketClient, &allSockets);
                    //send
                }
                else
                {
                    char strBuf[1500] = { 0 };
                    //客户端吧
                    int nRecv = recv(readSockets.fd_array[i], strBuf, 1500, 0);
                    //send
                    if (0 == nRecv)
                    {
                        //客户端下线了
                        //从集合中拿掉
                        SOCKET socketTemp = readSockets.fd_array[i];
                        FD_CLR(readSockets.fd_array[i], &allSockets);
                        //释放
                        closesocket(socketTemp);
                    }
                    else if (0 < nRecv)
                    {
                        //接收到了消息
                        printf(strBuf);
                    }
                    else //SOCK_ERROR
                    {
                        //强制下线也叫出错 10054
                        int a = WSAGetLastError();
                        switch (a)
                        {
                        case 10054:
                            {
                                SOCKET socketTemp = readSockets.fd_array[i];
                                FD_CLR(readSockets.fd_array[i], &allSockets);
                                //释放
                                closesocket(socketTemp);
                            }    
                        }
                    }    
                }
            }
        }

图片描述

总结

select模型

将一组socket数组投递给系统,然后在系统里去查询socket是否有信号,过程都是在select函数里面去进行的,再到返回有操作的socket集合

select()函数本质

select()函数执行遍历和返回有响应的socket,整个过程中也是阻塞的。

等待时间阻塞
不等待执行阻塞
半等待执行阻塞+软阻塞
全等待执行阻塞+硬阻塞
与CS模型对比

使用CS模型时,当链接了一个客户端,执行完了recv,while循环又回到了accept(),傻等着客户端来链接,无法多客户端链接通信。
使用select模型时,是select在遍历着socket数组,有响应的socket再取出来,没有就一直遍历,虽然select()函数的执行也是阻塞的。可以理解为,每次都是在处理只有响应的socket,所以可以进行多客户端链接通信。

当第一个客户端socket来链接时,select()函数将服务端socket从allsocket取出来,将新建的含有客户端socket添加到allsockets数组中,接着又在遍历allsocket,查看着时候有响应,所以不会像CS模型那种,在accept()函数阻塞着,傻等着。
select()函数主要解决的是accept()函数阻塞问题,而没有解决recv()和send()函数阻塞问题

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

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

大厂大数据面试题收录(1)

目录 1.java 中 object 类有哪些方法? 2.说一下和equals的区别&#xff1f; 3.为什么要重写 equals 和 hashcode()方法&#xff1f; 4.机器学习中&#xff0c;监督学习 和 无监督学习的区别是啥&#xff1f;&#xff1f; 5.kafka 组件熟悉吗,kafka 如何实现消息的有序的&a…

css 表示具有特定类或者其他属性的某种标签类型的元素

需求 通过 css 选择器获取某种标签&#xff08;如&#xff1a;div、input 等&#xff09;具有某个属性&#xff08;如&#xff1a;class、id 等&#xff09;的元素&#xff0c;从而修改其样式。 代码 通过 [标签].[属性] 的方式来获取 <div class"test">&l…

C++相关闲碎记录(8)

1、预定义的Function adapter 和 binder #include <iostream> #include <functional>int main() {auto plus10 std::bind(std::plus<int>(), std::placeholders::_1, 10);std::cout << "10: " << plus10(6) << std::endl…

基于FPGA的视频接口之高速IO(PCIE)

简介 相对于其他高速IO接口应用&#xff0c;PCIE协议有专门的的IP来进行操作&#xff0c;通过8对输入高速IO&#xff0c;以及输出高速IO&#xff0c;来实现PCIEX8功能。 原理框图 原理图 软件调用

Nginx首页修改及使用Nginx实现端口转发

按照我之前博客给的方法搭建好这样一个CTF靶场 但是呢它默认是在8000端口 如何直接访问IP地址或者域名就可以实现直接访问到靶场呢 我们需要将80端口的内容转发到8000&#xff0c;使用nginx实现端口转发功能 首先我们安装nginx&#xff1a; 安装工具和库 yum -y install gc…

《地理信息系统原理》笔记/期末复习资料(9. 网络地理信息系统)

目录 9. 网络地理信息系统 9.1. 概述 9.1.1. 网络GIS概念 9.1.2. 网络GIS体系结构 9.1.3. 网络GIS内容体系 9.2. 分布式网络GIS 9.2.1. 分布式网络GIS概念 9.2.2. 分布式主要技术 9.3. WebGIS 9.3.1. WebGIS概念 9.3.2. WebGIS分类与特点 9.3.3. WebGIS技术框架 9…

IDEA中的Postman!这款插件:免费,好用!

Postman是大家最常用的API调试工具&#xff0c;那么有没有一种方法可以不用手动写入接口到Postman&#xff0c;即可进行接口调试操作&#xff1f;今天给大家推荐一款IDEA插件&#xff1a;Apipost Helper&#xff0c;写完代码就可以调试接口并一键生成接口文档&#xff01;而且还…

电商早报 | 12月12日| 淘宝公布2023年度商品初选名单入围

淘宝公布2023年度商品初选名单&#xff1a;军大衣、酱香拿铁、熊猫周边入围 又一年临近收官&#xff0c;淘宝如期启动了“2023年度十大商品”评选。 12月11日&#xff0c;淘宝官方发布了初选入围名单&#xff0c;30件最具代表性的商品脱颖而出。据淘宝路边社介绍&#xff0c;…

系统架构设计师教程(三)信息系统基础知识

信息系统基础知识 3.1 信息系统概述3.1.1 信息系统的定义3.1.2 信息系统的发展3.1.3 信息系统的分类3.1.4 信息系统的生命周期3.1.5 信息系统建设原则3.1.6 信息系统开发方法 3.2 业务处理系统 (TPS)3.2.1 业务处理系统的概念3.2.2 业务处理系统的功能3.2.3 业务处理系统的特点…

互联网加竞赛 opencv 图像识别 指纹识别 - python

0 前言 &#x1f525; 优质竞赛项目系列&#xff0c;今天要分享的是 &#x1f6a9; 基于机器视觉的指纹识别系统 &#x1f947;学长这里给一个题目综合评分(每项满分5分) 难度系数&#xff1a;3分工作量&#xff1a;3分创新点&#xff1a;4分 该项目较为新颖&#xff0c;适…

Pearson、Spearman 相关性分析使用

介绍 Pearson 积差相关系数衡量了两个定量变量之间的线性相关程度。 用来衡量两个数据集的线性相关程度&#xff0c;仅当一个变量的变化与另一个变量的比例变化相关时&#xff0c;关系才是线性的。 Spearman等级相关系数则衡量分级定序变量之间的相关程度。斯皮尔曼相关系数不…

学习数据结构第一步(必看)——初识集合框架

一&#xff0c;学习数据结构前置知识 目录 一&#xff0c;学习数据结构前置知识 二&#xff0c;什么是数据结构&#xff1f; 1.什么是数据结构&#xff1f; 2.容器背后对应的数据结构 3.相关Java知识 4.什么是算法&#xff1f; 三&#xff0c;什么是集合&#xff1f; …

【详细解答】项目经VS产品经理,有什么区别?哪个更值得选择?

最近很多人咨询“项目经理跟产品经理该怎么选&#xff0c;我更适合哪个&#xff1f;”“项目经理跟产品经理哪个更有钱途 ”“项目经理转产品经理好转吗”等等&#xff0c;今天就一次性说清楚项目经理跟产品经理有什么区别&#xff0c;应该怎么选择。 不想看长篇大论的&#x…

区块链的可拓展性研究【03】扩容整理

为什么扩容&#xff1a;在layer1上&#xff0c;交易速度慢&#xff0c;燃料价格高 扩容的目的&#xff1a;在保证去中心化和安全性的前提下&#xff0c;提升交易速度&#xff0c;更快确定交易&#xff0c;提升交易吞吐量&#xff08;提升每秒交易量&#xff09; 目前方案有&…

Halcon参考手册语义分割和边缘提取知识总结

1.1 语义分割和边缘提取介绍 通过语义分割&#xff0c;我们使用深度学习(DL)网络将输入图像的每个像素分配给一个类。 图(1)语义分割示例 在图(1)中&#xff0c;输入图像的每个像素都被分配给一个类&#xff0c;但是苹果的三个不同实例和橘子的两个不同实例都不是可区分的对象…

C++STL的vector模拟实现

文章目录 前言成员变量成员函数构造函数push_backpop_backinserterase析构函数拷贝构造 前言 成员变量 namespace but {template<class T>class vector{public:typedef T* iterator;private:iterator _start;iterator _finish;iterator _end_of_storage;}; }我们之前实…

c/c++ malloc、calloc、realloc and free

malloc 需要头文件 #include<stdlib.h> void *malloc( size_t size ); malloc returns a void pointer to the allocated space, or NULL if there is insufficient memory available. To return a pointer to a type other than void, use a type cast on the return …

【算法题】单词接龙(js)

![在这里插入图片描述](https://img-blog.csdnimg.cn/direct/7fcc5df3354742bd88dad28219f82bf8.png 用例&#xff1a; 输入&#xff1a; 0 6 word dd da dc dword d 输出&#xff1a; worddwordda 说明&#xff1a; 先确定起始单词word&#xff0c;再接以d开有的且长度最长…

Canal实时同步MySQL数据到ES

一、canal简介 canal主要用途是对MySQL数据库增量日志进行解析&#xff0c;提供增量数据的订阅和消费&#xff0c;简单说就是可以对MySQL的增量数据进行实时同步&#xff0c;支持同步到MySQL、Elasticsearch、HBase等数据存储中去。 早期阿里巴巴因为杭州和美国双机房部署&…

MATLAB运动学之蒙特卡罗法求积分与机器人工作域分析

蒙特卡罗法又叫做统计模拟法、随机抽样技术&#xff0c;是一种随机模拟方法以概率和统计理论方法为基础的一种计算方法&#xff0c;通俗来说是可以使用随机数来解决很多计算问题的一种方法&#xff0c;很直观简单&#xff0c;尤其对于一些求解积分无解的情况&#xff0c;非常好…