##一、fifo_write.c和fifo_read.c ###1、fifo_write.c源代码 ![实验楼](https://dn-simplecloud.shiyanlou.com/4249781496448631542-wm) ###2、fifo_read.c源代码 ![实验楼](https://dn-simplecloud.shiyanlou.com/4249781496449332414-wm) ###3、编译运行fifo_read.c，创建管道并进入阻塞状态 ![实验楼](https://dn-simplecloud.shiyanlou.com/4249781496449422707-wm) ###4、编译运行fifo_write.c，并向管道写入数据 ![实验楼](https://dn-simplecloud.shiyanlou.com/4249781496449626669-wm) ###5、fifo_read读出管道数据 ![实验楼](https://dn-simplecloud.shiyanlou.com/4249781496449709881-wm) ###6、fifo_read.c代码注释 ``` /*fifo_read.c*/ #include #include #include #include #include #include #include // 有名管道的路径及文件名 #define MYFIFO "/tmp/myfifo" // 定义读取字符串的最大长度，数值在 limits.h 中 #define MAX_BUFFER_SIZE PIPE_BUF int main() { // 定义缓冲区、文件名描述符和读取函数返回值 char buff[MAX_BUFFER_SIZE]; int fd; int nread; // 判断有名管道是否已存在，若尚未创建，则以相应的权限创建 if (access(MYFIFO, F_OK) == -1) { // 以 rw-rw-rw- 的权限创建有名管道，若失败，则提示并退出函数 if ((mkfifo(MYFIFO, 0666) < 0) && (errno != EEXIST)) { printf("Cannot create fifo file\n"); exit(1); } } // 以只读阻塞方式打开有名管道 fd = open(MYFIFO, O_RDONLY); if (fd == -1) { printf("Open fifo file error\n"); exit(1); } // 无限读取管道中内容 while (1) { // 初始化缓冲区，将缓冲区用0填充，清零 memset(buff, 0, sizeof(buff)); // 用指定的格式读取管道中的数据，若失败，则提示并退出函数 if ((nread = read(fd, buff, MAX_BUFFER_SIZE)) > 0) { printf("Read '%s' from FIFO\n", buff); } } // 关闭管道 close(fd); exit(0); } ``` ###7、fifo_write.c代码注释 ``` /* fifo_write.c */ #include #include #include #include #include #include #include // 有名管道的路径及文件名 #define MYFIFO "/tmp/myfifo" // 定义输入字符串的最大长度，数值在 limits.h 中 #define MAX_BUFFER_SIZE PIPE_BUF // 参数为即将写入的字符串 int main(int argc, char * argv[]) { // 定义文件描述符、缓冲区和写入函数的返回值 int fd; char buff[MAX_BUFFER_SIZE]; int nwrite; // 判断是否输入字符串，没有则提示并退出函数 if(argc <= 1) { printf("Usage: ./fifo_write string\n"); exit(1); } // 从字符串中读进与指定格式相符的数据并格式化输入 sscanf(argv[1], "%s", buff); // 以只写阻塞方式打开FIFO 管道 fd = open(MYFIFO, O_WRONLY); // 判断管道是否成功打开 if (fd == -1) { printf("Open fifo file error\n"); exit(1); } // 向管道中写入字符串 if ((nwrite = write(fd, buff, MAX_BUFFER_SIZE)) > 0) { printf("Write '%s' to FIFO\n", buff); } // 关闭管道 close(fd); exit(0); } ``` ##二、msgsnd.c和msgrcv.c ###1、msgsnd.c源代码 ![实验楼](https://dn-simplecloud.shiyanlou.com/4249781496451074901-wm) ###2、msgrcv.c源代码 ![实验楼](https://dn-simplecloud.shiyanlou.com/4249781496451645837-wm) ###3、编译运行msgsnd.c，创建消息队列并写入数据 ![实验楼](https://dn-simplecloud.shiyanlou.com/4249781496451785506-wm) ###4、编译运行msgrcv.c，读取消息队列中的数据 ![实验楼](https://dn-simplecloud.shiyanlou.com/4249781496451863808-wm) ###5、msgsnd.c代码注释 ``` /* msgsnd.c */ #include #include #include #include #include #include #include // 定义消息正文长度大小 #define BUFFER_SIZE 512 // 定义消息结构 struct message { // 定义消息类型 long msg_type; // 定义消息正文 char msg_text[BUFFER_SIZE]; }; int main() { // 定义消息队列 ID 变量、键值变量、消息名称 int qid; key_t key; struct message msg; // 根据不同的路径和关键字产生标准的key，若失败，则报错并退出函数 if ((key = ftok(".", 'a')) == -1) { perror("ftok"); exit(1); } // 以 rw-rw-rw- 权限创建消息队列，若失败，报错并退出函数 if ((qid = msgget(key, IPC_CREAT|0666)) == -1) { perror("msgget"); exit(1); } // 提示成功打开消息队列 printf("Open queue %d\n",qid); // 无限循环输入字符串，直到输入 quit 停止 while(1) { printf("Enter some message to the queue:"); // 如果获取的字符串为空，报错并退出函数 if ((fgets(msg.msg_text, BUFFER_SIZE, stdin)) == NULL) { puts("no message"); exit(1); } // 获取信息队列的 ID msg.msg_type = getpid(); // 添加消息到消息队列 if ((msgsnd(qid, &msg, strlen(msg.msg_text), 0)) < 0) { perror("message posted"); exit(1); } // 检测输入的字符串是否为 quit ，若是，则退出循环 if (strncmp(msg.msg_text, "quit", 4) == 0) { break; } } exit(0); } ``` ###6、msgrcv.c代码注释 ``` /* msgrcv.c */ #include #include #include #include #include #include #include // 定义消息正文长度大小 #define BUFFER_SIZE 512 // 定义消息结构 struct message { // 定义消息类型 long msg_type; // 定义消息正文 char msg_text[BUFFER_SIZE]; }; int main() { // 定义消息队列 ID 变量、键值变量、消息名称 int qid; key_t key; struct message msg; // 根据不同的路径和关键字产生标准的key，若失败，则报错并退出函数 if ((key = ftok(".", 'a')) == -1) { perror("ftok"); exit(1); } // 以 rw-rw-rw- 权限创建消息队列，若失败，报错并退出函数 if ((qid = msgget(key, IPC_CREAT|0666)) == -1) { perror("msgget"); exit(1); } // 提示成功打开消息队列 printf("Open queue %d\n", qid); // 无限读取消息队列，直到检测到 quit 终止循环 do { // 初始化缓冲区，将缓冲区用0填充，清零 memset(msg.msg_text, 0, BUFFER_SIZE); // 读取指定信息队列 ID 中的信息 if (msgrcv(qid, (void*)&msg, BUFFER_SIZE, 0, 0) < 0) { perror("msgrcv"); exit(1); } // 将读取的信息的信息队列 ID 和信息正文输出 printf("The message from process %d : %s", msg.msg_type, msg.msg_text); } while(strncmp(msg.msg_text, "quit", 4)); // 从系统内核中移走消息队列，若失败，则报错并退出函数 if ((msgctl(qid, IPC_RMID, NULL)) < 0) { perror("msgctl"); exit(1); } exit(0); } ```

“嵌入式系统程序设计”实验报告