常见的socket函数封装和多进程和多线程实现服务器并发

常见的socket函数封装和多进程和多线程实现服务器并发

  • 1.常见的socket函数封装
  • 2.多进程和多线程实现服务器的并发
    • 2.1多进程服务器
    • 2.2多线程服务器
    • 2.3运行效果

1.常见的socket函数封装

在这里插入图片描述

accept函数或者read函数是阻塞函数，会被信号打断，我们不能让它停止，所以我们应该进行一些封装操作。

//wrap.h#ifndef __WRAP_H_
#define __WRAP_H_
#include <stdlib.h>
#include <stdio.h>
#include <unistd.h>
#include <errno.h>
#include <string.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <strings.h>void perr_exit(const char *s);
int Accept(int fd, struct sockaddr *sa, socklen_t *salenptr);
int Bind(int fd, const struct sockaddr *sa, socklen_t salen);
int Connect(int fd, const struct sockaddr *sa, socklen_t salen);
int Listen(int fd, int backlog);
int Socket(int family, int type, int protocol);
ssize_t Read(int fd, void *ptr, size_t nbytes);
ssize_t Write(int fd, const void *ptr, size_t nbytes);
int Close(int fd);
ssize_t Readn(int fd, void *vptr, size_t n);
ssize_t Writen(int fd, const void *vptr, size_t n);
ssize_t my_read(int fd, char *ptr);
ssize_t Readline(int fd, void *vptr, size_t maxlen);
int tcp4bind(short port,const char *IP);
#endif

下面是相关函数的实现

//wrap.c#include <stdlib.h>
#include <stdio.h>
#include <unistd.h>
#include <errno.h>
#include <string.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <strings.h>void perr_exit(const char *s)
{perror(s);exit(-1);
}int Accept(int fd, struct sockaddr *sa, socklen_t *salenptr)
{int n;again:if ((n = accept(fd, sa, salenptr)) < 0) {if ((errno == ECONNABORTED) || (errno == EINTR))goto again;elseperr_exit("accept error");     }return n;
}int Bind(int fd, const struct sockaddr *sa, socklen_t salen)
{int n;if ((n = bind(fd, sa, salen)) < 0)perr_exit("bind error");return n;
}int Connect(int fd, const struct sockaddr *sa, socklen_t salen)
{int n;if ((n = connect(fd, sa, salen)) < 0)perr_exit("connect error");return n;
}int Listen(int fd, int backlog)
{int n;if ((n = listen(fd, backlog)) < 0)perr_exit("listen error");return n;
}int Socket(int family, int type, int protocol)
{int n;if ((n = socket(family, type, protocol)) < 0)perr_exit("socket error");return n;
}ssize_t Read(int fd, void *ptr, size_t nbytes)
{ssize_t n;again:if ( (n = read(fd, ptr, nbytes)) == -1) {if (errno == EINTR)goto again;elsereturn -1;}return n;
}ssize_t Write(int fd, const void *ptr, size_t nbytes)
{ssize_t n;again:if ( (n = write(fd, ptr, nbytes)) == -1) {if (errno == EINTR)goto again;elsereturn -1;}return n;
}int Close(int fd)
{int n;if ((n = close(fd)) == -1)perr_exit("close error");return n;
}

2.多进程和多线程实现服务器的并发

当有多个客户端向服务器发送数据的时候，我们如何去操作，这就涉及到了我们的多线程和多进程开发了，下面看看如何来实现。

2.1多进程服务器

(1)首先我们想如何通过多进程来实现呢？那么我们得想清楚父子进程分别来干啥，我们可以这样，父进程来获取连接。

(2)然后子进程来进行通信发送数据给服务端。

(3)最后我们利用信号的方式来回收子进程，防止出现僵尸进程。

/*多进程实现并发，主进程中使用sigaction函数回收子进程*/
#include <signal.h>
#include <sys/wait.h>
#include <sys/types.h>
#include <unistd.h>
#include "wrap.h"void sighandler(int sig)
{pid_t wpid;//回收子进程while(1){wpid = waitpid(-1, NULL, WNOHANG);if(wpid <= 0){break;}}
}int main()
{int lfd = Socket(AF_INET, SOCK_STREAM, 0);//设置端口复用int opt = 1;setsockopt(lfd, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(int));struct sockaddr_in serverAddr;bzero(&serverAddr, sizeof(serverAddr));serverAddr.sin_family = AF_INET;serverAddr.sin_port = htons(8888);serverAddr.sin_addr.s_addr = htonl(INADDR_ANY);Bind(lfd, (struct sockaddr*)&serverAddr, sizeof(serverAddr));Listen(lfd, 128);//将SIGCHLD信号阻塞sigset_t mask;sigemptyset(&mask);sigaddset(&mask, SIGCHLD);sigprocmask(SIG_BLOCK, &mask, NULL);int cfd;pid_t mpid;struct sockaddr_in clientAddr;socklen_t len = sizeof(clientAddr);while(1){cfd = Accept(lfd, (struct sockaddr*)&clientAddr, &len);mpid = fork();if (mpid < 0){perror("fork error:");exit(0);}else if (mpid > 0){close(cfd);//signal(SIGCHLD, sighandler);//注册信号处理函数struct sigaction act;act.sa_handler = sighandler;sigemptyset(&act.sa_mask);act.sa_flags = 0;sigaction(SIGCHLD, &act, NULL);//解除对SIGCHLD信号的阻塞sigprocmask(SIG_UNBLOCK, &mask, NULL);}else if(mpid == 0){//子进程中执行消息收发close(lfd);char buf[1024];int nLen; char cIP[16];while(1){memset(buf, 0, sizeof(buf));nLen = Read(cfd, buf, sizeof(buf));if (nLen <= 0){perror("read error:");break;}printf("%s--%d: %s\n", inet_ntop(AF_INET, &clientAddr.sin_addr.s_addr, cIP, sizeof(cIP)), ntohs(clientAddr.sin_port), buf);strcat(buf, "---recvied");Write(cfd, buf, strlen(buf));}close(cfd);exit(0);  //子进程退出，防止子进程继续创建子进程}}close(lfd);return 0;
}

2.2多线程服务器

接下来就是多线程服务器如何去实现呢？

我们可以参考上面的多进程开发:
(1)首先我们利用主进程来获取连接。

(2)然后利用子线程来和服务器进行通信给服务器发送数据。

(3)最后设置线程分离属性，任务完成后自动回收子线程。

注意：

(1)线程和进程之间是有不同的，线程的文件描述符时共享的，一旦有一个新的连接过来的时候，所有的通信文件描述符cfd都会改变，但是进程时写时拷贝的，所以进程不会出现这种情况。因此在使用线程开发时，我们要分别给他们开辟空间，这里可以用一个结构体，不同线程使用不同的空间。

(2)由于线程的文件描述符是共享的，所以我们不可以关闭父线程的通信文件描述符，这样会导致子线程的通信文件描述符全关闭，导致子线程无法正常通信；而进程程会有计数引用，只会是通信文件描述符的引用次数减1，不会直接全部关闭。

下面是代码：

/*多线程实现并发， 解决多个子线程共享cfd存在的问题*/
#include "wrap.h"
#include <pthread.h>#define MAX_NUM 100struct PthreadInfo
{int cfd;  //若为-1表示可用, 大于0表示已被占用pthread_t threadID;struct sockaddr_in clientAddr;
};
//定义结构体数组，不同的线程访问不同的内存
struct PthreadInfo info[MAX_NUM];//线程执行函数
void* mythread(void* arg)
{struct PthreadInfo* p = (struct PthreadInfo*)arg;char buf[1024];int cfd = p->cfd;ssize_t len;while (1){memset(buf, 0, sizeof(buf));len = Read(cfd, buf, sizeof(buf));if (len <= 0){perror("read error:");close(cfd);p->cfd = -1;  //设置为-1表示该位置可用pthread_exit(NULL);}printf("%s\n", buf);strcat(buf, "---recvied");Write(cfd, buf, strlen(buf));}}void init_info()
{//初始化数组，当cfd = -1时表明这块内存空间可以使用for (size_t i = 0; i < MAX_NUM; i++){info[i].cfd = -1;}
}int find_index()
{int i;for(i = 0; i < MAX_NUM; i++){if (info[i].cfd == -1){break;}}if (i == MAX_NUM){return -1;}return i;
}int main()
{int lfd = Socket(AF_INET, SOCK_STREAM, 0);//设置端口复用int opt = 1;setsockopt(lfd, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(int));struct sockaddr_in serverAddr;bzero(&serverAddr, sizeof(serverAddr));serverAddr.sin_family = AF_INET;serverAddr.sin_port = htons(8888);serverAddr.sin_addr.s_addr = htonl(INADDR_ANY);Bind(lfd, (struct sockaddr*)&serverAddr, sizeof(serverAddr));Listen(lfd, 128);//初始化init_info();int cfd;int ret;int idx;socklen_t len;struct sockaddr_in client;while (1){len = sizeof(client);bzero(&client, len);cfd = Accept(lfd, (struct sockaddr*)&client, &len);//找数组中空闲的位置idx = find_index();if (idx == -1){close(cfd);continue;}//对空闲位置的元素的成员赋值info[idx].cfd = cfd;memset(&info[idx].clientAddr, &client, len);//创建子线程---该子线程完成对数据的收发ret = pthread_create(&info[idx].threadID, NULL, mythread, &info[idx]);if(ret!=0){printf("create thread error:[%s]\n", strerror(ret));exit(-1);}//设置子线程为分离属性pthread_detach(info[idx].threadID);}close(lfd);return 0;
}

我们在写的时候发现当一些进程完成通信以后，关闭文件描述符，我们的空间是无法进行回收的，这样就会大大浪费空间，因此我们可以写一个函数来返回结束通信的空间位置可利用的空间，来使用这块空间。

int find_index()
{int i;for(i = 0; i < MAX_NUM; i++){if (info[i].cfd == -1){break;}}if (i == MAX_NUM){return -1;}return i;
}

2.3运行效果

下面我们看看效果

1.这是连接的第一个客户端，可以看到通信正常
在这里插入图片描述
2.这是连接的第二个客户端，通信也正常

在这里插入图片描述3.我们用命令来看看连接的状态

在这里插入图片描述
可以看到tcp连接是一个双向的可靠连接，我们连接了两个客户端，所以有四个连接，可以看到都处于ESTABLISHESD的状态，可以看出是达到了效果。两个客户端和服务端的通信都是正常的。

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

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

相关文章

哪里申请EV代码签名证书？

哪里申请EV代码签名证书？

EV代码签名证书是一种高级别的数字证书&#xff0c;它通过严格的验证流程&#xff0c;确保软件发布者身份的真实性和可信度。相较于普通代码签名证书&#xff0c;EV证书采用了更严格的验证标准&#xff0c;包括对企业身份、法律地位、组织结构多个方面的核实。这使得EV证书成为…
阅读更多...
06 Qt自绘组件：Switch动画开关组件

06 Qt自绘组件：Switch动画开关组件

系列文章目录 01 Qt自定义风格控件的基本原则-CSDN博客 02 从QLabel聊起&#xff1a;自定义控件扩展-图片控件-CSDN博客 03 从QLabel聊起&#xff1a;自定义控件扩展-文本控件-CSDN博客 04 自定义Button组件&#xff1a;令人抓狂的QToolButton文本图标居中问题-CSDN博客 0…
阅读更多...
js中的任务处理机制

js中的任务处理机制

众所周知(不知道的话去查)&#xff0c;js是以单线程的方式执行的&#xff0c;在执行的过程中&#xff0c;某一时刻上只能执行一个任务&#xff0c;也就是说&#xff0c;我们写好了代码后执行的时候&#xff0c;程序是根据代码从上到下依次排队执行&#xff0c;只有上一个任务执…
阅读更多...
数据分析案例-社交媒体情绪数据集可视化分析（文末送书）

数据分析案例-社交媒体情绪数据集可视化分析（文末送书）

&#x1f935;‍♂️ 个人主页&#xff1a;艾派森的个人主页 ✍&#x1f3fb;作者简介&#xff1a;Python学习者 &#x1f40b; 希望大家多多支持&#xff0c;我们一起进步&#xff01;&#x1f604; 如果文章对你有帮助的话&#xff0c; 欢迎评论 &#x1f4ac;点赞&#x1f4…
阅读更多...
进程的控制

进程的控制

文章目录 进程退出进程等待进程程序替换 正文开始前给大家推荐个网站&#xff0c;前些天发现了一个巨牛的 人工智能学习网站&#xff0c; 通俗易懂&#xff0c;风趣幽默&#xff0c;忍不住分享一下给大家。 点击跳转到网站。 进程退出 进程的退出一共有三种场景。 程序跑完…
阅读更多...
别再让机会从指缝间溜走！社科院与杜兰大学金融管理硕士一同开创你的成功之路

别再让机会从指缝间溜走！社科院与杜兰大学金融管理硕士一同开创你的成功之路

新的一年&#xff0c;你的读研计划进行到哪个环节了呢&#xff1f;咨询社科院与杜兰大学金融管理硕士项目中&#xff0c;总听到有同学说&#xff0c;不着急&#xff0c;我先了解一下。你不知道是时间总是在指缝间溜走。别让犹豫成了我们前进的阻碍&#xff0c;马上行动早日遇到…
阅读更多...
基于Springboot的计算机知识竞赛网站（有报告）。Javaee项目，springboot项目。

基于Springboot的计算机知识竞赛网站（有报告）。Javaee项目，springboot项目。

演示视频&#xff1a; 基于Springboot的计算机知识竞赛网站&#xff08;有报告&#xff09;。Javaee项目&#xff0c;springboot项目。 项目介绍&#xff1a; 采用M&#xff08;model&#xff09;V&#xff08;view&#xff09;C&#xff08;controller&#xff09;三层体系结…
阅读更多...
产品老化试验目的、用途

产品老化试验目的、用途

什么是老化试验&#xff1f; 老化试验是通过模拟产品在使用过程中的老化情况&#xff0c;来评估产品在长期使用后的性能和可靠性。这种测试可以帮助制造商了解产品的寿命和耐久性&#xff0c;以及产品在不同环境条件下的表现。 模拟量采集/老化房采集软件 为什么需要进行老化试…
阅读更多...
智慧公厕：让城市更智慧、更环保

智慧公厕：让城市更智慧、更环保

在现代社会&#xff0c;智慧公厕作为城市管理的重要一环&#xff0c;是智慧城市的重要组成部分&#xff0c;其建设的价值十出突出&#xff0c;是公共厕所信息化升级改造的核心方案。如智慧公厕源头厂家广州中期科技有限公司&#xff0c;所自主研发的智慧公厕整体解决方案&#…
阅读更多...
【HarmonyOS】鸿蒙开发之Video组件——第3.7章

【HarmonyOS】鸿蒙开发之Video组件——第3.7章

Video组件内VideoOptions属性简介 src&#xff1a;设置视频地址。currentProgressRate&#xff1a;设置视频播放倍速&#xff0c;参数说明如下&#xff1a; number|string&#xff1a;只支持 0.75 &#xff0c; 1.0 &#xff0c; 1.25 &#xff0c; 1.75 &#xff0c; 2.0 。P…
阅读更多...
安装 docker 可视化工具 portainer

安装 docker 可视化工具 portainer

portainer 官方网站 https://www.portainer.io/ 一、portainer 介绍 Portainer是一款开源的容器管理平台&#xff0c;它提供了一个直观易用的Web界面&#xff0c;帮助用户管理Docker容器集群、镜像、卷等资源。Portainer 支持多种 Docker 环境&#xff0c;包括本地Docker、Sw…
阅读更多...
智能手表的革命性突破：TRIZ理论引领未来穿戴技术！

智能手表的革命性突破：TRIZ理论引领未来穿戴技术！

在科技日新月异的今天&#xff0c;智能手表已经从单纯的计时工具转变为集健康监测、信息通讯、娱乐休闲等多功能于一体的智能穿戴设备。而基于TRIZ理论的智能手表更是在这一变革中扮演着引领者的角色。TRIZ&#xff0c;即发明问题解决理论&#xff0c;是一套系统的创新方法学&a…
阅读更多...
使用vue把一周的时间划分为可以选择多个阶段

使用vue把一周的时间划分为可以选择多个阶段

提示：使用vue把一周的时间划分为可以选择多个阶段段（亲测有效） 一、直接复制以下代码 代码如下（示例）： <template><div class="byted-weektime" @mousedown="dian" @mousemove="yi" @mouseup="li"><div class=&q…
阅读更多...
【iOS ARKit】协作Session

【iOS ARKit】协作Session

使用 ARWorldMap&#xff0c;能解决使用者再次进入同一物理空间时的AR 场景恢复问题&#xff0c;也能在多人之间共桌AR 体验&#xff0c;但这种共享并不是实时的&#xff0c;在载入ARWorldMap 后&#xff0c;设备新检测到的环境信息和使用者所做操作不会实时共享&#xff0c;即…
阅读更多...
【MATLAB】 小波分解信号分解+FFT傅里叶频谱变换组合算法

【MATLAB】 小波分解信号分解+FFT傅里叶频谱变换组合算法

有意向获取代码&#xff0c;请转文末观看代码获取方式~ 展示出图效果 1 小波分解算法 小波分解算法是一种数学方法&#xff0c;用于将信号分解为不同频率的小波成分。这种算法基于小波函数&#xff0c;可以用于信号处理、图像压缩和数据压缩等领域。小波分解算法的基本思想是…
阅读更多...
LeetCode59. 螺旋矩阵 II(C++)

LeetCode59. 螺旋矩阵 II(C++)

LeetCode59. 螺旋矩阵 II 题目链接代码 题目链接 https://leetcode.cn/problems/spiral-matrix-ii/ 代码 class Solution { public:vector<vector<int>> generateMatrix(int n) {vector<vector<int>> res(n, vector<int>(n, 0));int startx …
阅读更多...
数据结构：栈和队列与栈实现队列（C语言版）

数据结构：栈和队列与栈实现队列（C语言版）

目录 前言 1.栈 1.1 栈的概念及结构 1.2 栈的底层数据结构选择 1.2 数据结构设计代码&#xff08;栈的实现&#xff09; 1.3 接口函数实现代码 &#xff08;1&#xff09;初始化栈 &#xff08;2&#xff09;销毁栈 &#xff08;3&#xff09;压栈 &#xff08;4&…
阅读更多...
代码随想录算法训练营第27天—贪心算法01 | ● 理论基础 ● 455.分发饼干 ● 376. 摆动序列 ● 53. 最大子序和

代码随想录算法训练营第27天—贪心算法01 | ● 理论基础 ● 455.分发饼干 ● 376. 摆动序列 ● 53. 最大子序和

理论基础 https://programmercarl.com/%E8%B4%AA%E5%BF%83%E7%AE%97%E6%B3%95%E7%90%86%E8%AE%BA%E5%9F%BA%E7%A1%80.html 贪心算法的本质&#xff1a;由局部最优推到全局最优贪心算法的套路&#xff1a;无固定套路 455.分发饼干 https://programmercarl.com/0455.%E5%88%8…
阅读更多...
【毕业设计推荐】基于MATLAB的水果分级系统设计与实现

【毕业设计推荐】基于MATLAB的水果分级系统设计与实现

一、课题介绍 现在商业行为中&#xff0c;在水果出厂前都需要进行质量检测&#xff0c;需要将不同等级的水果进行分级包装&#xff0c;以保证商业利益最大化。可是传统方法都是依靠人工进行检测&#xff0c;效率低下&#xff0c;主观成分大&#xff0c;并不能很好客观地评价出货…
阅读更多...
Qt中的QGraphicView和QGraphicScene简单使用

Qt中的QGraphicView和QGraphicScene简单使用

概述&#xff1a;我们利用QGraphicView和QGraphicScene来实现一个简单的视频播放器&#xff0c;然后上面悬浮一些操作的控件&#xff0c;看看怎么来实现。 1、CcTestVideoPlayer类 模拟播放器类&#xff0c;继承QGraphicScene 1.1 CcTestVideoPlayer.h #pragma once#include…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023