实验五 进程通信-管道通信

news2025/1/6 21:56:44

1. 函数int pipe(int fd[2])创建一个管道，管道两端可分别用描述字fd[0]以及fd[1]来描述。需要注意的是，管道的两端是固定了任务的。即一端只能用于读，由描述字fd[0]表示，称其为管道读端；另一端则只能用于写，由描述字fd[1]来表示，称其为管道写端。下面给出的程序使用系统调用pipe()建立一条管道线，两个子进程p1和p2分别向管道各写一句话：child1 is sending a message!和child2 is sending a message!，父进程则从管道中读出来自子进程的信息，并显示在屏幕上。请读懂程序并调试运行。

#include <unistd.h>
#include <signal.h>
#include <stdio.h>
#include<stdlib.h>
int pid1, pid2;
int main() {
	int fd[2];
	int pid1, pid2;
	char OutPipe[100], InPipe[100];

	pipe(fd);

	while ((pid1 = fork()) == -1);
	if (pid1 == 0) {
		printf("child process1 %d\n", getpid());
		lockf(fd[1], 1, 0);
		sprintf(OutPipe, "child1 is sending a message!");
		write(fd[1], OutPipe, 50);
		sleep(5);
		lockf(fd[1], 0, 0);
		exit(0);
	}
	else {
		while ((pid2 = fork()) == -1);
		if (pid2 == 0) {
			printf("child process2 % d\n", getpid());
			lockf(fd[1], 1, 0);
			sprintf(OutPipe, "child2 is sending a message!");
			write(fd[1], OutPipe, 50);
			sleep(5);
			lockf(fd[1], 0, 0);
			exit(0);
		}
		else {
			printf("parent process %d\n", getpid());
			wait(0);
			read(fd[0], InPipe, 50);
			printf("%s\n", InPipe);
			wait(0);
			read(fd[0], InPipe, 50);
			printf("%s\n", InPipe);
			exit(0);
		}
	}
}

阅读并运行程序并回答以下问题：
问题1：该程序中使用的管道是有名管道还是无名管道？程序中红色部分的含义是什么？
无名管道。锁定管道的写入端，从当前位置开始锁定。
问题2：程序的含义是什么？运行结果是什么？为什么？
这段代码创建了两个子进程，并使用管道来实现进程间通信。
运行结果：
在这里插入图片描述
出现该运行结果可能的原因是：
• 在程序运行时，两个子进程之间没有竞争管道写入权的情况发生。
• 在程序运行时，第一个子进程比第二个子进程先写入管道。

2.使用管道通信时，可关闭某些不需要的读或写描述符，建立起单向的读或写管道，然后用read和write像操作文件一样去操作它。下面给出的程序中子进程通过管道向父进程发送数据，这里子进程只使用到管道的写端口fd[1]、父进程使用到了fd[0]，因此可关闭子进程的fd[0]和父进程的fd[1]。请通过程序体会。

#include<sys/types.h> 
#include<unistd.h> 
#include<stdio.h> 
#include<stdlib.h> 
#include<errno.h> 
#include<memory.h>  
int main()
{
    char* msg = "I am child process!";
    /*子进程发送的数据*/
    pid_t pid;
    char buf[100];
    /*用于读取*/
    int pi;
    /*创建管道时的返回值*/
    int fd[2];
    /*创建管道的参数*/

    memset(buf, 0, sizeof(buf));
    /*设置buf数组全为0，需*/
    pi = pipe(fd);         					/*要引入#include<memory.h>*/
    if (pi < 0)
    {
        perror("pipe() error!");
        exit(0);
    }
    if ((pid = fork()) == 0)
        /*child process*/
    {
        close(fd[0]);
        /*关闭读管道*/
        if (write(fd[1], msg, 20) != -1)
            /*写入管道*/
            printf("child process write success!\n");
        close(fd[1]);
        /*关闭写管道*/
    }
    else if (pid > 0)					/*parent process*/
    {
        close(fd[1]);
        /*关闭写管道*/
        sleep(2);
        /*休眠一下等待数据写入*/
        if (read(fd[0], buf, 100) > 0)/*写入管道*/
            printf("Message from the pipe is:%s\n", buf);
        close(fd[0]);/*关闭读管道*/
        waitpid(pid, NULL, 0);
        /*待pid进程退出，此处pid为子进程*/
        exit(0);
    }
    else
    {
        perror("fork() error!");
        exit(0);
    }
}

在这里插入图片描述

3.普通管道只能用于一个进程家族之间的通信，如父子，兄弟之间，并且普通管道在于内存中，随着进程的结束而消失；而命名管道是有“名字”的管道，存在于磁盘上，作为一个特殊的设备文件而存在，不会随着进程结束而消失。有名管道可用于两个无关的进程之间的通信，实现函数是mkfifo()。下面的程序实例演示了mkfifo的使用。请先以超级用户身份登录系统，然后编辑/编译源程序（两个*.c程序），在图形终端上执行读程序readfifo.c，读程序执行后将陷入循环；切换到字符终端1（ctrl+alt+f1），以超级用户身份登录并执行写程序writefifo.c，然后回到图形终端，观察读程序的输出变化。

readfifo.c:

#include<sys/types.h> 
#include<unistd.h> 
#include<stdio.h> 
#include<stdlib.h> 
#include<errno.h> 
#include<fcntl.h> 
#include<sys/stat.h> 
#include<memory.h> 
#define FIFO "/home/ghj/myfifo" /*使用宏定义路径*/ 

int main()
{
    int fd;/*指向命名管道*/
    char buf[100];/*存储数据*/

    if (mkfifo(FIFO, O_CREAT | O_EXCL) < 0) /*创建管道*/
    {
        perror("Create error!\n");
        unlink(FIFO);/*清除管道*/
        exit(0);
    }
    fd = open(FIFO, O_RDONLY | O_NONBLOCK, 0);/*打开管道*/
    if (fd < 0) {
        perror("Create error!\n");
        unlink(FIFO);
        exit(0);
    }
    while (1) {
        memset(buf, 0, sizeof(buf));/*清空buf数组*/
        if (read(fd, buf, 100) > 0)/*读取管道*/
        {
            printf("Get message:%s\n", buf);
        }
        else {
            printf("Not accept any message!\n");
        }
        sleep(1);/*休眠*/
    }
}

writefifo.c:

#include<sys/types.h> 
#include<unistd.h> 
#include<stdio.h> 
#include<stdlib.h> 
#include<errno.h> 
#include<fcntl.h> 
#include<sys/stat.h> 
#define FIFO "/home/ghj/myfifo"/*宏定义命名管道路径*/ 

int main()
{
    char* msg = "Some message!";/*发送数据*/
    int fd;

    fd = open(FIFO, O_WRONLY | O_NONBLOCK, 0);/*打开*/
    if (write(fd, msg, 20) != -1)/*写信息*/
        printf("Message have been send to FIFO\n");
    exit(0);
}

本地运行结果出了点问题，这里就不展示运行结果图了。

4.编写两个程序client.c和server.c，分别用于消息的发送和接收。

client.c:

#include <stdio.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/msg.h>
#include <sys/ipc.h>
#define MSGKEY 75
struct msgform{
    long mtype;
    char mtext[1000];
}msg;
int msgqid;
void client(){
    int i;
    msgqid = msgget(MSGKEY, 0777);      /*打开75#消息队列*/
    for (i = 10; i >= 1; i--){
        msg.mtype = i;
        printf("(client)sent\n");
        msgsnd(msgqid, &msg, 1024, 0);    /*发送消息*/
    }
    exit(0);
}
int main(){
    client();

    return 0;
}

server.c:

#include <stdio.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/msg.h>
#include <sys/ipc.h>
#define MSGKEY 75
struct msgform{
    long mtype;
    char mtext[1000];
}msg;
int msgqid;
void server(){
    msgqid = msgget(MSGKEY, 0777 | IPC_CREAT);   /*创建75#消息队列*/
    do{
        msgrcv(msgqid, &msg, 1030, 0, 0);         /*接收消息*/
        printf("(server)received\n");
    } while (msg.mtype != 1);
    msgctl(msgqid, IPC_RMID, 0);     /*删除消息队列，归还资源*/
    exit(0);
}
int main(){
    server();
    
    return 0;
}

建议该题目的运行方法为：
将上述两个程序分别编译为server和client，并按以下方式执行：
./server & /*当在前台运行某个作业时，终端被该作业占据；而在后台运行作业时，它不会占据终端。可以使用&命令把作业放到后台执行。该命令的一般形式为：命令&*/
ipcs –q /* 输出有关信息队列(message queue)的信息*/
./client

阅读并运行程序并回答以下问题：
问题1：运行结果是什么？该程序为什么需要在后台运行server.c？若不如此会出现什么现象？为什么？
在这里插入图片描述
将服务器程序放在后台运行，会在客户端程序发送消息之前已经启动并创建了消息队列。如果不这样做，客户端程序可能会尝试打开一个不存在的消息队列，从而导致程序出错。
如果不将服务器程序放在后台运行，客户端程序可能会在服务器程序启动之前就尝试打开消息队列，导致错误。
问题2：两个程序的含义是什么？请解释其运行结果的含义？
server.c 和 client.c 两个程序分别实现了一个服务器和一个客户端，它们之间通过消息队列进行通信。
运行结果的含义是，服务器程序和客户端程序之间已经成功建立了连接，并且客户端程序已经发送了 10 条消息，服务器程序已经接收到了这些消息。

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

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

相关文章

我失业了？| ChatGPT生信分析初体验

我失业了？| ChatGPT生信分析初体验

最近ChatGPT火的一塌糊涂&#xff0c;作为在生物医学和计算机科学领域夹缝求生的边缘摇摆人&#xff0c;也来蹭一波热度。ChatGPT是一个预训练的语言模型&#xff0c;由OpenAI训练。它可以用来生成自然语言文本&#xff0c;并且可以进行对话。它基于Transformer架构&#xff0c…
阅读更多...
OAuth2.0的四种授权方式

OAuth2.0的四种授权方式

前言 OAuth 简单理解就是一种授权机制&#xff0c;它是在客户端和资源所有者之间的授权层&#xff0c;用来分离两种不同的角色。在资源所有者同意并向客户端颁发令牌后&#xff0c;客户端携带令牌可以访问资源所有者的资源。 OAuth2.0 是 OAuth 协议的一个版本&#xff0c;有…
阅读更多...
【计算机毕业设计】77.旅游资源网站源码

【计算机毕业设计】77.旅游资源网站源码

一、系统截图&#xff08;需要演示视频可以私聊&#xff09; 摘 要 本论文主要论述了如何使用JAVA语言开发一个旅游资源网站 &#xff0c;本系统将严格按照软件开发流程进行各个阶段的工作&#xff0c;采用B/S架构&#xff0c;面向对象编程思想进行项目开发。在引言中&#xf…
阅读更多...
MATLB|分布式能源的选址与定容IEEE30节点实现

MATLB|分布式能源的选址与定容IEEE30节点实现

&#x1f4a5;&#x1f4a5;&#x1f4a5;&#x1f49e;&#x1f49e;&#x1f49e;欢迎来到本博客❤️❤️❤️&#x1f4a5;&#x1f4a5;&#x1f4a5;&#x1f3c6;博主优势&#xff1a;&#x1f31e;&#x1f31e;&#x1f31e;博客内容尽量做到思维缜密&#xff0c;逻辑清…
阅读更多...
Jmeter(四)：请求默认值元件应用，模拟http请求实战，正则表达式提取器元件讲解

Jmeter(四)：请求默认值元件应用，模拟http请求实战，正则表达式提取器元件讲解

Jmeter(7)&#xff1a;jmeter请求默认值元件应用 HTTP请求默认值 在公司内部进行测试的时候&#xff0c;一般测试环境访问的接口地址&#xff08;服务器名称 或IP&#xff09;、端口、协议一般都是不变的&#xff0c;但http请求取样器每个请求都要求写一遍 这些信息&#xff0…
阅读更多...
购物网站系统

购物网站系统

视频如下 go网站前台:关于我们、联系我们、公告信息、商品类型、商品信息、商品评论管理员: 1、管理关于我们、联系我们 2、增删改查公告类型、公告信息 3增删改查商品类型、商品信息 4、查看注册用户信息 5、查看用户充值信息 6、查看回复用户咨询 7、查看下单信息 8、发货、查…
阅读更多...
微信支付API3 APP【统一下单 APIV3】

微信支付API3 APP【统一下单 APIV3】

官方参考资料 签名&#xff1a;签名生成-接口规则 | 微信支付商户平台文档中心 签名生成&#xff1a;签名生成 - WechatPay-API-v3 统一下单接口&#xff1a;微信支付-开发者文档 如何查看证书序列号&#xff1a;证书相关 - WechatPay-API-v3 私钥和证书&#xff1a;私钥和…
阅读更多...
EXCEL基础：数据透视表（按年龄分组统计与统计各部门的工资情况）

EXCEL基础：数据透视表（按年龄分组统计与统计各部门的工资情况）

【按年龄分组进行统计】&#xff1a; 如下为原始数据&#xff0c;最后就是年龄字段&#xff1a; 选择数据单元格&#xff0c;在新表里插入【数据透视表】&#xff0c;若数据透视表的【字段列表】没有显示&#xff0c;可以按照1标注那里勾选&#xff0c; 按照2处的列、行和统计…
阅读更多...
Pytorch:使用官网提供数据集的相关参数设置，以CIFAR10为例进行说明

Pytorch:使用官网提供数据集的相关参数设置，以CIFAR10为例进行说明

文章目录前言一、Dataset定义-组成分类二、获取数据集1.参数说明2.相关Demo前言 本文记录笔者关于Dataset的相关学习记录&#xff0c;以Pytorch官网文档为主进行学习 一、Dataset 定义-组成 所谓Dataset&#xff0c;指的是我们在学习神经网络中要接触的数据集&#xff0c;一…
阅读更多...
[附源码]Python计算机毕业设计SSM基于的楼盘销售系统的设计与实现（程序+LW)

[附源码]Python计算机毕业设计SSM基于的楼盘销售系统的设计与实现（程序+LW)

项目运行 环境配置&#xff1a; Jdk1.8 Tomcat7.0 Mysql HBuilderX&#xff08;Webstorm也行&#xff09; Eclispe&#xff08;IntelliJ IDEA,Eclispe,MyEclispe,Sts都支持&#xff09;。 项目技术&#xff1a; SSM mybatis Maven Vue 等等组成&#xff0c;B/S模式 M…
阅读更多...
关于近期虚拟化学习遇到的问题总结

关于近期虚拟化学习遇到的问题总结

一、关于Intel VT-x/EPT. 不使用虚拟化的Intel VT-x/EPT 因为需要在Linux中使用kvm做虚拟化因此需要开放宿主虚拟机的虚拟权限 但是打开报错 首先想要开启虚拟化&#xff0c;你的cpu是一定要支持虚拟化的 如何查看呢&#xff0c;可以ctrlaltdel打开任务管理器 点击性能 可以看…
阅读更多...
电子加速器原理与应用

电子加速器原理与应用

辐射单位 射线能量ϵ\epsilonϵ&#xff0c;单位eVeVeV ϵhν\epsilon h\nuϵhν&#xff0c;普朗克常数hhh&#xff0c;电磁波频率ν\nuν 电子伏特eVeVeV&#xff1a;一个电子&#xff08;电量为1.610C&#xff09;经过1VVV的电位差加速后获得的动能。 1eV1.610−19J1.610−…
阅读更多...
计及碳捕集电厂低碳特性的含风电电力系统源–荷多时间尺度调度方法（Matlab代码实现）

计及碳捕集电厂低碳特性的含风电电力系统源–荷多时间尺度调度方法（Matlab代码实现）

&#x1f4a5;&#x1f4a5;&#x1f49e;&#x1f49e;欢迎来到本博客❤️❤️&#x1f4a5;&#x1f4a5; &#x1f3c6;博主优势&#xff1a;&#x1f31e;&#x1f31e;&#x1f31e;博客内容尽量做到思维缜密&#xff0c;逻辑清晰&#xff0c;为了方便读者。 ⛳️座右铭&a…
阅读更多...
[附源码]Python计算机毕业设计SSM基于的楼盘销售管理系统（程序+LW)

[附源码]Python计算机毕业设计SSM基于的楼盘销售管理系统（程序+LW)

项目运行 环境配置&#xff1a; Jdk1.8 Tomcat7.0 Mysql HBuilderX&#xff08;Webstorm也行&#xff09; Eclispe&#xff08;IntelliJ IDEA,Eclispe,MyEclispe,Sts都支持&#xff09;。 项目技术&#xff1a; SSM mybatis Maven Vue 等等组成&#xff0c;B/S模式 M…
阅读更多...
Java基本微信小程序的适老化老人健康预警系统 springboot+vue

Java基本微信小程序的适老化老人健康预警系统 springboot+vue

随着信息技术和网络技术的飞速发展&#xff0c;人类已进入全新信息化时代&#xff0c;传统管理技术已无法高效&#xff0c;便捷地管理信息。为了迎合时代需求&#xff0c;优化管理效率&#xff0c;各种各样的管理系统应运而生&#xff0c;各行各业相继进入信息管理时代&#xf…
阅读更多...
LinkedList（Java8）个人理解

LinkedList（Java8）个人理解

问题&#xff1a;LinkedList 的 Node 怎么理解&#xff1f; Node 是 LinkedList 的私有静态内部类&#xff0c;作为链表结构的基本元素&#xff0c;可以看作是链条上的一个节&#xff08;结&#xff09;点。一个 node 对象中除了存储元素的值外&#xff0c;还存储着前一个 nod…
阅读更多...
【软件测试】测试员vs测试工程师，你是测试员还是测试工程师？

【软件测试】测试员vs测试工程师，你是测试员还是测试工程师？

目录&#xff1a;导读前言一、Python编程入门到精通二、接口自动化项目实战三、Web自动化项目实战四、App自动化项目实战五、一线大厂简历六、测试开发DevOps体系七、常用自动化测试工具八、JMeter性能测试九、总结&#xff08;尾部小惊喜&#xff09;前言 不是什么时候&#…
阅读更多...
[Java] 序列化（Serialization）的本质是什么？在Java中怎么实现？为什么要了解序列化技术？序列化技术选型要点是什么？

[Java] 序列化（Serialization）的本质是什么？在Java中怎么实现？为什么要了解序列化技术？序列化技术选型要点是什么？

文章目录前言序列化是什么&#xff1f;理解对象在内存中是如何存储的数据在进程内存中的分布图数据被序列化之后在内存中的分布图序列化/反序列化的本质&#xff1f;序列化在Java中的实现&#xff1f;1. JDK Serialization&#xff08;不推荐使用&#xff09;2. 第三方实现&…
阅读更多...
本地完成Vue脚手架和Django建立连接

本地完成Vue脚手架和Django建立连接

目录 在Vue中 setting.py中&#xff1a; urls.py中 首先把要连接的Django项目和Vue脚手架创建好 之后我们把整个Vue拖到Django的文件夹根目录下&#xff0c;于manage.py同级即可&#xff08;图中data-work为我的Vue&#xff09; 在Vue中 进入到vue.config.js文件夹下 添加as…
阅读更多...
全栈Jmeter接口测试(三)：jmeter利用察看结果树查看响应调试取样器(Debug Sampler)，设置HTTP信息头管理器模拟请求头

全栈Jmeter接口测试(三)：jmeter利用察看结果树查看响应调试取样器(Debug Sampler)，设置HTTP信息头管理器模拟请求头

Jmeter(5)&#xff1a;jmeter利用察看结果树查看响应&调试取样器(Debug Sampler) 察看结果树选项介绍&#xff1a; 名称&#xff1a;本属性用于标识一个察看结果树元件&#xff0c;建议使用一个有意义的名称 注释&#xff1a;对于测试没有任何作用&#xff0c;仅用户记录用…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023