嵌入式Linux--进程间通讯--消息队列

1.需要知道的问题：

1、如何创建消息队列（A\B使用同一个队列通信）

2、如何加消息到队列（队列是链表）

3、如何从队列拿到消息

消息队列：

消息队列，是消息的链接表，存放在内核中。一个消息队列由一个标识符（即队列ID）来标识。

特点：1、消息队列是面向记录的，其中的消息具有特定的格式以及特定的优先级。

2、消息队列独立于发送与接收进程。进程终止时，消息队列及其内容不会被删除。

3、消息队列可以实现消息的随机查询，消息不一定要以先进先出的次序读取，也可以按消息的类型读取。

A:①获取队列②读队列

B:①获取队列②写队列

2.相关函数

#include <sys/msg.h>

//创建或打开消息队列：成功返回队列id，失败返回-1
int msgget(key_t key, int flag);

//添加消息：成功返回0，失败返回-1
int msgsnd(int msgid, const void *ptr, size_t size, int flag);

//读取消息：成功返回消息数据的长度，失败返回-1
int msgrcv(int msgid, void *ptr, size_t size, long type, int flag);

//控制消息队列：成功返回0，失败返回-1
int msgctl(int msgid, int cmd, struct msgid_ds *buf);

ftok函数：

系统建立IPC通讯（消息队列、信号量和共享内存）时必须指定一个id值。通常情况下，该id值通过ftok函数得到。

ftok原型

#include <sys/types.h>
#include <sys/ipc.h>

key_t ftok(const char *pathname, int id);

//使用
key_t key;
key=ftok(".",1);//将pathname设为当前目录
//id是子序号。int型，但是只使用8bit（1-255）

消息队列的移除：

msgctl(msgid,IPC_RMID,NULL);

一般要在结尾加上移除。

3.代码：

get.c


#include <sys/msg.h>
#include <stdio.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <string.h>//创建或打开消息队列：成功返回队列id，失败返回-1
//int msgget(key_t key, int flag);//添加消息：成功返回0，失败返回-1
//int msgsnd(int msgid, const void *ptr, size_t size, int flag);//读取消息：成功返回消息数据的长度，失败返回-1
//int msgrcv(int msgid, void *ptr, size_t size, long type, int flag);//控制消息队列：成功返回0，失败返回-1
//int msgctl(int msgid, int cmd, struct msgid_ds *buf);struct msgbuf{long mtype;char mtext[99];};int main()
{struct msgbuf sendbuf= {35,"thank your message from get"};;struct msgbuf readbuf ;key_t key;key = ftok(".",66);printf("key = %d\n",key);int msgid = msgget(key,IPC_CREAT|0777);if(msgid == -1){printf("id creat failure\n");}msgrcv(msgid,&readbuf,sizeof(readbuf.mtext),25,0);printf("rcv from send :%s\n",readbuf.mtext);sleep(5);msgsnd(msgid,&sendbuf,strlen(sendbuf.mtext),0);msgctl(msgid,IPC_RMID,NULL);return 0;
}

send.c

#include <sys/msg.h>
#include <stdio.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <string.h>//创建或打开消息队列：成功返回队列id，失败返回-1
//int msgget(key_t key, int flag);//添加消息：成功返回0，失败返回-1
//int msgsnd(int msgid, const void *ptr, size_t size, int flag);//读取消息：成功返回消息数据的长度，失败返回-1
//int msgrcv(int msgid, void *ptr, size_t size, long type, int flag);//控制消息队列：成功返回0，失败返回-1
//int msgctl(int msgid, int cmd, struct msgid_ds *buf);struct msgbuf{long mtype;char mtext[99];};int main()
{struct msgbuf sendbuf = {25,"this message is from sendbuf"};struct msgbuf readbuf;key_t key;key = ftok(".",66);printf("key = %d\n",key);int msgid = msgget(key,IPC_CREAT|0777);if(msgid == -1){printf("id creat failure\n");}msgsnd(msgid,&sendbuf,strlen(sendbuf.mtext),0);msgrcv(msgid,&readbuf,sizeof(readbuf.mtext),35,0);printf("rcv from get :%s\n",readbuf.mtext);msgctl(msgid,IPC_RMID,NULL);return 0;
}

结果：