## fifo_write.c源码 ![实验楼](https://dn-simplecloud.shiyanlou.com/4241551496586901277-wm) ## fifo_read.c源码 ![实验楼](https://dn-simplecloud.shiyanlou.com/4241551496586957276-wm) ## 编译运行fifo_read.c，创建管道并进入阻塞状态 ![实验楼](https://dn-simplecloud.shiyanlou.com/4241551496586769057-wm) ## 编译运行fifo_write.c，并向管道写入数据 ![实验楼](https://dn-simplecloud.shiyanlou.com/4241551496586784211-wm) 1、msgsnd.c源代码 ![实验楼](https://dn-simplecloud.shiyanlou.com/4241551497196702790-wm) ![实验楼](https://dn-simplecloud.shiyanlou.com/4241551497193702420-wm) ![实验楼](https://dn-simplecloud.shiyanlou.com/4241551497196651952-wm) ![实验楼](https://dn-simplecloud.shiyanlou.com/4241551497196756306-wm)： # msgrcv.c代码注释 ![实验楼](https://dn-simplecloud.shiyanlou.com/4241551497372308669-wm) > 引用文字 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() { int qid; key_t key; struct message msg; // 根据不同的路径和关键字产生标准的 key if ((key = ftok(".", 'a')) == -1){ // 判断key是否生成成功 perror("ftok"); exit(1); } // 如果key对应的消息队列不存在，创建消息队列 if ((qid = msgget(key, IPC_CREAT|0666)) == -1){ // 判断消息队列是否生成成功 perror("msgget"); exit(1); } printf("Open queue %d\n",qid); while(1){ // 持续添加消息到消息队列 printf("Enter some message to the queue:"); // 从stdin中读取数据，每次读取一行保存在msg.msg_text中，每次最多读取BUFFER_SIZE-1个字符 if ((fgets(msg.msg_text, BUFFER_SIZE, stdin)) == NULL){ // 没有读取到数据或者读取错误返回NULL puts("no message"); exit(1); } msg.msg_type = getpid(); // 添加 msg 指向的消息结构到队列ID为 qid 消息队列中，消息大小大小为 msg.msg_text 的长度 if ((msgsnd(qid, &msg, strlen(msg.msg_text), 0)) < 0){ // 判断是否添加成功，成功返回0，失败返回-1 perror("message posted"); exit(1); } if (strncmp(msg.msg_text, "quit", 4) == 0){ // 如果msg.msg_text前4个字符为“quit”则退出循环 break; } } exit(0); } ``` 输入代码 ``` 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() { int qid; key_t key; struct message msg; // 根据不同的路径和关键字产生标准的 key if ((key = ftok(".", 'a')) == -1){ // 判断key是否生成成功 perror("ftok"); exit(1); } // 如果key对应的消息队列不存在，创建消息队列 if ((qid = msgget(key, IPC_CREAT|0666)) == -1){ // 判断消息队列是否生成成功 perror("msgget"); exit(1); } printf("Open queue %d\n", qid); do{ memset(msg.msg_text, 0, BUFFER_SIZE); // 清空 msg.msg_text 的数据 // 取走队列ID为 qid 消息队列中**当前最早的**消息到 msg 指向的缓冲区，消息大小大小为BUFFER_SIZE if (msgrcv(qid, (void*)&msg, BUFFER_SIZE, 0, 0) < 0){ // 判断是否读取成功，成功返回读取的字节数，失败返回-1 perror("msgrcv"); exit(1); } printf("The message from process %d : %s", msg.msg_type, msg.msg_text); } while(strncmp(msg.msg_text, "quit", 4)); // 如果msg.msg_text前4个字符为“quit”则退出循环 // 从系统内核中移走队列ID为 qid 消息队列 if ((msgctl(qid, IPC_RMID, NULL)) < 0){ // 判断是否成功，成功返回0，失败返回-1 perror("msgctl"); exit(1); } exit(0); }

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