多进程回声服务器

多进程回声服务器

服务器搭建思路

  1. 处理僵尸进程
  2. 生成服务端
  3. 循环接收客服端连接并开辟新进程处理新连接

以下是服务器实例:

#include<stdio.h>
#include<stdlib.h>
#include<string.h>
#include<unistd.h>
#include<arpa/inet.h>
#include<sys/socket.h>
#include<netinet/tcp.h>
#include<wait.h>
#include<signal.h>
#include<bits/sigaction.h>//子进程退出信号回调函数
void ChildExitHandle()
{//使用waitpid()函数int status;pid_t pid = waitpid(-1,&status,WNOHANG);//监控任意子进程、状态信息、非阻塞if (WIFEXITED(status)){printf("Child process exited.\n");printf("The child process's id is %d\n",WEXITSTATUS(status));}}//错误处理
void error_handing(char *message)
{fputs(message,stderr);fputc('\n',stderr);exit(1);
}int main(int argc, char const *argv[])
{//步骤1:处理僵尸进程 -> 使用sigaction()函数struct sigaction sig_cfg;sig_cfg.sa_handler = ChildExitHandle;sigaction(SIGCLD,&sig_cfg,NULL);//步骤2.1:生成服务端socketint server_sock;server_sock = socket(PF_INET,SOCK_STREAM,IPPROTO_TCP);if (server_sock == -1){error_handing("socket() error");}//步骤2.2:绑定监听端口struct sockaddr_in server_addr;memset(&server_addr,0,sizeof(server_addr));server_addr.sin_family = AF_INET;server_addr.sin_addr.s_addr = htonl(INADDR_ANY);server_addr.sin_port = htons(atoi("3333"));if (bind(server_sock,(struct sockaddr *)&server_addr,sizeof(server_addr)) == -1){error_handing("bind() error");}//步骤2.3:开启端口监听if (listen(server_sock,5) == -1){error_handing("listen() error");}//步骤3:循环接收客服端连接并开辟新进程处理新连接while (1){//步骤3.1:接受连接int accept_sock;struct sockaddr accept_addr;socklen_t len = sizeof(accept_addr);accept_sock = accept(server_sock,&accept_addr,&len);//第二个参数存储接入的客户端的地址信息if (accept_sock == -1){//error_handing("accept() error");continue;}else{printf("New client connected...\n");}//步骤3.2:开辟新进程与客户端交互pid_t pid = fork();if (pid == 0)//子进程{//子进程同时也复制了父进程的server_sock,要关闭close(server_sock);//步骤3.3:开始交互const int message_size = 10;char message[message_size];int read_len = 0;while((read_len=read(accept_sock, message, message_size))!=0)write(accept_sock, message, read_len);//步骤3.3:交互完毕,关闭连接close(accept_sock);//步骤3.4:子进程退出exit(2);}else//父进程{//父进程同时也包含了子进程的accept_sock,要关闭close(accept_sock);}}close(server_sock);return 0;
}

客户端实例:采用分割I/O的方法,将输入和出输出分割,简化逻辑

#include <stdio.h> 
#include <stdlib.h> 
#include <string.h> 
#include <unistd.h> 
#include <arpa/inet.h> 
#include <sys/socket.h> #define BUF_SIZE 30
void error_handling(char *message); 
void read_routline(int sock, char *buf);
void write_routline(int sock, char *buf);int main(int argc, char *argv[]) 
{int sock; pid_t pid;struct sockaddr_in serv_addr;char message[BUF_SIZE]; int str_len,i; if (argc != 3){printf("Usage : %s <IP> <port>\n", argv[0]);exit(1); }//步骤1:创建套接字sock = socket(PF_INET, SOCK_STREAM, 0);if (sock == -1) error_handling("socket() error"); //步骤2:连接端口memset(&serv_addr, 0, sizeof(serv_addr));serv_addr.sin_family = AF_INET; // 地址族设置为IPv4serv_addr.sin_addr.s_addr = inet_addr(argv[1]); // 设置服务器IP地址serv_addr.sin_port = htons(atoi(argv[2])); // 设置服务器端口号// 发送连接请求if (connect(sock, (struct sockaddr *)&serv_addr, sizeof(serv_addr)) == -1)error_handling("connect() error"); else{printf("Connected ok\n");}//步骤3:进行通讯pid=fork();if(pid==0){write_routline(sock,message);}else{read_routline(sock,message);close(sock);return 0;}}void error_handling(char* message){fputs(message, stderr); fputc('\n', stderr); exit(1); 
}void write_routline(int sock, char *buf){while(1){fgets(buf, BUF_SIZE, stdin);if(!strcmp(buf,"q\n")||!strcmp(buf,"Q\n")){shutdown(sock, SHUT_WR);return;}write(sock, buf, strlen(buf));}
}void read_routline(int sock, char *buf){while(1){int str_len=read(sock, buf, BUF_SIZE);if(str_len==0){return;}buf[str_len]=0;printf("Message from server:%s", buf);}
}

使用客户端 :./client “服务端ip” “端口”

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

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

相关文章

SpringCloudAlibaba实战入门之OpenFeign高级用法(十)

在上一篇中我们简单了解了OpenFeign的简单使用,本篇是承接上一篇的高级使用拓展内容。 一、@FeignClient 标签的常用属性 @FeignClient 注解是 Spring Cloud OpenFeign 中用于声明一个 Feign 客户端的核心注解。它可以用来指定服务的名称、配置类、负载均衡策略等。下面是 @…

DBeaver 数据库安装及破解个人使用 不同版本不同jdk

DBeaver DBeaver 分为 **Lite、Enterprise、Ultimate&#xff08;功能最全&#xff09;、Community&#xff0c;**其中Community免费使用&#xff0c;但是功能不言而喻&#xff0c;具体差异自行去官网对比。 安装 DBeaver 到官网下载即可 https://dbeaver.io/download/ 激活 D…

docker安装中的遇到的问题及解决方案

docker 安装中遇到的问题及解决方案 截至2024/11/1&#xff0c;我在安装docker中遇到的问题将悉数列出&#xff0c;供大家参考。 说明&#xff1a;这些解决方案在我自己的虚拟机中有用&#xff0c;可能大家的虚拟机并不适用&#xff0c;这些解决方案均转载自另外的博客&#x…

Jetson OrinNX平台CSI相机导致cpu load average升高问题调试

1. 前言 硬件: Orin NX JP: 5.1.2, R35.4.1 用v4l2-ctl --stream-mmap -d0 命令去获取相机数据时, 用top查看cpu使用情况, CPU占用率很低,但load average在1左右, 无任何程序运行时,load average 为0 用ps -aux 查看当前进程情况,发现有两个系统进程vi-output, …

AppInventor2能否用网络摄像头画面作为屏幕的背景?

// 视频是否可以作为背景&#xff1f; // 有会员提问&#xff1a;能否用网络摄像头的实时画面作为屏幕的背景&#xff1f;就跟这个一样背景全覆盖&#xff1a; 摄像头画面是一个在线的网站链接视频流。 // 原先思路 // 1、目前原生组件无法直接实现这个功能&#xff0c;屏幕…

【开源免费】基于SpringBoot+Vue.JS网上租赁系统(JAVA毕业设计)

本文项目编号 T 050 &#xff0c;文末自助获取源码 \color{red}{T050&#xff0c;文末自助获取源码} T050&#xff0c;文末自助获取源码 目录 一、系统介绍二、演示录屏三、启动教程四、功能截图五、文案资料5.1 选题背景5.2 国内外研究现状5.3 可行性分析5.4 用例设计5.4.1 用…

fmql之Linux以太网

正点原子第57章。 dts fmql-dtsi&#xff1a; 我们用的PHY芯片是RTL8211F&#xff1a; 需要添加PHY信息&#xff1a; fmql-dtsi提供的参考&#xff1a; 根据vivado工程自动生成的&#xff1a; reg <0x1>; 配置 疑问 网口通讯需要网线&#xff0c;但是目前板卡上只有PS…

基于STM32的农业监测与管理系统设计思路介绍(代码示例)

一、项目概述 在全球农业现代化进程中&#xff0c;农业监测与管理系统的研发具有重要意义。本文介绍的基于STM32的农业监测与管理系统&#xff0c;旨在通过智能小车实现对农作物的环境监测、土壤检测等功能。该系统利用手势控制技术&#xff0c;农民可以通过简单的手势指令来操…

【2024-10-31-2024-11-03】LeetCode刷题——python语法基础题

&#x1f4dd;前言说明&#xff1a; ●本专栏主要记录本人的基础算法学习以及LeetCode刷题记录&#xff0c;主要跟随B站作者灵茶山的视频进行学习&#xff0c;专栏中一篇文章为B站对应的一个视频 题目主要为B站视频内涉及的题目以及B站视频中提到的“课后作业”。 ●文章中的理…

2024年【烟花爆竹储存】考试试卷及烟花爆竹储存试题及解析

题库来源&#xff1a;安全生产模拟考试一点通公众号小程序 烟花爆竹储存考试试卷考前必练&#xff01;安全生产模拟考试一点通每个月更新烟花爆竹储存试题及解析题目及答案&#xff01;多做几遍&#xff0c;其实通过烟花爆竹储存作业模拟考试很简单。 1、【单选题】( )负责烟花…

Uniapp的H5以及App不支持后端传FormData类型参数的解决方案

在uniapp中不支持FormData的传参&#xff0c;这就很恶心&#xff1b;如果强行传的话会提示&#xff0c;请求失败的报错信息。 因为后端必须要FormData类型的传参&#xff0c;所以在查阅一系列方案后&#xff0c;有一种解决办法可以完美解决。 代码&#xff1a; init() {const…

JS实现漂亮的登录页面(氛围感页面)

代码&#xff1a; <!DOCTYPE html> <html lang"zh-CN"> <head><meta charset"UTF-8"><meta name"viewport" content"widthdevice-width, initial-scale1.0"><title>登录</title><style…

(C#面向初学者的 .NET 的生成 AI) 第 2 部分-什么是 AI 和 ML?

从本部分开始Luis Quintanilla介绍AI和机器学习&#xff0c;需要学习的一些东西是什么是AI和ML&#xff1f;作为一名.net开发人员如何学习使用AI和ML。 1、首先什么是AI 和 ML&#xff1f; 你可以把它看作是基本相同事物的不同层次。 在顶层的是AI&#xff08;人工智能&#xf…

Spring Boot技术:校园社团信息管理的革新者

4系统概要设计 4.1概述 本系统采用B/S结构(Browser/Server,浏览器/服务器结构)和基于Web服务两种模式&#xff0c;是一个适用于Internet环境下的模型结构。只要用户能连上Internet,便可以在任何时间、任何地点使用。系统工作原理图如图4-1所示&#xff1a; 图4-1系统工作原理…

探索高效HTTP会话管理:sessionup开源项目推荐

探索高效HTTP会话管理&#xff1a;sessionup开源项目推荐 sessionup Straightforward HTTP session management 项目地址: https://gitcode.com/gh_mirrors/se/sessionup 在现代Web应用开发中&#xff0c;会话管理是确保用户身份验证和数据安全的关键环节。为了帮助开发…

(七)JavaWeb后端开发——Maven

目录 1.Maven概述 2.Maven依赖管理 2.1依赖配置 2.2依赖传递 2.3依赖范围 2.4生命周期 1.Maven概述 maven是一款管理和构建java项目的工具 Maven的作用&#xff1a; 依赖管理&#xff1a;方便快捷的管理项目依赖的资源(jar包)&#xff0c;避免版本冲突问题统一项目结构…

jenkins 构建报错 Cannot run program “sh”

原因 在 windows 操作系统 jenkins 自动化部署的时候, 由于自动化构建的命令是 shell 执行的,而默认windows 从 path 路径拿到的 shell 没有 sh.exe &#xff0c;因此报错。 解决方法 前提是已经安装过 git WINR 输入cmd 打开命令行, 然后输入where git 获取 git 的路径, …

数据结构——二叉树

♥♥♥~~~~~~欢迎光临知星小度博客空间~~~~~~♥♥♥ ♥♥♥零星地变得优秀~也能拼凑出星河~♥♥♥ ♥♥♥我们一起努力成为更好的自己~♥♥♥ ♥♥♥如果这一篇博客对你有帮助~别忘了点赞分享哦~♥♥♥ ♥♥♥如果有什么问题可以评论区留言或者私信我哦~♥♥♥ 这一篇博客我们开…

NVR批量管理软件/平台EasyNVR多个NVR同时管理支持视频投放在电视墙上

在当今智能化、数字化的时代&#xff0c;视频监控已经成为各行各业不可或缺的一部分&#xff0c;无论是公共安全、交通管理、企业监控还是智慧城市建设&#xff0c;都离不开高效、稳定的视频监控系统的支持。而在这些应用场景中&#xff0c;将监控视频实时投放到大屏幕电视墙上…

JAVA_18

JAVA_18 1.IO流2.JAVA_IO流3.标准输入输出4.对象序列化5.字符编码与字符集6.异常处理和资源关闭7.NIO、BIO、AIO1. IO回顾&#xff1a;2. BIO(Blockingl/O)&#xff1a;3. NIO(Newl/O)&#xff1a;4. AIO(AsynchronousI/O)&#xff1a; 1.IO流 IO流(Input/Output stream)是用于…