#一、fifo有名管道 ##1、fifo_write和fifo_read的编译 ![图片描述](https://dn-simplecloud.shiyanlou.com/uid/425407/1496457815806.png-wm) ![图片描述](https://dn-simplecloud.shiyanlou.com/uid/425407/1496457821756.png-wm) ##2、 fifo的运行 ###写运行在只有一个参数的时候运行如下 ![图片描述](https://dn-simplecloud.shiyanlou.com/uid/425407/1496457907532.png-wm) ### 写运行正确运行 ![图片描述](https://dn-simplecloud.shiyanlou.com/uid/425407/1496457985277.png-wm) ##3、fifo写代码如下 ``` #include #include #include #include #include #include #define MYFIFO "/tmp/myfifo" //有名管道名称 #define MAX_BUFFER_SIZE PIPE_BUF #include int main(int argc,char *argv[]){ int fd;//定义文件描述符 char buff[MAX_BUFFER_SIZE];//定义一个字符型buff数组存放缓冲 int nwrite;//定义写变量 if(argc <=1){ printf("usage:./fifo_write string\n"); exit(1); }//如果主函数里的变量只有一个./fifo_write时会打印出错误并退出 sscanf(argv[1],"%s",buff);//输入的字符串都存放在buff里 printf("argc = %d\n",argc);//主函数参数的个数 printf("argv0 = %s\n",argv[0]); printf("argv1 = %s\n",argv[1]); fd = open(MYFIFO,O_WRONLY);//以只写阻塞的方式打开管道 if(fd ==-1){ printf("open fifo file error\n"); exit(1); }//文件描述符返回值为-1时，打开有名管道失败 if((nwrite = write(fd,buff,MAX_BUFFER_SIZE))>0){ printf("write '%s' to fifo\n",buff); }// 写入MAX_BUFFER_SIZE长度到buff里 close(fd);//关闭文件描述符 exit(0); } ``` ##4、fifo读代码如下 ``` #include #include #include #include #include #include #define MYFIFO "/tmp/myfifo" #define MAX_BUFFER_SIZE PIPE_BUF int main(){ char buff[MAX_BUFFER_SIZE];//定义buff数组，长度MAX_BUFFER_SIZE int fd;//定义文件描述符 int nread;//定义读函数 if(access(MYFIFO, F_OK)==-1) { if((mkfifo(MYFIFO,0666)<0)&&(errno != EEXIST)){ printf("Cnnot create fifo file\n"); exit(1); } }//如果进入管道文件的权限是-1（失败）时，并且创建管道文件权限<0或者管道存在时输出创建管道失败。 fd = open(MYFIFO,O_RDONLY);//只读阻塞方式打开管道 if(fd ==-1){ printf("open fifo file error \n"); exit(1); } while(1) { memset(buff,0,sizeof(buff));//将已经开辟内存空间的buff中buff个字节设置为0 if((nread = read(fd,buff,MAX_BUFFER_SIZE))>0){ printf("read '%s' from fifo\n",buff); } }//读管道的死循环 close(fd); exit(0); } ``` ##5、实验结果 ![图片描述](https://dn-simplecloud.shiyanlou.com/uid/425407/1496473578822.png-wm) #二、消息队列 ##1、msgsnd与msgrcv的编译![实验楼](https://dn-simplecloud.shiyanlou.com/4254071496473733427-wm) ##2、消息队列的运行![实验楼](https://dn-simplecloud.shiyanlou.com/4254071496473823492-wm) ##3、 msgsnd代码如下： ``` #include #include #include #include #include #include #include #define BUFFER_SIZE 512 //定义512长度的BUFFER_SIZE内存空间 struct message{ long msg_type; char msg_text[BUFFER_SIZE]; };//定义一个结构体，里面有两个参数，一个是长整型的msg_type，另一个是字符串数组msg_text int main(){ int qid; key_t key; struct message msg; if((key = ftok(".","a"))==-1){ perror("ftok"); exit(1); }//建立通信时通过ftok得到一个进程键值，如果是-1就输出错误 if((qid = msgget(key,IPC_CREAT|0666)) == -1)//msgget函数包括消息队列键值和权限，0666表示所有都是有读写权限 { perror("msgget"); exit(1); }//如果msgget得到的消息队列键值是-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();//获得消息队列ID if((msgsnd(qid,&msg,strlen(msg.msg_text),0))<0){ perror("message posted"); exit(1); }//将写内容添加到消息队列里 if(strncmp(msg.msg_text,"quit",4)==0){ break; }//如果输入的字符串是quit就终止循环 }//死循环一直执行上述内容 exit(0); } ``` ##4、msgrcv代码如下： ``` #include #include #include #include #include #include #include #define BUFFER_SIZE 512 //顶底BUFFER_SIZE长度512的内存空间 struct message{ long msg_type; char msg_text[BUFFER_SIZE]; };//定义一个结构体里面两个参数 int main(){ int qid;//定义队列ID key_t key;//定义一个键值变量 struct message msg; if((key = ftok(".","a"))==-1){ perror("ftok"); exit(1); }//通过ftok获得一个键值 if((qid = msgget(key,IPC_CREAT|0666))==-1){ perror("msgget"); exit(1); }//如果队列ID是-1就输出错误退出 printf("open queue %d\n",qid); do{ memset(msg.msg_text,0,BUFFER_SIZE);//将内存空间中msg.text清0 if(msgrcv(qid,(void*)&msg,BUFFER_SIZE,0,0)<0){ perror("msgrcv"); exit(1); }//如果读消息函数的返回值是-1就输出错误退出 printf("the message from process %d :%s",msg.msg_type,msg.msg_text); }while(strncmp(msg.msg_text,"quit",4));//当读出的消息是quit时就退出循环，否则继续读 if((msgctl(qid,IPC_RMID,NULL))<0){ perror("msgctl"); exit(1); }//从系统内核中移出消息队列，如果返回值是-1就移出失败 exit(0);//执行了所有之后退出程序 } ```

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