#一、管道 ##遇到问题： **程序要需要先运行./fifo_read 否则会出现文件打开错误，也可以在/tmp下手动创建该文件** **原因：没有myfifo管得到文件** ![图片描述](https://dn-simplecloud.shiyanlou.com/uid/423004/1496912375478.png-wm) **编译fifo_read时出现错误memset** **原因：需要添加头文件memory.h** ![图片描述](https://dn-simplecloud.shiyanlou.com/uid/7d3f2bb3bd48090762019cb7a1aef423/1496912633227.png-wm) **实验必须在图形界面打开两个终端** ##实验结果 ![图片描述](https://dn-simplecloud.shiyanlou.com/uid/7d3f2bb3bd48090762019cb7a1aef423/1496912880201.png-wm) ![图片描述](https://dn-simplecloud.shiyanlou.com/uid/7d3f2bb3bd48090762019cb7a1aef423/1496912886969.png-wm) #二、消息队列 ![图片描述](https://dn-simplecloud.shiyanlou.com/uid/7d3f2bb3bd48090762019cb7a1aef423/1496976264619.png-wm) #三、关键代码注解 fifo_write.c ``` /* fifo_write.c */ #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)//判断输入命令的个数小于等于1输出Usage { printf("Usage: ./fifo_write string\n"); exit(1); } sscanf(argv[1], "%s", buff);// 第二个参数存入字符串数组中 /* 以只写阻塞方式打开 FIFO 管道 */ fd = open(MYFIFO, O_WRONLY); //打开管道文件写管道附给文件描述符fd if (fd == -1)//文件描述符-1输出错误信息 { printf("Open fifo file error\n"); exit(1);//退出 } /*向管道中写入字符串*/ if ((nwrite = write(fd, buff, MAX_BUFFER_SIZE)) > 0)//调用写函数 fd文件描述符 buff字符串 MAX_BUFFER_SIZE字节的大小 { printf("Write '%s' to FIFO\n", buff); } close(fd);//关闭文件 exit(0);//退出 } ``` fifo_read.c ``` /*fifo_read.c*/ #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))//access=-1时创建管道文件权限为666并且errno判断文件bu不存在 { printf("Cannot create fifo file\n");//否则打印文件不存在 exit(1);//退出 } } /* 以只读阻塞方式打开有名管道 */ fd = open(MYFIFO, O_RDONLY);//打开管道文件写管道附给文件描述符fd if (fd == -1))//文件描述符-1输出错误信息 { printf("Open fifo file error\n"); exit(1); } while (1)//无限循环 { memset(buff, 0, sizeof(buff));//内存清零 if ((nread = read(fd, buff, MAX_BUFFER_SIZE)) > 0)//读取fd描述符里的neir { printf("Read '%s' from FIFO\n", buff);//读取后打印出来 } } close(fd);//关闭文件 exit(0);//退出 } ``` msgsnd.c ``` /* msgsnd.c */ #include #include #include #include #include #include #include #include #define BUFFER_SIZE 512 struct message//定义message结构体 { long msg_type;//定义长整型消息类型 char msg_text[BUFFER_SIZE];//定义消息内容 }; int main() { int qid; key_t key;//定义消息队列的键值 struct message msg;定义message类型的结构体msg /*根据不同的路径和关键字产生标准的 key*/ if ((key = ftok(".", 'a')) == -1)//ftok函数产生键值附给key判断如果等于-1 { perror("ftok");//把一个描述性错误消息输出 exit(1);//退出 } /*创建消息队列*/ if ((qid = msgget(key, IPC_CREAT|0666)) == -1)、*创建消息队列 IPC_EXCL:表示如果要创建的消息队列已经存在，则返回错误权限666*/ { perror("msgget")；//如果qid=-1输出错误信息 exit(1);//退出 } printf("Open queue %d\n",qid); while(1)//无限循环 { printf("Enter some message to the queue:"); if ((fgets(msg.msg_text, BUFFER_SIZE, stdin)) == NULL)//如果内容为空 { puts("no message"); //向终端输出 exit(1);//退出 } msg.msg_type = getpid();//调用结构体msg中的msg_type，把消息进程识别码附给它 /*添加消息到消息队列*/ if ((msgsnd(qid, &msg, strlen(msg.msg_text), 0)) < 0)//将消息写入队列 { perror("message posted");//输出错误信息 exit(1);//退出 } if (strncmp(msg.msg_text, "quit", 4) == 0)//比较函数若输入信息为quit时执行break退出 { break;// } } exit(0);//退出 } ``` msgrcv.c ``` /* msgrcv.c */ #include #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)//生成键值如果为-1输出错误信息 { perror("ftok"); exit(1); //退出 } /*创建消息队列*/ if ((qid = msgget(key, IPC_CREAT|0666)) == -1)//创建消息队列权限666如果返回值为-1输出错误信息退出 { perror("msgget");//输出错误信息 exit(1);//退出 } printf("Open queue %d\n", qid); do { /*读取消息队列*/ memset(msg.msg_text, 0, BUFFER_SIZE);//清零 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));//比较函数若输入信息为quit时执行break退出 /*从系统内核中移走消息队列 */ if ((msgctl(qid, IPC_RMID, NULL)) < 0)//从系统内核中移走消息队列,如果不能复制内部缓冲区，调用进程将返回-1 { perror("msgctl");//输出错误信息 exit(1);//退出 } exit(0);//退出 } ```

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