1. Toy模板网首页
  2. >Toy博客

《嵌入式系统开发实践》实验三 进程通信

1年前作者：okfang616分类：Toy博客阅读(41)违法举报

这篇具有很好参考价值的文章主要介绍了《嵌入式系统开发实践》实验三 进程通信。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

一、 实验目的

  1. 掌握无名管道与有名管道的进程通信；
  2. 掌握消息队列的读写操作；
  3. 掌握共享内存的通信机制。

二、 实验任务与要求

  1. 管道读写程序的编写与应用；
  2. 消息队列的发送和接收程序的编写和应用；
  3. 共享内存的创建、连接和分离编程和应用。

三、 实验工具和环境
PC机、Linux Ubuntu操作系统。
四、 实验内容与结果

  1. 利用无名管道通信编写程序实现命令cat的功能。
    7.2.1-1
    《嵌入式系统开发实践》实验三 进程通信 
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/wait.h>
#include <fcntl.h>

int main(int argc, char **argv)
{
    // printf("%d", argc);
    if (argc < 2)
    {
        printf("argv lost\n");
        exit(0);
    }
    int fd[2];
    int err = pipe(fd);
    if (err == -1)
    {
        printf("pipe err\n");
        exit(0);
    }
    pid_t pid = fork();
    if (pid == -1)
        exit(0);
    else if (pid == 0)
    {
        close(fd[1]);
        char buf[256] = {0};
        int size = read(fd[0], buf, 256);

        if (size > 0)
            printf("son --- %s\n", buf);
        else
            printf("son read err\n");

        close(fd[0]);
        exit(0);
    }
    else if (pid > 0)
    {
        close(fd[0]);
        int fd2, size2;
        char buf2[256];
        fd2 = open(argv[1], O_RDONLY);
        if (fd2)
        {
            size2 = read(fd2, buf2, 256);
            write(fd[1], buf2, 256);
        }
        close(fd2);
        sleep(5);
        close(fd[1]);
        wait(NULL);
        exit(0);
    }
}

《嵌入式系统开发实践》实验三 进程通信
这段代码实现了一个简单的管道通信，父进程通过读取文件内容，将数据写入管道，子进程从管道中读取数据并打印。其中使用了fork创建子进程，pipe创建管道，open函数打开文件，read和write函数进行读写操作。程序在父进程中使用wait函数等待子进程退出。

  1. 设计两个程序：有名管道的读程序和写程序，要求利用有名管道实现聊天程序，每次发言后自动在后面增加当前系统时间。增加结束字符，比如最后输入“886”后结束进程。

写程序

#include <sys/types.h>
#include <sys/stat.h>
#include <unistd.h>
#include <errno.h>
#include <string.h>
#include <stdio.h>
#include <stdlib.h>
#include <fcntl.h>
#include <limits.h>
#include <time.h>

int main(void)
{
    int fd;
    int len;
    char buf[PIPE_BUF];
    time_t tp;
    printf("I am %d\n", getpid());
    if ((fd = open("fifo1", O_RDWR)) < 0)
    {
        perror("open");
        exit(EXIT_FAILURE);
    }

    while (1)
    {
        time(&tp);
        printf("\n[%d]请输入文字：", getpid());
        char text[256];
        fgets(text, (sizeof text / sizeof text[0]), stdin);
        if (strcmp(text, "886\n") == 0)
        {
            printf("\n886!\n");
            close(fd);
            exit(EXIT_SUCCESS);
        }
        len = sprintf(buf, "-[%d]: %s%s", getpid(), text, ctime(&tp));
        if ((write(fd, buf, len)) < 0)
        {
            perror("write");
            close(fd);
            exit(EXIT_FAILURE);
        }
        sleep(3);
    }
    close(fd);
    exit(EXIT_SUCCESS);
}

读程序

#include <sys/types.h>
#include <sys/stat.h>
#include <unistd.h>
#include <errno.h>
#include <stdio.h>
#include <stdlib.h>
#include <fcntl.h>
#include <limits.h>
#include <time.h>

int main(void)
{
    int fd;
    int len;
    char buf[PIPE_BUF];
    mode_t mode = 0666;
    system("rm fifo1 > null");
    if ((mkfifo("fifo1", mode)) < 0)
    {
        perror("mkfifo");
        exit(EXIT_FAILURE);
    }
    if ((fd = open("fifo1", O_RDONLY)) < 0)
    {
        perror("open");
        exit(EXIT_FAILURE);
    }

    while ((len = read(fd, buf, PIPE_BUF)) > 0)
    {
        printf("%s", buf);
    }
    close(fd);
    exit(EXIT_SUCCESS);
}

《嵌入式系统开发实践》实验三 进程通信

这两段代码是一个进程间通信的例子，使用了命名管道（FIFO）来实现。第一个程序是写程序，不断从命令行读取用户输入的文字，将其和当前时间一起发送到命名管道中。第二个程序是读程序，不断从命名管道中读取数据并输出到控制台。通过命名管道，实现了两个进程之间的通信。其中，mkfifo函数用于创建命名管道，open函数用于打开命名管道，read和write函数用于读写数据，close函数用于关闭文件描述符。

  1. 设计一个程序，要求用函数msgget创建消息队列，从键盘输入的字符串添加到消息队列，然后应用函数msgrcv读取队列中的消息并在计算机屏幕上输出。程序先调用msgget函数创建、打开消息队列，接着调用msgsnd函数，把输入的字符串添加到消息队列中，然后调用msgrcv函数，读取消息队列中的消息并打印输出，最后调用msgctl函数，删除系统内核中的消息队列。
// q3reader.c
#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <errno.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
struct my_msg_st
{

	long int my_msg_type;
	char some_text[BUFSIZ];
};
int main(void)
{

	int running = 1;
	int msgid;
	struct my_msg_st some_data; // 定义消息变量
	long int msg_to_receive = 0;
	msgid = msgget((key_t)1234, 0666 | IPC_CREAT);
	if (msgid == -1)
	{
		fprintf(stderr, "msgget failed with error: %d\n", errno);
		exit(EXIT_FAILURE);
	}
	/*创建消息队列*/
	/*循环从消息队列中接收消息*/
	while (running)
	{
		/*读取消息*/
		if (msgrcv(msgid, (void *)&some_data, BUFSIZ, msg_to_receive, 0) == -1)
		{
			fprintf(stderr, "msgrcv failed with error: %d\n", errno);
			exit(EXIT_FAILURE);
		}
		printf("You wrote: %s", some_data.some_text);
		/*接收到的消息为“end”时结束循环*/
		if (strncmp(some_data.some_text, "end", 3) == 0)
		{
			running = 0;
		}
	}
	/*从系统内核中移走消息队列*/
	if (msgctl(msgid, IPC_RMID, 0) == -1)
	{
		fprintf(stderr, "msgctl(IPC_RMID) failed\n");
		exit(EXIT_FAILURE);
	}
	exit(EXIT_SUCCESS);
}


// q3writer.c 
#include <stdlib.h>
#include <errno.h>
#include <unistd.h>
#include <sys/types.h>
#include <stdio.h>
#include <string.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#define MAX_TEXT 512
struct my_msg_st
{

	long int my_msg_type;
	char some_text[MAX_TEXT];
};
int main(void)
{
	int running = 1;
	struct my_msg_st some_data;
	int msgid;
	char buffer[BUFSIZ];
	/*创建消息队列*/
	msgid = msgget((key_t)1234, 0666 | IPC_CREAT);
	if (msgid == -1)
	{
		fprintf(stderr, "msgget failed with error:%d\n", errno);
		exit(EXIT_FAILURE);
	}
	while (running)
	{ /*循环向消息队列中添加消息*/
		printf("Enter some text:");
		fgets(buffer, BUFSIZ, stdin); // 从标准输入文件读取字符串赋给buffer
		some_data.my_msg_type = 1;
		strcpy(some_data.some_text, buffer); // buffer的内容复制给消息
		/*添加消息*/
		if (msgsnd(msgid, (void *)&some_data, MAX_TEXT, 0) == -1)
		{
			fprintf(stderr, "msgsed failed\n");
			exit(EXIT_FAILURE);
		}
		/*用户输入的为“end”时结束循环*/
		if (strncmp(buffer, "end", 3) == 0)
		{
			running = 0;
		}
	}
	exit(EXIT_SUCCESS);
}

《嵌入式系统开发实践》实验三 进程通信

这两段代码分别实现了消息队列的读和写操作。其中，q3reader.c创建了一个消息队列，并通过循环从中接收消息，如果接收到的消息为“end”，则结束程序；而q3writer.c循环向消息队列中添加消息，如果用户输入的消息为“end”，则结束程序。两段代码都使用了结构体my_msg_st来定义消息，其包含了消息类型my_msg_type和消息内容some_text。在创建/添加消息的时候，需要使用msgsnd/mssgrcv函数，并将my_msg_st作为参数传递进去。同时，需要使用msgget函数获取消息队列的ID，并使用msgctl函数移走消息队列。

  1. 设计两个程序要求用消息队列实现简单的聊天功能。
// q3reader.c
#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <errno.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
struct my_msg_st
{

	long int my_msg_type;
	char some_text[BUFSIZ];
};
int main(void)
{

	int running = 1;
	int msgid;
	struct my_msg_st some_data; // 定义消息变量
	long int msg_to_receive = 0;
	msgid = msgget((key_t)1234, 0666 | IPC_CREAT);
	if (msgid == -1)
	{
		fprintf(stderr, "msgget failed with error: %d\n", errno);
		exit(EXIT_FAILURE);
	}
	/*创建消息队列*/
	/*循环从消息队列中接收消息*/
	while (running)
	{
		/*读取消息*/
		if (msgrcv(msgid, (void *)&some_data, BUFSIZ, msg_to_receive, 0) == -1)
		{
			fprintf(stderr, "msgrcv failed with error: %d\n", errno);
			exit(EXIT_FAILURE);
		}
		printf("You wrote: %s", some_data.some_text);
		/*接收到的消息为“end”时结束循环*/
		if (strncmp(some_data.some_text, "end", 3) == 0)
		{
			running = 0;
		}
	}
	/*从系统内核中移走消息队列*/
	if (msgctl(msgid, IPC_RMID, 0) == -1)
	{
		fprintf(stderr, "msgctl(IPC_RMID) failed\n");
		exit(EXIT_FAILURE);
	}
	exit(EXIT_SUCCESS);
}


// q3writer.c 
#include <stdlib.h>
#include <errno.h>
#include <unistd.h>
#include <sys/types.h>
#include <stdio.h>
#include <string.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#define MAX_TEXT 512
struct my_msg_st
{

	long int my_msg_type;
	char some_text[MAX_TEXT];
};
int main(void)
{
	int running = 1;
	struct my_msg_st some_data;
	int msgid;
	char buffer[BUFSIZ];
	/*创建消息队列*/
	msgid = msgget((key_t)1234, 0666 | IPC_CREAT);
	if (msgid == -1)
	{
		fprintf(stderr, "msgget failed with error:%d\n", errno);
		exit(EXIT_FAILURE);
	}
	while (running)
	{ /*循环向消息队列中添加消息*/
		printf("Enter some text:");
		fgets(buffer, BUFSIZ, stdin); // 从标准输入文件读取字符串赋给buffer
		some_data.my_msg_type = 1;
		strcpy(some_data.some_text, buffer); // buffer的内容复制给消息
		/*添加消息*/
		if (msgsnd(msgid, (void *)&some_data, MAX_TEXT, 0) == -1)
		{
			fprintf(stderr, "msgsed failed\n");
			exit(EXIT_FAILURE);
		}
		/*用户输入的为“end”时结束循环*/
		if (strncmp(buffer, "end", 3) == 0)
		{
			running = 0;
		}
	}
	exit(EXIT_SUCCESS);
}
  1. 在主程序中先调用shmget函数创建一个共享内存，得到共享内存的id，然后利用shmat函数将创建的共享内存连接到一个进程的地址空间，返回值为该内存空间的地址指针，利用地址指针对共享内存进行访问；最后利用shmdt函数分离进程和共享内存。
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/shm.h>
#include <stdlib.h>
#include <stdio.h>
#include <unistd.h>
#define BUFSZ 4096
int main(int argc, char *argv[])
{
    int shm_id;
    char *shm_buf;
    key_t key;
    system("touch shmfile");
    // 生成一个共享内存段的唯一键
    key = ftok("shmfile", 65);
    if (key == -1)
    {
        perror("ftok");
        exit(1);
    }
    // 用键和共享内存段的大小创建一个共享内存段并获取它的 ID
    shm_id = shmget(key, BUFSZ, 0666 | IPC_CREAT);
    if (shm_id < 0)
    {
        perror("shmget");
        exit(1);
    }
    printf("successfully created segment: %d \n", shm_id);
    // 将共享内存段连接到进程地址空间并获取一个指向它的指针
    if ((shm_buf = shmat(shm_id, NULL, 0)) == (char *)-1)
    {
        perror("shmat");
        exit(1);
    }
    printf("segment attached at %p\n", shm_buf);
    system("ipcs -m");
    sleep(3); /*休眠*/
    // 将共享内存段从进程地址空间分离
    if ((shmdt(shm_buf)) < 0)
    {
        perror("shmdt");
        exit(1);
    }
    printf("segment detached \n");
    system("ipcs -m "); /*再次查看系统IPC状态*/
    // 删除共享内存段
    if (shmctl(shm_id, IPC_RMID, NULL) == -1)
    {
        perror("shmctl");
        exit(1);
    }
    printf("segment removed \n");
    system("ipcs -m "); /*再次查看系统IPC状态*/
    exit(0);
}

《嵌入式系统开发实践》实验三 进程通信

这段代码演示了创建、连接、分离、删除共享内存段的过程。首先使用ftok函数生成一个共享内存段的唯一键，然后使用shmget函数创建一个共享内存段并获取它的ID。接着使用shmat函数将共享内存段连接到进程地址空间并获取一个指向它的指针。然后可以使用shm_buf指针来读写共享内存段。当不需要使用共享内存段时，可以使用shmdt函数将它从进程地址空间分离。最后使用shmctl函数删除共享内存段并释放它的系统资源。在代码中还使用了system函数调用ipcs命令来查看系统中的IPC状态。

  1. 编写生产者、消费者程序。

（1） 消费者程序中创建一个共享内存段，并将其中的内容显示出来；

消费者程序：

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/shm.h>

#define SHM_SIZE 1024  // 共享内存大小
#define SHM_KEY 1234   // 共享内存键值

int main()
{
    int shmid;
    char *shmaddr;

    // 连接到已有的共享内存段并获取其地址
    shmid = shmget(SHM_KEY, SHM_SIZE, 0666);
    if (shmid == -1) {
        perror("shmget");
        exit(1);
    }

    shmaddr = (char *)shmat(shmid, NULL, 0);
    if (shmaddr == (char *)(-1)) {
        perror("shmat");
        exit(1);
    }

    printf("Content of shared memory:\n%s", shmaddr);  // 显示共享内存中的内容

    // 断开共享内存连接
    shmdt(shmaddr);

    return 0;
}

（2） 生产者连接到一个已有的共享内存段，并允许向其中写入数据。

生产者程序：

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/shm.h>

#define SHM_SIZE 1024  // 共享内存大小
#define SHM_KEY 1234   // 共享内存键值

int main()
{
    int shmid;
    char *shmaddr;
    char buffer[256];

    // 创建共享内存段
    shmid = shmget(SHM_KEY, SHM_SIZE, IPC_CREAT | 0666);
    if (shmid == -1) {
        perror("shmget");
        exit(1);
    }

    // 连接到共享内存段并获取其地址
    shmaddr = (char *)shmat(shmid, NULL, 0);
    if (shmaddr == (char *)(-1)) {
        perror("shmat");
        exit(1);
    }

    while (1) {
        printf("Enter message: ");
        fgets(buffer, sizeof(buffer), stdin);
        strncpy(shmaddr, buffer, SHM_SIZE);  // 写入共享内存
    }
    
    // 断开共享内存连接
    shmdt(shmaddr);
    
    // 删除共享内存段
    shmctl(shmid, IPC_RMID, NULL);
    return 0;
}

《嵌入式系统开发实践》实验三 进程通信
生产者程序使用 shmget() 函数创建了一个大小为 SHM_SIZE 的共享内存段，并使用 shmat() 函数将其连接到进程的虚拟地址空间，从而获取其地址指针 shmaddr。然后通过 fgets() 函数从标准输入读取字符串，再使用 strncpy() 将其写入共享内存中。这个过程循环执行，直到程序结束。最后使用 shmdt() 断开共享内存连接，使用 shmctl() 删除共享内存段。

消费者程序先使用 shmget() 函数连接到已有的共享内存段，并使用 shmat() 函数将其连接到进程的虚拟地址空间，从而获取其地址指针 shmaddr。然后通过 printf() 打印共享内存中的内容。最后使用 shmdt() 断开共享内存连接。

五、 实验总结文章来源地址https://www.toymoban.com/news/detail-466175.html

到了这里，关于《嵌入式系统开发实践》实验三 进程通信的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处： 如若内容造成侵权/违法违规/事实不符，请点击违法举报进行投诉反馈，一经查实，立即删除！

分享到：
领支付宝红包赞助服务器费用

相关文章

  • 嵌入式系统实验报告实验一 GPIO 口控制LED 实验

    嵌入式系统实验报告实验一 GPIO 口控制LED 实验

    1 实验目的 1.） 了解并掌握如何控制 STM32 的 GPIO； 2.） 掌握控制 LED 的电路原理和程序代码； 2 实验环境 1.） 硬件：1 个空气温湿度传感器模块、1 个 ST-Link 调试器、1 根USB2.0 方口线、1根USB3.0 数据线、1 台PC 机； 2.） 软件：Windows 10、MDK 集成开发环境。 3 实验功能 实现LED灯依

    2024年02月01日
    浏览(37)

  • 合肥工业大学嵌入式系统原理实验报告

    ✅作者简介：CSDN内容合伙人、信息安全专业在校大学生🏆 🔥系列专栏 ： 📃新人博主 ：欢迎点赞收藏关注，会回访！ 💬舞台再大，你不上台，永远是个观众。平台再好，你不参与，永远是局外人。能力再大，你不行动，只能看别人成功！没有人会关心你付出过多少努力，

    2024年02月07日
    浏览(38)
  • [嵌入式系统-32]：RT-Thread -17- 任务、进程、线程的区别

    [嵌入式系统-32]：RT-Thread -17- 任务、进程、线程的区别

    目录 一、基本概念澄清 1.1 任务 1.2 进程 1.3 线程 1.4 比较 1.5 任务VS进程 1.6 进程 VS 线程 1.7 任务 进程 线程 发展历史 任务（Task）： 进程（Process）： 线程（Thread）： 发展趋势： 二、不同操作系统中任务、进程、线程 2.1 Linux：没人任务，只有进程与线程 进程相关函数： 线程

    2024年02月21日
    浏览(9)
  • 嵌入式Linux裸机开发（七）UART串口、IIC、SPI通信

    嵌入式Linux裸机开发（七）UART串口、IIC、SPI通信

    大概学完这三种通信后，之后就先去学系统移植，其他的先暂时放下 串口全称叫做串行接口，通常也叫做 COM 接口。 UART：（Universal Asynchronous Receiver/Trasmitter）通用异步串行收发器。 USART：（Universal Synchronous/Asynchronous Receiver/Transmitter）通用同步/异步串行收发器，相比 UART多了

    2024年02月07日
    浏览(37)
  • 【嵌入式操作系统】实验2：GPIO编程及应用

    【嵌入式操作系统】实验2：GPIO编程及应用

    熟悉STM32 模块的GPIO硬件连接； 掌握GPIO初始化配置； 掌握GPIO控制板上LED灯编程； 熟练KEIL 工程的配置，编译，调试，下载。 操作系统：WINDOWS 10 开发工具：Keil 4，UartAssists 实验设备：125K RFID读写器模块、JLink在线调试器、电源、PC   运行程序后，LED灯D7、D8按照全熄灭、亮

    2024年02月09日
    浏览(10)
  • 关于嵌入式开发的一些信息汇总：嵌入式C开发人员、嵌入式系统Linux

    关于嵌入式开发的一些信息汇总：嵌入式C开发人员、嵌入式系统Linux

    这篇文章是关于嵌入式开发的一些基本信息，供想入行的人参考。有一些作者本人的想法，以及来自外网的大拿的文章翻译而来，原文链接在此Learning Linux for embedded systems，再次感谢，支持原创。 普通C开发人员和嵌入式C开发人员之间的 基本区别在于 ，因为嵌入式C程序被设

    2024年02月03日
    浏览(51)
  • 飞凌嵌入式i.MX9352嵌入式ARM开发板，让通信安全又稳定——EMC防护，静电、浪涌、脉冲4级防护能力

    飞凌嵌入式i.MX9352嵌入式ARM开发板，让通信安全又稳定——EMC防护，静电、浪涌、脉冲4级防护能力

    随着新基建的加快推进，智能制造迎来了更好的发展时机，嵌入式板卡等智能设备也在更多的应用场景中大放异彩。但随着现场的设备数量的剧增，环境中的各种干扰信号也随之增加，这就对设备间通信的安全性与稳定性提出了更高的要求。 强磁、强电以及大功率设备所产生

    2024年02月13日
    浏览(37)
  • 嵌入式系统中MCU与SoC通信方式的选择与应用

    嵌入式系统中MCU与SoC通信方式的选择与应用

    在探讨嵌入式系统中微控制器单元（MCU）和系统级芯片（SoC）之间的通信方式之前，让我们先对嵌入式系统的核心概念进行深入了解。嵌入式系统是一种专用的计算系统，它被设计来执行或支持特定的功能或任务。这些系统通常嵌入在更大的设备中，如家电、汽车、工业机器

    2024年01月21日
    浏览(12)
  • 【嵌入式开发】开发板设置系统时间

    【嵌入式开发】开发板设置系统时间

    时钟包括硬件时钟和系统时钟，系统时钟就是linux系统显示的时间，用命令 date 可以显示当前系统时间；硬件时钟就是硬件自身的时间了。它们两者没有关系的，但是可以通过命令设置系统时钟和硬件设置，让它们同步。 Linux系统ARM架构开发板、Xshell软件 date 命令查看系统时

    2024年02月11日
    浏览(10)
  • 通信工程毕设 Stm32酒驾检查系统 - 单片机 嵌入式 物联网

    通信工程毕设 Stm32酒驾检查系统 - 单片机 嵌入式 物联网

    🔥 这两年开始毕业设计和毕业答辩的要求和难度不断提升，传统的毕设题目缺少创新和亮点，往往达不到毕业答辩的要求，这两年不断有学弟学妹告诉学长自己做的项目系统达不到老师的要求。 为了大家能够顺利以及最少的精力通过毕设，学长分享优质毕业设计项目，今天

    2024年02月19日
    浏览(284)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包，优惠每天领

二维码1

领取红包

二维码2

领红包