步骤：在fifo_read头文件中加入string.h ![图片描述](https://dn-simplecloud.shiyanlou.com/uid/425042/1497272034726.png-wm) 运行结果： ![图片描述](https://dn-simplecloud.shiyanlou.com/uid/425042/1497272053431.png-wm) ![图片描述](https://dn-simplecloud.shiyanlou.com/uid/425042/1497272053690.png-wm) ![图片描述](https://dn-simplecloud.shiyanlou.com/uid/38b571f7bdcac4642cede2d208b7524a/1497347240550.png-wm) 代码注释：fifo_write #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); /* 以只写阻塞方式打开 FIFO 管道 */ /*open函数第一个参数为待打开/创建文件的路径名第二个参数为用于指定文件的打开/创建模式 O_RDONLY 只读模式 O_WRONLY 只写模式 O_RDWR 读写模式 */ fd = open(MYFIFO, O_WRONLY); if (fd == -1) { printf("Open fifo file error\n"); exit(1); } /*向管道中写入字符串*/ /*write函数第一个参数为 fd：要进行写操作的文件描述词。第二个参数buff：需要输出的缓冲区第三个参数MAX_BUFFER_SIZE：最大输出字节计数 */ if ((nwrite = write(fd, buff, MAX_BUFFER_SIZE)) > 0) { printf("Write '%s' to FIFO\n", buff); } close(fd); exit(0); } fifo_read:#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; /* 判断有名管道是否已存在，若尚未创建，则以相应的权限创建*/ /* access()函数会检查是否可以读/写某一已存在的文件。*/ if (access(MYFIFO, F_OK) == -1) { if ((mkfifo(MYFIFO, 0666) < 0) && (errno != EEXIST)) /*mkfifo()会依参数pathname建立特殊的FIFO文件，该文件必须不存在，而参数mode为该文件的权限（mode%~umask），因此 umask值也会影响到FIFO文件的权限。Mkfifo()建立的FIFO文件其他进程都可以用读写一般文件的方式存取返回值*/ { printf("Cannot create fifo file\n"); exit(1); } } /* 以只读阻塞方式打开有名管道 */ /*open函数第一个参数为待打开/创建文件的路径名第二个参数为用于指定文件的打开/创建模式 O_RDONLY 只读模式 O_WRONLY 只写模式 O_RDWR 读写模式 */ fd = open(MYFIFO, O_RDONLY); if (fd == -1) { printf("Open fifo file error\n"); exit(1); } while (1) { /*memset函数将s所指向的某一块内存中的每个字节的内容全部设置为ch指定的ASCII值, 块的大小由第三个参数指定,这个函数通常为新申请的内存做初始化工作, 其返回值为指向S的指针*/ memset(buff, 0, sizeof(buff)); /*read函数从参数fd指定的文件中读取数据到大小为MAX_BUFFER_SIZE的缓存buff中，然后返回读取的实际读取到的字节数*/ if ((nread = read(fd, buff, MAX_BUFFER_SIZE)) > 0) { printf("Read '%s' from FIFO\n", buff); } } close(fd); exit(0); } 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); } // 如果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：

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