【Linux网络编程】select多路复用

news2024/11/17 17:31:49

文章目录

  • 前言
  • 如何增强服务端的通信能力
  • Linux的设计哲学
  • 文件描述符
    • 代码讲解
  • 以文件方式操作命令行
    • 阻塞函数与非阻塞函数
    • 轮询
    • select()
  • 代码全貌
  • The End


前言

我们上节课讲解了服务端的编程(Linux服务端编程初体验)
本节课要讲的是select


提示:以下是本篇文章正文内容,下面案例可供参考

如何增强服务端的通信能力

如何增强服务端的能力,同时支持很多个客户端?
1、有同学说:用多线程啊!
这个回答可以完成,但有缺陷:太占用系统的资源了

所以:我们的select就诞生了

Linux的设计哲学

一切都是文件!

Linux中文件是什么
1、文件系统中物理意义上的文件
2、Linux管理的一切对象

文件描述符

他就是一个非负整数值,一个句柄
如果学习过Windows的小伙伴应该知道什么是句柄
没有学过也不要紧,他就是一个非负整数值

作用:
1、与内核交互
2、内核通过他操作对应的数据结构

玩法:

1、open
2、read
3、write
4、close

Linux文件编程模式:

int fd = open("Dev",O_RDWR);
if(fd!=-1)
{
	char buf[32] = {0};
	int len = read(fd,buf,sizeof(buf));
	
	len = write(fd,buf,len);
	
	close(fd);
}

代码讲解

注意:在Linux中,我们不需要open打开文件close关闭文件,因为内核已经帮忙打开了

函数原型讲解

write(fd,void *p,size_t s);//参数1:要操作的文件描述符,参数2:要写入的地址,写入的大小
int read(fd,void *p,size_t readsize);//参数1:要操作的文件描述符,参数2:存储的地址,读出的大小
#include <stdio.h>
#include <unistd.h>

int main()
{
    int iofd = 0;
    char s[] = "csdn\n";
    int len = 0;

    write(0, s, sizeof(s));

    len = read(0, s, 5);
    
    s[len] = 0;

    printf("%s\n", s);

    return 0;
}

结果:
在这里插入图片描述
所以我们可以说:write和printf的功能是一样的
read和scanf的功能是一样的

以文件方式操作命令行

阻塞函数与非阻塞函数

阻塞函数:
要等某个事件发生了才返回

非阻塞函数:
函数调用后可以及时返回(仅仅标记等待的事件)
事件发生后以回调的方式传递

轮询

轮询指依次询问每个相关设备是否需要服务的方式
轮询可以解决阻塞函数导致程序无法进行的问题

select()

功能:用于监视指定的文件描述符是否产生事件

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

参数1:指定的文件描述符
参数2:从readset里看有没有读事件发生,有:标记
参数3:从writeset里看有没有写事件发生
参数4:从excepset里面看有没有哪个有错误
参数5:多久没有响应为超时

返回值:
当返回值>0:有事件
当返回值==0:无事件

select()多路复用的使用步骤:

1、设置文件描述符
2、设置监听范围
3、设置监听超时
4、调用select
5、查看监听结果
6、处理目标事件
7、调用select....

fd_set的意义
就是一个装着文件描述符的数组

操作函数

FD_ZERO(fd_set *fdset);//将fdset里面的所有位设置成0
FD_SET(int fd,fd_set *fd fdset);//设置fd到fdset中
FD_CLR(int fd,fd_set *fdset);//从fdset中删除fd
FD_ISSET(int fd,fd_set *fdset);//判断fd在不在fdset中

代码全貌

#include <sys/select.h>
#include <sys/time.h>
#include <stdio.h>
#include <unistd.h>

int main()
{
    int len = 0;
    fd_set reads = {0};
    fd_set temps = {0};
    struct timeval timeout = {0};
    int iofd = 0;
    char s[32] = {'\0'};

    FD_ZERO(&reads);
    FD_SET(iofd, &reads);

    while( 1 )
    {
        int r = -1;

        temps = reads;

        timeout.tv_sec = 0;
        timeout.tv_usec = 50000;

        r = select(1, &temps, 0, 0, &timeout);

        if( r > 0 )
        {
            len = read(iofd, s, sizeof(s)-1);

            s[len] = 0;

            printf("Input: %s\n", s);
        }
        else if( r == 0 )
        {
            static int count = 0;

            usleep(10000);   // do something else

            count++;

            if( count > 100 )
            {
                printf("do something else\n");

                count = 0;
            }
        }
        else
        {
            break;
        }
    }

    return 0;
}

需要注意的细节:
其中iofd为文件操作符
reads用于保存文件操作符
temps用于select()函数
原因:select()函数调用后,temps里面就只剩有信号的fd了,因为reads不能丢,所以不能直接设置reads到里面,因为temps里面就只剩有信号的fd了,所以每次reads里面的也要赋值到temps里
maxfd = iofd+1;

temeval成员:

timeout.tv_sec = 0;//延时多少秒
timeout.tv_usec = 50000;//延时多少毫秒

The End

做这博客也是很难的,望大家的点赞关注!

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

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

相关文章

RocketMQ引发的磁盘预警复盘

RocketMQ引发的磁盘预警复盘前言发现问题排查过程Step 1Step 2Step 3Step 4Step 5Step 6Step 7Step 8Step 9解决方式写在最后前言 一款优秀的中间件&#xff0c;参数的缺省值必然是经过反复验证得出的最优解&#xff0c;勿动&#xff01; 发现问题 某台SaaS服务器磁盘不足发出…

kafka的 __consumer_offsets

Zookeeper不适合大批量的频繁写入操作。Kafka 1.0.2将consumer的位移信息保存在Kafka内部的topic中&#xff0c;即__consumer_offsets主题&#xff0c;并且默认提供了kafka_consumer_groups.sh脚本供用户查看consumer信息。 1、创建topic “tp_test_01” [rootnode1 ~]# kafka…

《Linux运维总结:Centos7.6部署二进制mongodb4.4.8三节点副本集群》

一、Mongodb集群模式 1、三种集群介绍 MongoDB有三种集群部署模式&#xff0c;分别为主从复制&#xff08;Master-Slaver&#xff09;、副本集&#xff08;Replica Set&#xff09;和分片&#xff08;Sharding&#xff09;模式。 1、Master-Slaver 是一种主从副本的模式&#x…

自动驾驶之行人轨迹预测数据集

一、 Real Data ETH: Univ. Hotel;750 pedestrians exhibiting complex interactions UCY: Zara01, Zara02 and Uni.780 pedestrians 单应性矩阵&#xff0c;SLAM中的当用多个不同相机拍摄同一个三维平面需要考虑的矩阵&#xff0c;适应场景为平面情况 商场 这个数据集是用双…

Onvif学习

ONVIF onvif&#xff08;Open Network Video Interface Forum&#xff0c;开放型网络视频接口论坛&#xff09;协议. onvif协议涵盖了设备发现、设备配置、事件、PTZ控制、视频分析和实时流媒体直播功能&#xff0c;以及搜索&#xff0c;回放和录像录音管理功能。 先去看许振…

git 常用操作

Git 是一个分布式版本控制系统&#xff0c;用于项目开发中的版本控制。从本质上来讲Git是一个内容寻址(content-addressable)文件系统&#xff0c;并在此之上提供了一个版本控制系统的用户界面。 Git的核心部分是一个简单的键值对数据库(key-value data store)。 你可以向该数据…

XML配置文件、用来约束XML文档:DTD、Schema(类型更多)

上一章properties作为配置文件的内容好像还没讲&#xff1f; properties相对于XML的缺点&#xff1a;如果要运行多个方法&#xff0c;只能在properties配置文件里等号后面加逗号&#xff08;或指定符号&#xff09;隔开&#xff0c;然后再加值&#xff0c;这样累加下去会导致阅…

基于分布式数据库集群的大数据职位信息统计

目录 任务一&#xff1a; MongoDB 分布式集群关键配置信息截图&#xff08;启动参数文件、初始化参数文件、启动命令等&#xff09; ch0的参数文件配置&#xff1a; ​编辑 ch1的参数文件配置&#xff1a; ​编辑chconfig的参数文件配置&#xff1a; router的参数文件配置…

SpringSecurity整合Oauth2.0

SpringSecurity整合Oauth2.0一、概述与原理1.1 、OAuth2.0 是什么&#xff1f;1.2、OAuth2.0中角色解释1.3、OAuth2.0的4中授权模式1.3.1、授权码模式&#xff08;重点&#xff09;1.3.1.1 原理1.3.1.2 代码1.3.2、密码模式&#xff08;重点&#xff09;1.3.2.1 原理1.3.2.2 代…

开发运维(DevOps)自动化运维与持续交付企业级实战

一、网站部署流程 1、传统网站部署流程 传统的网站部署,大家在运维过程中,网站部署是运维的工作之一,网站部署的流程大致分为: 需求分析—原型设计—开发代码—提交测试—内网部署—确认上线—备份数据—外网更新-最终测试,如果发现外网部署的代码有异常,需要及时回滚…

[附源码]JAVA毕业设计心理健康系统(系统+LW)

[附源码]JAVA毕业设计心理健康系统&#xff08;系统LW&#xff09; 项目运行 环境项配置&#xff1a; Jdk1.8 Tomcat8.5 Mysql HBuilderX&#xff08;Webstorm也行&#xff09; Eclispe&#xff08;IntelliJ IDEA,Eclispe,MyEclispe,Sts都支持&#xff09;。 项目技术&…

网络安全观察报告恶意软件观察

攻击类型分析 2018 年&#xff0c;主要的攻击类型 1 为 SYN Flood&#xff0c;UDP Flood&#xff0c;ACK Flood&#xff0c;HTTP Flood&#xff0c;HTTPS Flood&#xff0c; 这五大类攻击占了总攻击次数的 96&#xff05;&#xff0c;反射类攻击不足 3%。和 2017 年相比&…

使用分页导入的方式把大量数据从mysql导入es

1、首先要有分页功能的代码 如何使用mybatis-plus实现分页&#xff0c;可参考 http://t.csdn.cn/ddnlk 2、要创建feign远程调用模块 可以参考 http://t.csdn.cn/gshFw 3、在feign模块中声明远程调用接口 1.在feign模块中创建一个接口&#xff0c;名字可以是你要调用的服务名&…

指定区域内实现多尺度、多维度2D图形随机填充(如圆、椭圆、多边形)之MATLAB实现

N久之前&#xff0c;咱在公众号中分享了如何用MATLAB实现在指定区域内随机填充圆&#xff0c;并将相关功能封装一个名为randCircle函数里面&#xff0c;其可实现的功能如下&#xff1a; (1) 设定是否允许填充圆相交、相切或独立存在 (2) 指定区域内圆的生成个数 (3) 设定是否允…

[附源码]计算机毕业设计基于vuejs的文创产品销售平台appSpringboot程序

项目运行 环境配置&#xff1a; Jdk1.8 Tomcat7.0 Mysql HBuilderX&#xff08;Webstorm也行&#xff09; Eclispe&#xff08;IntelliJ IDEA,Eclispe,MyEclispe,Sts都支持&#xff09;。 项目技术&#xff1a; SSM mybatis Maven Vue 等等组成&#xff0c;B/S模式 M…

【面试题】说说 Promise是什么?如何使用

大厂面试题分享 面试题库 前端面试题库 &#xff08;面试必备&#xff09; 推荐&#xff1a;★★★★★ 地址&#xff1a;前端面试题库 前言 本文主要介绍和总结Promise的作用、使用方式和其对应的一些方法,供大家参考学习&#xff0c;如有写的不准确的地方欢迎大家指出&a…

Android 使用 jni Demo示例

Android 使用 jni Demo示例简介1. NDK的介绍1.1 NDK 简介1.2 NDK 特点2. JNI介绍2.1 JNI 简介2.2 为什么要有 JNI&#xff1f;3. NDK 与 JNI 的关系NDK下载及环境配置1. 使用Android studio SDK Manager下载2.配置NDK2.1 配置环境变量2.2 Android studio配置NDK示例Demo流程1.版…

RabbitMQ - 安装和使用

RabbitMQ - 安装和使用一. 安装二. RabbitMQ的简单使用2.1 创建交换机2.1.1 交换机类型2.1.2 持久化方式2.2 创建队列2.3 绑定交换机和队列2.4 SpringBoot整合2.5 另外一种监听写法一. 安装 一键安装&#xff1a; docker run -d --name rabbitmq -p 5671:5671 -p 5672:5672 …

rtl8221b+mcu,2.5g光纤收发器的开发备份

1、rtl8221b是一款2.5g的光电转换的phy 系统的构建如下 为了省成本&#xff0c;不用mac来对接其中的gmii接口直接接光模块 2、mdio和mdc由mcu的gpio来模拟&#xff0c;在csdn上有很多的文章来参考 mdio的参数如下 不想看英文可以参考下面的文章 MDIO(clause 22 与 clause 4…

Java基础之《netty(10)—Reactor三种模式》

一、单Reactor单线程模式 1、工作原理图 2、方案说明 &#xff08;1&#xff09;Select是前面I/O复用模型介绍的标准网络编程API&#xff0c;可以实现应用程序通过一个阻塞对象监听多路连接请求。 &#xff08;2&#xff09;Reactor对象通过Select监控客户端请求事件&#xf…