tcp并发设计

4注意：原始代码，如果先关闭服务器端，再次开启服务器的时候会报"connect: Connection refused
"错误，这是因为先关服务器端，导致系统认为客户端仍然在与服务器端连接造成。

可以使用setsockopt

setsockopt函数用于设置套接字选项，可以用来控制套接字的行为和属性。通过setsockopt函数，可以设置套接字的各种选项，如超时设置、缓冲区大小、复用地址、广播等。这些选项可以影响套接字的连接、通信、数据传输等方面的行为，使程序更加灵活、高效地运行。通过设置不同的选项，可以满足不同的网络编程需求。
int setsockopt(int sockfd, int level, int optname, const void *optval, socklen_t optlen);

参数说明：
- `sockfd`为目标套接字的文件描述符。
- `level`为选项所在的协议层，一般为`SOL_SOCKET`表示Socket级别选项。
- `optname`为要设置的选项名。
- `optval`为指向包含新选项值的缓冲区的指针。
- `optlen`为新选项值的长度。

成功时返回0，失败时返回-1并设置errno。

（后续文章会仔细讲解）

    int flag=1,len=sizeof(int);if(setsockopt(fd,SOL_SOCKET,SO_REUSEADD,&flag,len)==-1){perror("setsockopt");exit(0);}

进程并发设计

并法思路：

一个新生成的文件描述符对应一个客户端，如果多个客户端就需要多个accept函数生成多个文件描述符

注意：给客户端的端口号代表的是服务器的端口号，为了确定是连接的是哪个服务器

accept(fd, (struct sockaddr *)&clint_addr, &addrlen);accept获取的是客户端的端口

1.创建子进程

子进程接收accept返回的新的newfd

while(1){newfd = accept(fd, (struct sockaddr *)&clint_addr, &addrlen);if(newfd < 0){perror("accept");exit(0);}printf("addr:%s port:%d\n",inet_ntoa(clint_addr.sin_addr),ntohs(clint_addr.sin_port));if((pid=fork())<0){perror("fork");exit(0);}else if(pid==0){close(fd);//此时子进程不用fd，将子进程中fd关掉ClientHandle(newfd);//此时子进程打开了一个newfd，父进程也打开了一个newfd，浪费资源，因此将父进程的newfd关掉exit(0);}elseclose(newfd);//父进程不用newfd，将父进程中newfd关掉}close(fd);return 0;
}
void ClientHandle(int newfd){int ret;char buf[BUFSIZ]={};

 2.执行子进程内容

void ClientHandle(int newfd){int ret;char buf[BUFSIZ]={};while(1){//	memset(buf, 0, BUFSIZ);bzero(buf,BUFSIZ);ret = read(newfd, buf, BUFSIZ);if(ret < 0){perror("read");exit(0);}else if(ret == 0)break;elseprintf("buf = %s\n", buf);}
}

 3.回收子进程

通过信号机制
1.初始化signaction函数
	struct sigaction act;act.sa_handler=SignHandle;act.sa_flags=SA_RESTART;sigemptyset(&act.sa_mask);sigaction(SIGCHLD,&act,NULL);

注意：

accept: Interrupted system call
当回收进程时，可能会出现"accept: Interrupted system call"错误，是因为使用信号机制时导致某些系统调用被终止了，此时设置sigaction函数结构体中的sa_flags=SA_RESTART，让意外终止的系统调用继续运行。

（可以通过man signaction命令查看）

2.创建SignHandle函数
void SignHandle(int sig){if(sig==SIGCHLD){printf("client exit\n");wait(NULL);}
}

 原始代码

#include <stdio.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <stdlib.h>
#include <arpa/inet.h>
#include <unistd.h>
#include <string.h>
#include<strings.h>
#include<signal.h>
#include<sys/types.h>
#include<sys/wait.h>
#define BACKLOG 5
void ClientHandle(int newfd);
void SignHandle(int sig);
void SignHandle(int sig){if(sig==SIGCHLD){printf("client exit\n");wait(NULL);}
}
int main(int argc, char *argv[])
{int fd, newfd;struct sockaddr_in addr,clint_addr;socklen_t addrlen;//尽量不使用指针类型，如果指针指向的地址没有存储给定的数据，很可能成为野指针addrlen=sizeof(clint_addr);pid_t pid;struct sigaction act;act.sa_handler=SignHandle;act.sa_flags=SA_RESTART;sigemptyset(&act.sa_mask);sigaction(SIGCHLD,&act,NULL);if(argc < 3){fprintf(stderr, "%s<addr><port>\n", argv[0]);exit(0);}fd = socket(AF_INET, SOCK_STREAM, 0);if(fd < 0){perror("socket");exit(0);}addr.sin_family = AF_INET;addr.sin_port = htons( atoi(argv[2]) );if ( inet_aton(argv[1], &addr.sin_addr) == 0) {fprintf(stderr, "Invalid address\n");exit(EXIT_FAILURE);}int flag=1,len=sizeof(int);if(setsockopt(fd,SOL_SOCKET,SO_REUSEADDR,&flag,len)==-1){perror("setsockopt");exit(0);}if(bind(fd, (struct sockaddr *)&addr, sizeof(addr) ) == -1){perror("bind");exit(0);}if(listen(fd, BACKLOG) == -1){perror("listen");exit(0);}//此新的文件描述符用于跟客户通讯//并法思路：一个新生成的文件描述符对应一个客户端，如果多个客户端就需要多个accept函数生成多个文件描述符while(1){newfd = accept(fd, (struct sockaddr *)&clint_addr, &addrlen);if(newfd < 0){perror("accept");exit(0);}printf("addr:%s port:%d\n",inet_ntoa(clint_addr.sin_addr),ntohs(clint_addr.sin_port));if((pid=fork())<0){perror("fork");exit(0);}else if(pid==0){close(fd);//此时子进程不用fd，将子进程中fd关掉ClientHandle(newfd);//此时子进程打开了一个newfd，父进程也打开了一个newfd，浪费资源，因此将父进程的newfd关掉exit(0);}elseclose(newfd);//父进程不用newfd，将父进程中newfd关掉}close(fd);return 0;
}
void ClientHandle(int newfd){int ret;char buf[BUFSIZ]={};while(1){//	memset(buf, 0, BUFSIZ);bzero(buf,BUFSIZ);ret = read(newfd, buf, BUFSIZ);if(ret < 0){perror("read");exit(0);}else if(ret == 0)break;elseprintf("buf = %s\n", buf);}
}

线程并发设计

并发思路：通过accept返回的新的文件描述符，传参给子线程

1.创建子线程

	while(1){newfd = accept(fd, (struct sockaddr *)&clint_addr, &addrlen);if(newfd < 0){perror("accept");exit(0);}printf("addr:%s port:%d\n", inet_ntoa(clint_addr.sin_addr), ntohs(clint_addr.sin_port) );pthread_create(&tid, NULL, ClinetHandle, &newfd);pthread_detach(tid);//设置为分离模式，不需要回收线程}

 2.执行子线程函数

void *ClinetHandle(void *arg){int ret;char buf[BUFSIZ] = {};int newfd = *(int *)arg;while(1){//memset(buf, 0, BUFSIZ);bzero(buf, BUFSIZ);ret = read(newfd, buf, BUFSIZ);if(ret < 0){perror("read");exit(0);}else if(ret == 0)break;elseprintf("buf = %s\n", buf);}printf("client exited\n");close(newfd);return NULL;
}

 原始代码

#include <stdio.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <stdlib.h>
#include <arpa/inet.h>
#include <unistd.h>
#include <string.h>
#include <strings.h>
#include <pthread.h>#define BACKLOG 5void *ClinetHandle(void *arg);
int main(int argc, char *argv[])
{int fd, newfd;struct sockaddr_in addr, clint_addr;pthread_t tid;socklen_t addrlen = sizeof(clint_addr);if(argc < 3){fprintf(stderr, "%s<addr><port>\n", argv[0]);exit(0);}fd = socket(AF_INET, SOCK_STREAM, 0);if(fd < 0){perror("socket");exit(0);}addr.sin_family = AF_INET;addr.sin_port = htons( atoi(argv[2]) );if ( inet_aton(argv[1], &addr.sin_addr) == 0) {fprintf(stderr, "Invalid address\n");exit(EXIT_FAILURE);}int flag=1,len= sizeof (int); if ( setsockopt(fd, SOL_SOCKET, SO_REUSEADDR, &flag, len) == -1) { perror("setsockopt"); exit(1); } if(bind(fd, (struct sockaddr *)&addr, sizeof(addr) ) == -1){perror("bind");exit(0);}if(listen(fd, BACKLOG) == -1){perror("listen");exit(0);}while(1){newfd = accept(fd, (struct sockaddr *)&clint_addr, &addrlen);if(newfd < 0){perror("accept");exit(0);}printf("addr:%s port:%d\n", inet_ntoa(clint_addr.sin_addr), ntohs(clint_addr.sin_port) );pthread_create(&tid, NULL, ClinetHandle, &newfd);pthread_detach(tid);//设置为分离模式，不需要回收线程}close(fd);return 0;
}
void *ClinetHandle(void *arg){int ret;char buf[BUFSIZ] = {};int newfd = *(int *)arg;while(1){//memset(buf, 0, BUFSIZ);bzero(buf, BUFSIZ);ret = read(newfd, buf, BUFSIZ);if(ret < 0){perror("read");exit(0);}else if(ret == 0)break;elseprintf("buf = %s\n", buf);}printf("client exited\n");close(newfd);return NULL;
}

注意：

vi排版：按v，上下键选中需要排版的代码，按=即可

相关函数：

`bzero()` 函数用于将指定长度的内存区域清零，即将所有字节初始化为0。它通常用于清空敏感的数据或准备数据结构。`bzero()` 函数在许多系统中已经被废弃，应该使用更现代的函数`memset()` 来替代。其原型如下：

include<strings.h>
void bzero(void *s, size_t n);

其中，参数 `s` 是指向要清零的内存区域的指针，参数 `n` 是要清零的字节数。
man inet_addr可以查看使用in_addr结构体的函数返回值类型

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

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

相关文章

three-tile 一个开源的轻量级三维瓦片库

three-tile 一个开源的轻量级三维瓦片库

three-tile 介绍 three-tile 是一个开源的轻量级三维瓦片库&#xff0c;它基于threejs使用typescript开发&#xff0c;提供一个三维地形模型&#xff0c;能轻松给你的应用增加三维瓦片地图。 源码&#xff1a;https://github.com/sxguojf/three-tile 示例&#xff1a;https:/…
阅读更多...
【TB作品】51单片机 Proteus仿真 00013红外proteus仿真循迹避障小车

【TB作品】51单片机 Proteus仿真 00013红外proteus仿真循迹避障小车

实验报告&#xff1a;智能小车系统设计与实现 一、背景介绍 本实验旨在设计并实现一个基于STC89C52单片机控制的智能小车系统。该系统通过超声波传感器进行避障&#xff0c;通过红外接收器实现远程控制&#xff0c;同时具备循迹功能。整个系统的核心是单片机&#xff0c;它通…
阅读更多...
YOLOv10改进 | 损失函数篇 | InnerIoU、InnerSIoU、InnerWIoU、FocusIoU等损失函数

YOLOv10改进 | 损失函数篇 | InnerIoU、InnerSIoU、InnerWIoU、FocusIoU等损失函数

一、本文介绍 本文给大家带来的是YOLOv10最新改进&#xff0c;为大家带来最近新提出的InnerIoU的内容同时用Inner的思想结合SIoU、WIoU、GIoU、DIoU、EIOU、CIoU等损失函数&#xff0c;形成 InnerIoU、InnerSIoU、InnerWIoU、等新版本损失函数&#xff0c;同时还结合了Focus和…
阅读更多...
LeetCode42(接雨水)[三种解法:理解动态规划,双指针,单调栈]

LeetCode42(接雨水)[三种解法:理解动态规划,双指针,单调栈]

接雨水 给定 n 个非负整数表示每个宽度为 1 的柱子的高度图&#xff0c;计算按此排列的柱子&#xff0c;下雨之后能接多少雨水。 这是一道困难题,难度确实有点层次.我们先来朴素思想走一波. 要求能接多少雨水,我们可以具化到每个硅谷,每个硅谷能存多少雨水,那么答案就是每个…
阅读更多...
PDA:Prompt-based Distribution Alignment for Unsupervised Domain Adaptation

PDA:Prompt-based Distribution Alignment for Unsupervised Domain Adaptation

文章汇总 式中&#xff0c; y s y^s ys表示源域数据的one-hot ground-truth&#xff0c; K K K为类数&#xff0c; w i w_i wi​和 z ~ s \tilde{z}_s z~s​分别表示源域经过提示调优的最终文本表示和最终图像表示的第 i i i类。 同理&#xff0c;为了进一步利用目标领域的数据…
阅读更多...
防火墙详解（USG6000V）

防火墙详解（USG6000V）

0、防火墙组网模式 防火墙能够工作在三种模式下分别是路由模式、透明模式、旁路检测模式、混合模式 0.1、路由模式 路由模式&#xff1a;防火墙全部以第三层对外连接&#xff0c;即接口具有IP 地址。一般都用在防火墙是边界的场景下 防火墙需要的部署/配置&#xff1a; 接…
阅读更多...
【入门篇】STM32寻址范围（更新中）

【入门篇】STM32寻址范围（更新中）

写在前面 STM32的寻址范围涉及存储器映射和32位地址线的使用。并且STM32的内存地址访问是按字节编址的，即每个存储单元是1字节（8位）。 一、寻址大小与范围 地址线根数 地址编号(二进制) 地址编号数(即内存大小) <
阅读更多...
实现基于Elasticsearch的搜索服务

实现基于Elasticsearch的搜索服务

实现基于Elasticsearch的搜索服务 大家好&#xff0c;我是微赚淘客系统3.0的小编&#xff0c;也是冬天不穿秋裤&#xff0c;天冷也要风度的程序猿&#xff01; 1. Elasticsearch简介 Elasticsearch是一个开源的分布式搜索引擎&#xff0c;提供强大的全文搜索和分析功能。本文…
阅读更多...
10、DDD分层架构

10、DDD分层架构

微服务架构模型有很多种&#xff0c;例如洋葱架构、CQRS和六边形架构等。虽然这些架构模式提出的时代和背景不同&#xff0c;但其核心理念都是为了设计出“高内聚&#xff0c;低耦合”的微服务&#xff0c;轻松实现微服务的架构演进。DDD分层架构的出现&#xff0c;使微服务的架…
阅读更多...
什么是ThreadLocal以及内存泄漏问题、hash冲突问题

什么是ThreadLocal以及内存泄漏问题、hash冲突问题

ThreadLocal是什么 ThreadLocal类用来提供线程内部的局部变量 它主要有三大特性&#xff1a; 线程安全: 在多线程并发的场景下保证线程安全传递数据&#xff1a;通过ThreadLocal在同一线程传递公共变量线程隔离&#xff1a;每个线程的变量都是独立的&#xff0c;不会互相影响…
阅读更多...
这次让我们从几个点认识一下Mysql的Innodb

这次让我们从几个点认识一下Mysql的Innodb

MySQL 的 InnoDB 存储引擎是 MySQL 默认和最常用的存储引擎之一。它主要关注的是高可靠性、性能以及完整的事务支持。以下是对 InnoDB 存储引擎的详细介绍&#xff1a; 1. 数据库特性 1.1 事务支持 InnoDB 是完全支持事务的存储引擎&#xff0c;支持四种主要的事务隔离级别&…
阅读更多...
【uniapp-ios】App端与webview端相互通信的方法以及注意事项

【uniapp-ios】App端与webview端相互通信的方法以及注意事项

前言 在开发中&#xff0c;使用uniapp开发的项目开发效率是极高的&#xff0c;使用一套代码就能够同时在多端上线&#xff0c;像笔者之前写过的使用Flutter端和webview端之间的相互通信方法和问题&#xff0c;这种方式本质上实际上是h5和h5之间的通信&#xff0c;网上有非常多…
阅读更多...
ios身份证实名认证接口开发示例助力电商物流实名认证

ios身份证实名认证接口开发示例助力电商物流实名认证

为了更好的利用货车资源&#xff0c;也方便企业正常的运送货物&#xff0c;“互联网电商”平台可谓风起云涌。货车司机和有发货需求的人们可以在物流平台注册&#xff0c;货车司机接单为有运送需求的用户提供有偿货运服务。那么&#xff0c;如何让企业放心的将货物安心的交予货…
阅读更多...
物联网实训室建设可行性报告

物联网实训室建设可行性报告

一、建设物联网实训室的目的和意义 随着信息技术的快速发展&#xff0c;物联网&#xff08;IoT&#xff09;已成为推动社会进步和经济发展的关键技术之一。物联网技术的集成应用&#xff0c;不仅能够提高生产效率&#xff0c;还能促进智慧城市、智能家居、智能农业等多个领域的…
阅读更多...
python04——类（基础new）

python04——类（基础new）

类其实也是一种封装的思想&#xff0c;类就是把变量、方法等封装在一起&#xff0c;然后可以通过不同的实例化对其进行调用操作。 1.类的定义 class 类名&#xff1a; 变量a def __init__ (self,参数2&#xff0c;参数2...)&#xff1a;初始化函数&#xff01;&#xff01;&…
阅读更多...
vivado DELAY_VALUE_XPHY、DIFF_TERM

vivado DELAY_VALUE_XPHY、DIFF_TERM

延迟_值_XPHY PORT对象上的DELAY_VALUE_XPHY属性指定要添加的延迟量 Versal XPHY逻辑接口的输入或输出路径。在的早期阶段 opt_design在重新生成高级I/O向导IP时 DELAY_VALUE_XPHY值将从PORT复制到的XPHY实例上 输入或输出路径。Vivado设计套件中存在DRCs&#xff0c;以确保 DE…
阅读更多...
简单实现联系表单Contact Form自动发送邮件

简单实现联系表单Contact Form自动发送邮件

如何实现简单Contact Form自动邮件功能&#xff1f;怎样简单设置&#xff1f; 联系表单不仅是访客与网站所有者沟通的桥梁&#xff0c;还可以收集潜在客户的信息&#xff0c;从而推动业务的发展。AokSend将介绍如何简单实现一个联系表单&#xff0c;自动发送邮件的过程&#x…
阅读更多...
java Collections类介绍

java Collections类介绍

Java 的 java.util.Collections 类提供了一组静态方法&#xff0c;用于操作或返回集合&#xff08;如列表、集合和映射&#xff09;。Collections 类是一个实用工具类&#xff0c;旨在为集合提供便捷的算法和操作。以下是对 Collections 类及其常用方法的介绍。 常用方法总结 …
阅读更多...
【游戏客户端】大话slg玩法架构（一）滚动基类

【游戏客户端】大话slg玩法架构（一）滚动基类

【游戏客户端】大话slg玩法架构&#xff08;一&#xff09;滚动基类 大家好&#xff0c;我是Lampard家杰~~ 今天我们兑现诺言&#xff0c;给大家分享SLG玩法的实现j架构&#xff0c;关于SLG玩法的介绍可以参考这篇上一篇文章&#xff1a;【游戏客户端】制作率土之滨Like玩法 PS…
阅读更多...
保险理论与实践

保险理论与实践

《保险理论与实践》是由中国保险学会主办的学术集刊&#xff0c;于2016年1月正式创办&#xff0c;致力于发表权威、严谨、高质量的理论研究、政策研究和实务研究成果&#xff0c;强调学术性与政策性、理论性与实践性的有机结合。本刊由中国金融出版社公开出版&#xff0c;每月下…
阅读更多...
最新文章

Copyright @ 2022~2023