信号通信与消息队列实现的通信：2024/2/23

作业1：将信号和消息队列的课堂代码敲一遍

1.1 信号

1.1.1 信号默认、捕获、忽略处理(普通信号)

代码：

#include <myhead.h>
void handler(int signo)
{
	if(signo==SIGINT){
		printf("用户键入 ctrl+c\n");
	}
}
int main(int argc, const char *argv[])
{
	//忽略信号
	if(signal(SIGINT,SIG_IGN)==SIG_ERR){
		perror("signal error");
		return -1;
	}
	/*
	//默认处理信号
	if(signal(SIGINT,SIG_IGN)==SIG_ERR){
		perror("signal error");
		return -1;
	}
	//捕获信号
	if(signal(SIGINT,handler)==SIG_ERR){
		perror("signal error");
		return -1;
	}
	*/
	while(1)
	{
		printf("123456\n");
		sleep(1);
	}
	return 0;
}

效果图：

1.1.2 SIGCHLD回收僵尸进程

代码：

#include <myhead.h>
void handler(int signo)
{
	if(signo==SIGCHLD){
		while(waitpid(-1,NULL,WNOHANG)>0);
		//waitpid(-1,NULL,WNOHANG);
	}
}
int main(int argc, const char *argv[])
{
	
	//捕获信号
	if(signal(SIGCHLD,handler)==SIG_ERR){
		perror("signal error");
		return -1;
	}
	//创建僵尸进程
	for(int i=0;i<5;i++)
	{
		if(fork()==0){
			sleep(1);
			exit(EXIT_SUCCESS);
		}
	}
	while(1);
	return 0;
}

效果图：

1.1.3 模拟出牌

代码：

#include <myhead.h>

//信号处理函数
void handler(int signo)
{
	if(signo==SIGALRM){
		printf("系统为您出了一张牌\n");
		alarm(5);
	}
}
int main(int argc, const char *argv[])
{
	//捕获SIGALRM信号
	if(signal(SIGALRM,handler)==SIG_ERR){
		perror("signal error");
		return -1;
	}
	alarm(5);             //启动定时器
	
	//出的牌
	char ch=0;
	while(1)
	{
		scanf("%c",&ch);
		getchar();

		printf("你出的牌为:%c\n",ch);
		alarm(5);
	}
	return 0;
}

效果图：

1.1.4 发送信号函数

代码：

#include <myhead.h>

void hander(int signo)
{
	if(signo==SIGUSR1){
		printf("大清亡了\n");
		raise(SIGKILL);
	}
}
int main(int argc, const char *argv[])
{
	//发送信号
	if(signal(SIGUSR1,hander)==SIG_ERR){
		perror("signal error");
		return -1;
	}
	
	
	//创建进程
	pid_t pid=fork();

	if(pid>0){
		//父进程
		while(1)
		{
			printf("这是朕的江山\n");
			sleep(1);
		}
	}else if(pid==0){
		//子进程
		sleep(3);
		printf("我才是真命天子\n");
		kill(getppid(),SIGUSR1);
		while(1)
		{
			printf("现在是我的了\n");
			sleep(1);
		}
	}else{
		perror("pid error");
		return -1;
	}
	return 0;
}

效果图：

1.2 消息队列

msgsnd.c:

#include <myhead.h>

//消息队列结构体
struct msgbuf
{
	long mtype;
	char mtest[1024];
};
//宏表示消息正文的大小
#define MSGSIZE sizeof(struct msgbuf)-sizeof(long)

int main(int argc, const char *argv[])
{
	//创建 key 值
	key_t key=0;
	if((key=ftok("/",'k'))==-1){
		perror("ftok error");
		return -1;
	}
	printf("fork success key=%#x\n",key);
	//根据key值创建消息队列
	int msqid=-1;
	if((msqid=msgget(key,IPC_CREAT|0664))==-1){
		perror("msgget error");
		return -1;
	}
	printf("msgget success msqid=%#x\n",msqid);
	//定义一个消息
	struct msgbuf sbuf;

	while(1)
	{
		//清空正文的容器
		bzero(sbuf.mtest,sizeof(sbuf.mtest));
		
		printf("请输入当前消息的类型:");
		scanf("%ld",&sbuf.mtype);
		getchar();                 //吸收垃圾字符
		printf("请输入消息正文:");
		fgets(sbuf.mtest,sizeof(sbuf.mtest),stdin);
		sbuf.mtest[strlen(sbuf.mtest)-1]='\0';

		//将消息存放到队列中
		msgsnd(msqid,&sbuf,MSGSIZE,0);
		printf("发送成功\n");

		if(strcmp(sbuf.mtest,"quit")==0){
			break;
		}

	}

	return 0;
}

msgrcv.c:

#include <myhead.h>

//消息队列结构体
struct msgbuf
{
	long mtype;
	char mtest[1024];
};
//宏表示消息正文的大小
#define MSGSIZE sizeof(struct msgbuf)-sizeof(long)

int main(int argc, const char *argv[])
{
	//创建 key 值
	key_t key=0;
	if((key=ftok("/",'k'))==-1){
		perror("ftok error");
		return -1;
	}
	printf("fork success key=%#x\n",key);
	//根据key值创建消息队列
	int msqid=-1;
	if((msqid=msgget(key,IPC_CREAT|0664))==-1){
		perror("msgget error");
		return -1;
	}
	printf("msgget success msqid=%#x\n",msqid);
	//定义一个消息
	struct msgbuf rbuf;

	while(1)
	{
		//清空正文的容器
		bzero(rbuf.mtest,sizeof(rbuf.mtest));
	
		//从消息队列中读取一个消息
		msgrcv(msqid,&rbuf,MSGSIZE,0,0);

		printf("收到的消息为:%s\n",rbuf.mtest);

		if(strcmp(rbuf.mtest,"quit")==0){
			break;
		}

	}

	//删除消息队列
	if(msgctl(msqid,IPC_RMID,NULL)!=0){
		perror("msgctl error");
		return -1;
	}

	return 0;
}

效果图：

作业2：使用消息队列完成两个进程间相互通信

msgsnd.c:

#include <myhead.h>

//定义一个消息类型
struct msgbuf
{
	long mtype;
	char mtest[1024];
};

//宏表示消息正文大小
#define MSGSIZE sizeof(struct msgbuf)-sizeof(long)

/*****************************主程序***********************/
int main(int argc, const char *argv[])
{
	//1、创建key值
	key_t key=0;
	if((key=ftok("/",'k'))==-1){
		perror("ftok error");
		return -1;
	}
	//根据key值创建一个消息队列
	int msqid=-1;
	if((msqid=msgget(key,IPC_CREAT|0664))==-1){
		perror("msgget error");
		return -1;
	}
	//创建一个子进程
	pid_t pid=fork();

	if(pid>0){
		//父进程向消息队列中写入类型为1的消息正文
		//定义一个消息
		struct msgbuf sbuf;
		sbuf.mtype=1;
		while(1)
		{
			//清空容器
			bzero(sbuf.mtest,sizeof(sbuf.mtest));

			printf("发送的消息:");
			fgets(sbuf.mtest,sizeof(sbuf.mtest),stdin);
			sbuf.mtest[strlen(sbuf.mtest)-1]='\0';

			//将消息存放到消息队列
			msgsnd(msqid,&sbuf,MSGSIZE,0);
			printf("发送成功\n");

			if(strcmp(sbuf.mtest,"quit")==0){
				break;
			}
		}
        wait(NULL);	
	}else if(pid==0){
		//子进程从消息队列中取出类型为2的消息正文
		//定义一个消息
		struct msgbuf rbuf;

		while(1)
		{
			//清空容器
			bzero(rbuf.mtest,sizeof(rbuf.mtest));

			//从消息队列中读取类型为2的消息正文
			msgrcv(msqid,&rbuf,MSGSIZE,2,0);

			printf("收到的消息为:%s\n",rbuf.mtest);
			if(strcmp(rbuf.mtest,"quit")==0){
				break;
			}
		}
        exit(EXIT_SUCCESS);
	}else{
		perror("fork error");
		return -1;
	}

	return 0;
}

msgrcv.c:

#include <myhead.h>

//定义一个消息类型
struct msgbuf
{
	long mtype;
	char mtest[1024];
};

//宏表示消息正文大小
#define MSGSIZE sizeof(struct msgbuf)-sizeof(long)

/*****************************主程序***********************/
int main(int argc, const char *argv[])
{
	//1、创建key值
	key_t key=0;
	if((key=ftok("/",'k'))==-1){
		perror("ftok error");
		return -1;
	}
	//根据key值创建一个消息队列
	int msqid=-1;
	if((msqid=msgget(key,IPC_CREAT|0664))==-1){
		perror("msgget error");
		return -1;
	}
	//创建一个子进程
	pid_t pid=fork();

	if(pid>0){
		//父进程从消息队列中取出类型为1的消息正文
		//定义一个消息
		struct msgbuf rbuf;

		while(1)
		{
			//清空容器
			bzero(rbuf.mtest,sizeof(rbuf.mtest));

			//从消息队列中读取类型为1的消息正文
			msgrcv(msqid,&rbuf,MSGSIZE,1,0);

			printf("收到的消息为:%s\n",rbuf.mtest);
			if(strcmp(rbuf.mtest,"quit")==0){
				break;
			}
		}
        wait(NULL);
	}else if(pid==0){
		//子进程向消息队列中写入类型为2的消息正文
		//定义一个消息
		struct msgbuf sbuf;
		sbuf.mtype=2;
		while(1)
		{
			//清空容器
			bzero(sbuf.mtest,sizeof(sbuf.mtest));

			printf("发送的消息:");
			fgets(sbuf.mtest,sizeof(sbuf.mtest),stdin);
			sbuf.mtest[strlen(sbuf.mtest)-1]='\0';

			//将消息存放到消息队列
			msgsnd(msqid,&sbuf,MSGSIZE,0);
			printf("发送成功\n");

			if(strcmp(sbuf.mtest,"quit")==0){
				break;
			}
		}
        exit(EXIT_SUCCESS);
	}else{
		perror("fork error");
		return -1;
	}

	return 0;
}

效果图：

作业3：思维导图

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

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

相关文章

招聘APP开发实践：技术选型、架构设计与开发流程

招聘APP开发实践：技术选型、架构设计与开发流程

时下&#xff0c;招聘APP成为了企业和求职者之间连接的重要纽带。本文将深入探讨招聘APP的开发实践&#xff0c;重点关注技术选型、架构设计以及开发流程等关键方面&#xff0c;带领读者走进这一充满挑战与机遇的领域。 一、技术选型 在开始招聘APP的开发之前&#xff0c;首…
阅读更多...
单片机51 输入和输出

单片机51 输入和输出

一、IO口基本概念介绍 单片机的IO口&#xff08;Input/Output口&#xff09;是连接单片机与外部电路或设备的接口。单片机的IO口可以分为输入口和输出口两种&#xff0c;用于控制和监测外部设备的状态。 1. 输入口&#xff1a;单片机的输入口用于接收外部电路或设备的信号。输…
阅读更多...
Day20_网络编程(软件结构,网络编程三要素,UDP网络编程,TCP网络编程)

Day20_网络编程(软件结构,网络编程三要素,UDP网络编程,TCP网络编程)

文章目录 Day20 网络编程学习目标1 软件结构2 网络编程三要素2.1 IP地址和域名1、IP地址2、域名3、InetAddress类 2.2 端口号2.3 网络通信协议1、OSI参考模型和TCP/IP参考模型2、UDP协议3、TCP协议 2.4 Socket编程 3 UDP网络编程3.1 DatagramSocket和DatagramPacket1、Datagram…
阅读更多...
2024年 最新python调用ChatGPT实战教程

2024年 最新python调用ChatGPT实战教程

2024年 最新python调用ChatGPT实战教程 文章目录 2024年 最新python调用ChatGPT实战教程一、前言二、具体分析1、简版程序2、多轮对话3、流式输出4、返回消耗的token 一、前言 这个之前经常用到&#xff0c;简单记录一下,注意目前chatgpt 更新了&#xff0c;这个是最新版的&am…
阅读更多...
linux中的权限

linux中的权限

Linux 的权限 在了解Linux的权限之前&#xff0c;我们需要知道Linux的构成&#xff0c;Linux分为三个部分&#xff0c;内核、外部程序、以及用户。 内核&#xff1a; 内核一般是指Linux的操作系统&#xff0c;用来执行用户发送的指令 或者 拒绝执行用户发布指令时而发出的报…
阅读更多...
07_html

07_html

文章目录 引言前端概述分类 HTML快速入门重要的body标签注释hr标签br标签一些常见的标签标题标签div标签span标签p标签a标签img标签路径问题 ol和ul标签table标签input标签&#xff08;表单元素&#xff09;textarea标签&#xff08;表单元素&#xff09;select标签&#xff08…
阅读更多...
使用Lombok @Data 出现java: 找不到符号 的问题

使用Lombok @Data 出现java: 找不到符号 的问题

第一种&#xff1a;pom依赖最好如下方式 <dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><version>RELEASE</version><scope>compile</scope> </dependency>第二种&#xff1…
阅读更多...
在项目中应用设计模式的实践指南

在项目中应用设计模式的实践指南

目录 ✨✨ 祝屏幕前的您天天开心&#xff0c;每天都有好运相伴。我们一起加油&#xff01;✨✨ &#x1f388;&#x1f388;作者主页&#xff1a; 喔的嘛呀&#x1f388;&#x1f388; 引言 一. 单例模式&#xff08;Singleton Pattern&#xff09; 1、实现单例模式的方式 1…
阅读更多...
neo4j创建新数据库

neo4j创建新数据库

根据网上提供的教程&#xff0c;neo4j并没有提供创建数据库的命令&#xff0c;其只有一个默认数据库graph.db&#xff0c;该数据库中的所有数据将存储在neo4j安装路径下的data/databases/graph.db目录中。 因此&#xff0c;我们猜想&#xff0c;如果我们将默认数据库的名字修改…
阅读更多...
【Vue渗透】Vue Devtools 浏览器插件

【Vue渗透】Vue Devtools 浏览器插件

下载地址 Vue Devtools 浏览器插件 Vue站点渗透思路 【Vue渗透】Vue站点渗透思路 简介 Vue Devtools 是 Vue 官方发布的调试浏览器插件&#xff0c;可以安装在 Chrome 和 Firefox 等浏览器上&#xff0c;直接内嵌在开发者工具中&#xff0c;使用体验流畅。Vue Devtools 由…
阅读更多...
【复现】用友U8 oa协同工作系统 文件上传漏洞_57

【复现】用友U8 oa协同工作系统 文件上传漏洞_57

目录 一.概述 二 .漏洞影响 三.漏洞复现 1. 漏洞一&#xff1a; 四.修复建议&#xff1a; 五. 搜索语法&#xff1a; 六.免责声明 一.概述 用友U8 &#xff0d;OA 协同办公管理系统&#xff0c;可把日常业务、事物、协作等信息在企业的各分子公司、部门、群组、个人之间…
阅读更多...
Nginx网络服务四-----日志、Nginx压缩和ssl

Nginx网络服务四-----日志、Nginx压缩和ssl

1.自定义访问日志 如果访问出错---404&#xff0c;可以去看error.log日志信息 访问日志是记录客户端即用户的具体请求内容信息&#xff0c;而在全局配置模块中的error_log是记录nginx服务器运行时的日志保存路径和记录日志的level&#xff0c;因此两者是不同的&#xff0c;而且…
阅读更多...
Linux——简单的Shell程序

Linux——简单的Shell程序

&#x1f4d8;北尘_&#xff1a;个人主页 &#x1f30e;个人专栏:《Linux操作系统》《经典算法试题 》《C》 《数据结构与算法》 ☀️走在路上&#xff0c;不忘来时的初心 文章目录 一、Shell程序思路二、Shell代码展示 一、Shell程序思路 用下图的时间轴来表示事件的发生次序…
阅读更多...
广联达Linkworks GetAllData 信息泄露漏洞复现

广联达Linkworks GetAllData 信息泄露漏洞复现

0x01 产品简介 广联达 LinkWorks（也称为 GlinkLink 或 GTP-LinkWorks）是广联达公司（Glodon）开发的一种BIM（建筑信息模型）协同平台。广联达是中国领先的数字建造技术提供商之一，专注于为建筑、工程和建筑设计行业提供数字化解决方案。 0x02 漏洞概述 广联达-Linkworks…
阅读更多...
QT常用类

QT常用类

五、常用类 QString 字符串类&#xff08;掌握&#xff09; QString是Qt的字符串类&#xff0c;与C的std::string相比&#xff0c; 不再使用ASCII编码。QString使用的是Unicode编码。 QString中每个字符都是一个16位的QChar&#xff0c;而不是8位的char。 QString完全支持中文&…
阅读更多...
2、Web攻防-SQL注入-联合查询注入

2、Web攻防-SQL注入-联合查询注入

用途&#xff1a;个人学习笔记&#xff0c;有所借鉴&#xff0c;欢迎指正&#xff01; 声明&#xff1a;只用于学习交流&#xff0c;点到为止&#xff0c;请勿非法测试。 概念&#xff1a; 联合查询注入&#xff1a;联合注入是回显注入的一种&#xff0c;也就是说联合注入的前…
阅读更多...
解决docker中运行的jar包连不上数据库

解决docker中运行的jar包连不上数据库

目录 数据库主机地址设置问题&#xff1a; 网络连接问题&#xff1a; 数据库端口映射&#xff1a; 数据库认证问题&#xff1a; 数据库服务是否正常运行&#xff1a; 日志查看&#xff1a; 如果在 Docker 中运行的 JAR 包无法连接到数据库&#xff0c;有几个可能的原因和…
阅读更多...
「JavaSE」String类3：字符串常量池

「JavaSE」String类3：字符串常量池

&#x1f387;个人主页&#xff1a;Ice_Sugar_7 &#x1f387;所属专栏&#xff1a;快来卷Java啦 &#x1f387;欢迎点赞收藏加关注哦&#xff01; 字符串常量池 &#x1f349;常量池&#x1f349;字符串常量池&#x1f349;intern 方法 &#x1f349;常量池 在Java程序中&…
阅读更多...
Docker 第十九章 ： 阿里云个人镜像仓使用

Docker 第十九章 ： 阿里云个人镜像仓使用

Docker 第十九章 ： 阿里云个人镜像仓使用 本章知识点： 如何创建镜像库，如何设置密码，如何登录与退出个人镜像仓，如何本地打镜像，如何将本地镜像推送到个人镜像库。 背景 在项目YapiDocker部署中，因读取mongo:latest 版本不一致，导致后续执行步骤的异常。遇到此场景…
阅读更多...
document.cookie中expires 格式设置问题导致部分iphone safari上登录失效

document.cookie中expires 格式设置问题导致部分iphone safari上登录失效

一、问题描述 设备信息&#xff1a;iPhone 12, iOS 16.3 昨天有个小伙伴发现自己的iPhone safari打开网页登录时&#xff0c;登录页面显示登录成功&#xff0c;但实际进入首页后仍然显示未登录。多次测试&#xff0c;该问题在该设备上属于必现问题。 二、问题排查与解决 经过…
阅读更多...
最新文章

Copyright @ 2022~2023

友情链接： 我的编程经验分享 一条长河网 尧图网站开发 尧图建网站