[问答]

怎样去编写linux编程消息队列的写入和读取函数呢

问答对人有帮助，内容完整，我也想知道答案 0 消息队列主要用到两种函数，写入和读取：接收函数： size_t msgrcv(int msqid,void msgp,size_t msgsz,long msgtyp,int msgflg) / 其中： msqid:消息队列的标识码，queen 队列id就是identity 身份 msgp:指向消息缓冲区的指针pointer msgsz:消息的长短size msgtyp:等于0则返回队列最早的一个消息，大于0则返回类型为mtype的一个消息，小于0则返回其类型小于或等于mtype参数的绝对值的最小的一个消息。 msgflg:消息的标志位flag，falg=0则表示忽略，即标志位不起作用返回值：成功则返回数据长度，错误返回-1 / 发送函数 int msgsnd(int msqid,const void msgp,size_t msgsz,int msgflg) /* 其中： msqid:消息队列的标识码，queen 队列id就是identity 身份 msgp:指向消息缓冲区的指针pointer,发送接收可以通用 msgsz:消息的长短size msgflg:消息的标志位flag 返回值：成功则返回0，错误返回-1 / 消息队列标识码获取函数： int msgget(key_t key,int msgflag) / key:消息队列关联的标识符 msgflg:消息队列创建的标志和存取权限其常用IPC_CREAT及IPC_EXCL这两个宏定义作为标识，执行成功则返回消息队列的标识码否则返回-1 / 这里开始放置实际操作代码：首先是接收的： #include #include #include #include #include #include #include #include #include #define MAX_TEXT 512 struct msg_st { long int msg_type; char text[MAX_TEXT]; }; int main() { struct msg_st data; char buffer[BUFSIZ];//8192 set in stdio.h like this / Default buffer size #define BUFSIZ 8192 / int running =1; int msgid=-1; long int msgtyp =0; msgid=msgget((key_t)1234,0666\|IPC_CREAT); if(msgid==-1) { fprintf(stderr,"msgget failed with error:%d n",errno); exit(EXIT_FAILURE); } while(running) { if(msgrcv(msgid,(void)&data,BUFSIZ,msgtyp,0)==-1) { fprintf(stderr,"msgrcv failed with errno :%dn",errno); exit(EXIT_FAILURE); } printf("You write:%sn",data.text); if(strncmp(buffer,"end",3)==0) { running=0; } } if(msgctl(msgid,IPC_RMID,0)==-1) { fprintf(stderr,"remove msgid failed with errno :%dn",errno); exit(EXIT_FAILURE); } else { exit(EXIT_SUCCESS); } } 然后是发送的： #include #include #include #include #include #include #include #include #include #define MAX_TEXT 512 struct msg_st { long int msg_type; char text[MAX_TEXT]; }; int main() { struct msg_st data; char buffer[BUFSIZ];//8192 set in stdio.h like this /* Default buffer size #define BUFSIZ 8192 / int running =1; int msgid=-1; msgid=msgget((key_t)1234,0666\|IPC_CREAT); if(msgid==-1) { fprintf(stderr,"msgget failed with error:%d n",errno); exit(EXIT_FAILURE); } while (running) { printf("enter some text:"); scanf("%s",buffer); //fgets(buffer,BUFSIZ,stdin); data.msg_type =1; stpcpy(data.text,buffer); if(msgsnd(msgid,(void)&data,MAX_TEXT,0)==-1) { fprintf(stderr,"msgsnd failed!n"); exit(EXIT_FAILURE); } if(strncmp(buffer,"end",3)==0) { running=0; } sleep(1); } exit(EXIT_SUCCESS); } 测试方法如下：交叉编译无错误后放在目标系统中先运行接收程序，这里使用后台运行后台运行test ./bin/test & 后台查看是否在运行 jobs 运行成功且查看正在运行无误后，运行发送程序输入你想要发送的代码，回车接收程序自动打出你输入的数据原作者：T触发器 0
2022-5-18 11:51:06　　评论淘帖0 邀请回答您可以邀请以下用户，快速回答问题 × hgimtk 该类别下有 16 个回答。邀请回答 dianzijie5 该类别下有 16 个回答。邀请回答嵌入式-H 该类别下有 16 个回答。邀请回答 hucc 该类别下有 14 个回答。邀请回答舍我其谁84 该类别下有 13 个回答。邀请回答 HCPcry 该类别下有 12 个回答。邀请回答冰箱洗衣机该类别下有 12 个回答。邀请回答学生物的程序猿该类别下有 11 个回答。邀请回答小刘该类别下有 11 个回答。邀请回答 sjjs001 该类别下有 11 个回答。邀请回答 iettke 该类别下有 11 个回答。邀请回答 YOYOOO 该类别下有 10 个回答。邀请回答 bigbangboom 该类别下有 10 个回答。邀请回答 wuli北该类别下有 9 个回答。邀请回答 zengweishuai 该类别下有 9 个回答。邀请回答广州洋钒该类别下有 9 个回答。邀请回答 siyugege 该类别下有 9 个回答。邀请回答 drakannie 该类别下有 9 个回答。邀请回答 ze55me 该类别下有 8 个回答。邀请回答 zhuzb0754 该类别下有 8 个回答。邀请回答举报刘丹相关推荐 • 嵌入式软件的外设初始化函数该怎样去编写呢 1097 • 怎样去编写一个gpio触发的中断驱动代码程序呢 1234 • 怎样去编写外部中断的服务函数呢 965 • 什么是构造函数？怎样去编写构造函数呢 1392 • 请问怎样在linux驱动设备中去使用clk函数呢 770 • FreeRtos中消息队列API的调用该怎样去实现呢 1101 • 怎样去编写Arduino位操作的相关函数呢 856 • 怎样去编写usart.c串口中断处理函数呢 1410 • 怎样去编写一种基于STM32的汇编程序呢 835 • 怎样通过中断检测三个按键状态在读取到不同键值后发送到队列中呢 827