**第一项** 有名管道部分 1.完成写入代码并编译 ![实验楼](https://dn-simplecloud.shiyanlou.com/4312421497328741768-wm) 2.输出结果 ![实验楼](https://dn-simplecloud.shiyanlou.com/4312421497328889525-wm) fifo_write代码及注释 ``` #include #include #include #include #include #include #include #include #define MYFIFO "/tmp/myfifo" 管道文件名 #define MAX_BUFFER_SIZE PIPE_BUF 定义在于 limits.h 中 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); 保存上一步输入的参数 fd = open(MYFIFO, O_WRONLY); 仅能写入的阻塞方式打开管道 if (fd == -1){ 判断管道是否打开成功 printf("Open fifo file error\n"); exit(1); } 向文件描述符为 fd 的管道中写入 buff 指向的缓冲区字符串 if ((nwrite = write(fd, buff, MAX_BUFFER_SIZE)) > 0){ //nwrite 此部为写入文档的字节数 printf("Write '%s' to FIFO\n", buff); } close(fd); exit(0); } ``` fifo_read代码及注释 ``` #include #include #include #include #include #include #include #include #define MYFIFO "/tmp/myfifo" 管道文件名 #define MAX_BUFFER_SIZE PIPE_BUF 定义在于 limits.h int main() { char buff[MAX_BUFFER_SIZE]; int fd; int nread; 判断有名管道是否已存在，若没有则创建 if (access(MYFIFO, F_OK) == -1){ 判断MYFIFO文件是否存在 if ((mkfifo(MYFIFO, 0666) < 0) && (errno != EEXIST)){ 确定mkfifo是否创建成功以及函数是否出错 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){ 持续读取管道信息 memset(buff, 0, sizeof(buff)); 清空buff数据 if ((nread = read(fd, buff, MAX_BUFFER_SIZE)) > 0){ nread为读取文档的字节数成功或者出错 printf("Read '%s' from FIFO\n", buff); } } close(fd); exit(0); } ``` **第二** 消息队列运行结果如下 ![实验楼](https://dn-simplecloud.shiyanlou.com/4312421497332525260-wm) msgsnd代码及注释 ``` #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); } 如果消息队列不存在创建消息队列 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中读取数据 if ((fgets(msg.msg_text, BUFFER_SIZE, stdin)) == NULL){ 没有读取到数据或者读取错误返回NULL puts("no message"); exit(1); } msg.msg_type = getpid(); 添加msg到队列ID为qid中 if ((msgsnd(qid, &msg, strlen(msg.msg_text), 0)) < 0){ 判断是否添加成功 perror("message posted"); exit(1); } if (strncmp(msg.msg_text, "quit", 4) == 0){ 如果msg.msg_text前4个字符为quit则退出循环 break; } } exit(0); } ``` msgrcv代码及注释 ``` #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 消息队列中 if (msgrcv(qid, (void*)&msg, BUFFER_SIZE, 0, 0) < 0){ 判断是否读取成功 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); } ```

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