5.22-wjn

使用select实现的TCP并发服务器端

#define SER_PORT 8888
#define SER_IP "192.168.125.158"
int main(int argc, const char *argv[])
{
    //1、为通信创建一个端点
    int sfd = socket(AF_INET, SOCK_STREAM, 0);
    //参数1：说明使用的是ipv4通信域
    //参数2：说明使用的是TCP面向连接的通信方式
    //参数3：由于参数2中已经指定通信方式，填0即可
    if(sfd == -1)
    {
        perror("socket error");
        return -1;
    }
    printf("socket success sfd = %d\n", sfd);   //3

    //3\、设置地址能够快速重用
    int reuse = 1;
    if(setsockopt(sfd, SOL_SOCKET, SO_REUSEADDR, &reuse, sizeof(reuse))==-1)
    {
        perror("setsockopt error");
        return -1;
    }

    //2、绑定ip和端口号
    //2.1 准备地址信息结构体
    struct sockaddr_in sin;
    sin.sin_family = AF_INET;    //通信域
    sin.sin_port = htons(SER_PORT);    //端口号
    sin.sin_addr.s_addr = inet_addr(SER_IP);  //ip地址

    //2.2 绑定工作
    if(bind(sfd, (struct sockaddr*)&sin, sizeof(sin)) ==-1)
    {
        perror("bind error");
        return -1;
    }
    printf("bind success\n");

    //3、将套接字设置成被动监听状态
    if(listen(sfd, 128)==-1)
    {
        perror("listen error");
        return -1;
    }
    printf("listen success\n");
                                                                                                             
    //4、阻塞等待客户端的连接
    //4.1 定义用于接受客户端信息的容器
    struct sockaddr_in cin;
    socklen_t addrlen = sizeof(cin);

    //11、准备检测文件描述符的集合
    fd_set readfds, tempfds;

    //22、清空集合中的内容
    FD_ZERO(&readfds);

    //33、将要检测的文件描述符放入集合中
    FD_SET(sfd, &readfds);
    FD_SET(0, &readfds);

    int newfd = 0;            //存放客户端套接字变量
    int maxfd = sfd;         //存放容器中最大的文件描述符

    struct sockaddr_in cin_arr[1024];     //存储客户端地址信息结构体的容器


    while(1){

        //执行阻塞函数之前将文件描述符集合备份一份
        tempfds = readfds;

        //使用阻塞函数，检测文件描述符集合中是否有事件产生
        int res = select(maxfd+1, &tempfds, NULL, NULL, NULL);
        if(res == -1){
            perror("select error");
            return -1;
        }
        else if(res == 0){
            printf("time out\n");
            return -1;
        }

        //当程序执行至此，表示检测容器中已经有一个或多个事件产生
        //只需要判断哪些文件描述符还在集合中，就一定产生了事件，直接取执行相关逻辑即可
        //将所有的文件描述符全部遍历一遍        
        for(int i=0; i<=maxfd; i++){

            //判断当前的i文件描述符是否没有触发事件
            if(!FD_ISSET(i, &tempfds)){
                continue;
            }

            //如果程序执行至此，说明当前的 i
            //触发了事件，要判断该i是什么文件描述符

            //判断sfd是否触发了相关事件
            if(i == sfd){
                newfd = accept(i, (struct sockaddr*)&cin, &addrlen);
                if(newfd == -1){
                    perror("accept error");
                    return -1;
                }

            printf("[%s:%d]:发来连接请求\n", inet_ntoa(cin.sin_addr), ntohs(cin.sin_port));

            //将newfd放入到 readfds容器中，以便于检测是否有客户端发来数据
            FD_SET(newfd, &readfds);
            //更新maxfd
            if(newfd >= maxfd){

                maxfd = newfd;
            }

            //将套接字地址信息结构体放入数组中
            cin_arr[newfd] = cin;

        }
        else if(i == 0){                 //判断是否是0号文件描述符解除的阻塞

            char buf[128] = "";
            fgets(buf, sizeof(buf), stdin);
            buf[strlen(buf)-1] = 0;
            printf("键盘输入事件完成：%s\n", buf);

            //循环将消息发送给所有客户端
            for(int k=4; k<=maxfd; k++){

                send(k, buf, strlen(buf), 0);
            }

        }
        else{
            //5、与客户端进行相互通信
            char rbuf[128] = "";            //读取消息内容的容器

            //清空容器
            bzero(rbuf, sizeof(rbuf));

            //从套接字中读取数据
            //int res = read(newfd, rbuf, sizeof(rbuf));=
            int res = recv(i, rbuf, sizeof(rbuf), 0);
            if(res == 0){

                printf("客户端已经下线\n");
                //6、关闭套接字
                close(i);

                //将当前的套接字文件描述符从容器中移除
                FD_CLR(i, &readfds);
                //更新maxfd
                for(int j=maxfd; j>=sfd; j--){

                    if(FD_ISSET(j, &readfds)){

                        maxfd = j;
                        break;
                    }
                }

                continue;
             }

           //将读取的消息展示出来
           printf("[%s:%d]:%s\n", inet_ntoa(cin_arr[i].sin_addr), ntohs(cin_arr[i].sin_port), rbuf);

            //将消息转发给所有客户端
            for(int k=4; k<=maxfd; k++){
                 if(k != i){          //不转发给自己
                    send(k, rbuf, strlen(rbuf), 0);
                }
            }
        }
    }

}
    close(sfd);

使用poll实现TCP客户端中发送数据和接收数据的并发执行

#define SER_PORT 8888
#define SER_IP "192.168.125.158"
#define CLI_PORT 6666
#define CLI_IP "192.168.125.158"

int main(int argc, const char *argv[])
{
    //1、创建用于通信的套接字文件描述符
    int cfd = socket(AF_INET, SOCK_STREAM, 0);
    if(cfd == -1)
    {
        perror("socket error");
        return -1;
    }
    printf("cfd = %d\n", cfd);            //3
    
    //2、绑定IP地址和端口号 ?
    //2.1 填充客户端地址信息结构体
    struct sockaddr_in cin;
    cin.sin_family = AF_INET;
    cin.sin_port = htons(CLI_PORT);
    cin.sin_addr.s_addr = inet_addr(CLI_IP);
    //2.2 绑定
    if( bind(cfd, (struct sockaddr*)&cin, sizeof(cin)) ==-1)
    {
        perror("bind error");
        return -1;
    }
    printf("bind success\n");
    
    
    //3、连接服务器
    //3.1 准备对端地址信息结构体
    struct sockaddr_in sin;
    sin.sin_family = AF_INET;
    sin.sin_port = htons(SER_PORT);
    sin.sin_addr.s_addr = inet_addr(SER_IP);
    //3.2 连接服务器
    if(connect(cfd, (struct sockaddr*)&sin, sizeof(sin))==-1)
    {
        perror("connect error");
        return -1;
    }
    printf("connect success\n");

    //使用poll完成多个阻塞任务的并发执行
    struct pollfd pfd[2];
    pfd[0].fd = 0;       //表示检测0好文件描述符
    pfd[0].events = POLLIN;   //表示检测读事件

    pfd[1].fd = cfd;        //表示检测cfd文件描述符
    pfd[1].events = POLLIN;   //表示检测读事件

    
    //4、数据收发
    char wbuf[128] = "";
    char rbuf[128] = "";
    while(1)
    {
        int res = poll(pfd, 2, -1);
        if(res == -1)
        {
            perror("poll error");
            return -1;
        }else if(res == 0)
        {
            printf("time out\n");
            return -1;
        }
        //当程序执行至此，说明检测容器中有事件产生

        //判断是否为0号文件描述符产生的事件
        if(pfd[0].revents == POLLIN)
        {

            //从终端上获取要发送的数据
            fgets(wbuf, sizeof(wbuf), stdin);
            wbuf[strlen(wbuf)-1] = '\0';           //将读取的换行改成'\0'

            //将数据发送给服务器
            send(cfd, wbuf, strlen(wbuf), 0);
            printf("发送成功\n");
        }

        //判断是否为cfd文件描述符产生事件
        if(pfd[1].revents == POLLIN)
        {
            //接收服务器发来的消息
            bzero(rbuf, sizeof(rbuf));

            recv(cfd, rbuf, sizeof(rbuf), 0);
            printf("服务器发来的消息为：%s\n", rbuf);
        }
    }

    //5、关闭套接字
    close(cfd);

    return 0;
}

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

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

相关文章

SpringBoot Bean

SpringBoot Bean

配置优先级 Bean的管理 从IOC容器中获取Bean对象&#xff1a;注入IOC容器对象 bean的作用域 Bean对象默认在容器启动时实例化 Lazy在第一次使用时初始化 Bean的管理&#xff1a;第三方Bean 引入依赖&#xff0c;每次解析创建新对象&#xff0c;浪费资源 将第三方对象交给…
阅读更多...
vr商品全景展示场景编辑软件的优点

vr商品全景展示场景编辑软件的优点

3D模型展示网站搭建编辑器以强大的3D编辑引擎和逼真的渲染效果&#xff0c;让您轻松实现模型展示的优化。让用户通过简单的操作&#xff0c;就能满足个人/设计师/商户多样化展示的需求&#xff0c;让您的模型成为独一无二的杰作。 3D模型展示网站搭建编辑器采用国内领先的实时互…
阅读更多...
软件设计师中级

软件设计师中级

计算机系统 运算器和控制器 算术逻辑单元 累加寄存器器 状态寄存器 数据缓冲寄存器 指令寄存器 程序计数器 地址寄存器 指令译码器 内存按字节编址 内存存储单元16位 1 浮点数 浮点数范围&#xff1a;-2的(2的阶码次)-1到-2的(2的阶码次)-1 乘 1-2负尾数次 海明码 海明码&…
阅读更多...
力扣HOT100 - 136. 只出现一次的数字

力扣HOT100 - 136. 只出现一次的数字

解题思路&#xff1a; class Solution {public int singleNumber(int[] nums) {int single 0;for (int num : nums) {single ^ num;}return single;} }
阅读更多...
Java基础的语法---StringBuilder

Java基础的语法---StringBuilder

StringBuilder 构造方法 StringBuilder()&#xff1a;创建一个空的StringBuilder实例。 StringBuilder(String str)&#xff1a;创建一个StringBuilder实例&#xff0c;并将其初始化为指定的字符串内容。 StringBuilder(int a): 创建一个StringBuilder实例…
阅读更多...
AWTK实现汽车仪表Cluster/DashBoard嵌入式GUI开发（七）：快启

AWTK实现汽车仪表Cluster/DashBoard嵌入式GUI开发（七）：快启

前言： 汽车仪表是人们了解汽车状况的窗口，而仪表中的大部分信息都是以指示灯形式显示给驾驶者。仪表指示灯图案都较为抽象，对驾驶不熟悉的人在理解仪表指示灯含义方面存在不同程度的困难，尤其对于驾驶新手，如果对指示灯的含义不求甚解，有可能影响驾驶的安全性。即使是对…
阅读更多...
Leetcode刷题笔记3：链表基础1

Leetcode刷题笔记3：链表基础1

导语 leetcode刷题笔记记录&#xff0c;本篇博客记录链表基础1部分的题目&#xff0c;主要题目包括&#xff1a; 203.移除链表元素707.设计链表206.反转链表 知识点 链表 链表是一种通过指针串联在一起的线性结构&#xff0c;每一个节点由两部分组成&#xff0c;一个是数据…
阅读更多...
企业如何防止数据泄密？大型企业必备的文件加密软件

企业如何防止数据泄密？大型企业必备的文件加密软件

随着信息化建设的大步推进&#xff0c;越来越多的企业资料以电子文件的形式保存&#xff0c;企业内部和企业之间的信息交流也主要依靠电子文件。近年来的泄密事件层出不穷&#xff0c;比如东软泄密案、HTC窃密案、力拓案等&#xff0c;给企业带来灾难性的经济损失及信誉重创。如…
阅读更多...
CentOS7安装内网穿透实现远程推送镜像到本地Docker Registry

CentOS7安装内网穿透实现远程推送镜像到本地Docker Registry

文章目录 前言1. 部署Docker Registry2. 本地测试推送镜像3. Linux 安装cpolar4. 配置Docker Registry公网访问地址5. 公网远程推送Docker Registry6. 固定Docker Registry公网地址 前言 本文主要介绍如何部署Docker Registry 本地镜像仓库,简单几步结合cpolar内网穿透工具实现…
阅读更多...
使用控制台方式部署sentinel

使用控制台方式部署sentinel

1.下载控制台jar包 2.运行jar包 java -jar sentinel-dashboard-1.8.0.jar 也可以通过编写批处理文件指定端口、用户名、密码&#xff1a; 客户端添加依赖&#xff08;后续整合springcloudalibaba时不需要此依赖&#xff09; 如修改了sentinel端口&#xff0c;需要添加客户端运…
阅读更多...
ubuntu下载离线软件包及依赖

ubuntu下载离线软件包及依赖

目录 一、前言 二、正文 1.准备环境 2.开始下载 3.后续工作 三、总结 一、前言 由于给客户提供的设备机不允许上网&#xff0c;那么所有待安装的软件包及依赖库都需要提前下载好&#xff0c;然后通过局域网传过去再安装。 另外&#xff0c;软件包可能还依赖其他的库&…
阅读更多...
【Pytorch】【MacOS】14.m1芯片使用mps进行深度模型训练

【Pytorch】【MacOS】14.m1芯片使用mps进行深度模型训练

读者要先自行安装python以及anaconda&#xff0c;并且配置pytorch环境 第一步 测试环境 import torch # 判断macOS的版本是否支持 print(torch.backends.mps.is_available()) # 判断mps是否可用 print(torch.backends.mps.is_built())如果第一个语句为False&#xff0c;说明当前…
阅读更多...
自定义一个SpringBoot场景启动器

自定义一个SpringBoot场景启动器

前言 一个刚刚看完SpringBoot自动装配原理的萌新依据自己的理解写下的文章&#xff0c;如有大神发现错误&#xff0c;敬请斧正&#xff0c;不胜感激。 分析SpringBoot自动配置原理 SpringBoot的启动从被SpringBootApplication修饰的启动类开始,SpringBootApplicaiotn注解中最…
阅读更多...
浅谈后端boot框架整合第三方技术JUnit MyBatis Druid整体思想

浅谈后端boot框架整合第三方技术JUnit MyBatis Druid整体思想

整合第三方技术 不要单单学习指定技术与springboot整合的方式 学习目标的是整合整体的技术的思路 拿到任何一个第三方技术后我们在springboot中如何操作 这是真正我们应该学习的东西 以后能整合任意技术 整合JUnit JUnit 是一个流行的开源测试框架&#xff0c;用于 Java …
阅读更多...
Redis优化笔记

Redis优化笔记

Redis优化 一&#xff1a;Key&#xff1a; 1.1.Key的规范&#xff1a; 测试如下&#xff1a; 1.2.拒绝BigKey&#xff1a; 我们可以用&#xff1a; MEMORY USAGE name命令来看它的大小。 注意&#xff0c;这里的第二种之所以不使用Keys *&#xff0c;因为在实际生产时&#…
阅读更多...
NDIS小端口驱动开发(一)

NDIS小端口驱动开发(一)

在四种NDIS相关的驱动中&#xff0c;微型端口驱动(也经常翻译为为小端口驱动)位于驱动栈的底部&#xff0c;一般将它理解为NIC设备的驱动程序&#xff1a; 有几种类型的微型端口驱动程序类型&#xff1a; 无连接微型端口驱动程序用于控制无连接网络媒体 &#xff0c;如以太网的…
阅读更多...
SpringBoot接入Knife4j接口文档

SpringBoot接入Knife4j接口文档

0.介绍 1&#xff09; Knife4j是什么 Knife4j是Java MVC框架集成Swagger生成Api文档的增强解决方案&#xff0c;前身是swagger-bootstrap-ui&#xff0c;有着比Swagger更为美观的UI以及功能。 例如以下效果图&#xff1a; 2&#xff09; 官方链接 官网&#xff1a;Knife4j …
阅读更多...
FastSAM 部署 rknn

FastSAM 部署 rknn

基于yolov8(ultralytics)工程导出的FastSAM的onnx模型&#xff0c;后处理和yolov8seg是一样的。      模型和完整测试代码。 1 FastSAM 导出 onnx 导出onnx的方式有两种&#xff0c;一种使用FastSAM工程&#xff0c;一种是使用yolov8(ultralytics)工程。本篇博客使用yolov…
阅读更多...
2024年【N1叉车司机】免费试题及N1叉车司机模拟试题

2024年【N1叉车司机】免费试题及N1叉车司机模拟试题

题库来源&#xff1a;安全生产模拟考试一点通公众号小程序 N1叉车司机免费试题考前必练&#xff01;安全生产模拟考试一点通每个月更新N1叉车司机模拟试题题目及答案&#xff01;多做几遍&#xff0c;其实通过N1叉车司机模拟考试题库很简单。 1、【多选题】《中华人民共和国特…
阅读更多...
3款录屏录制软件，打造专业级视频内容

3款录屏录制软件，打造专业级视频内容

随着技术的不断发展&#xff0c;人们在日常工作和学习中经常会遇到记录电脑屏幕的需求&#xff0c;例如录制游戏过程、制作教程、保存会议记录等。为了解决这一需求&#xff0c;许多录屏录制软件应运而生。本文将介绍三款常见的录屏录制软件&#xff0c;通过分析它们的特点和使…
阅读更多...
最新文章

Copyright @ 2022~2023