Linux进程间通信之消息队列
消息队列：
使用消息队列的好处：可以给消息附加特定的消息类型。消息队列用于同一台计算机的进程间的通信。
相关的系统函数：
#include <sys/types.h>
#include <sys/ipc.h>
key_t ftok(const char *pathname, int proj_id);
该函数根据文件名生成一个ID，系统建立IPC通讯 （消息队列、信号量和共享内存） 时必须指定一个ID值。
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
int msgget(key_t key, int msgflg);
该函数的作用为：创建一个新的消息队列，或者获取一个已经存在的消息队列
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
int msgsnd(int msqid, const void *msgp, size_t msgsz, int msgflg);
该函数为向消息队列中传输一个消息，其中msqid为消息队列id，msgp为自定义的消息数据类型，msgsz为消息附加信息size，msgflg为消息标志
ssize_t msgrcv(int msqid, void *msgp, size_t msgsz, long msgtyp,
int msgflg);
Msqid为消息队列id；msgp为指向消息数据结构的指针；msgsz为消息数据的长度；
type == 0 返回队列中的第一个消息。
type > 0 返回队列中消息类型为t y p e的第一个消息。
type < 0 返回队列中消息类型值小于或等于t y p e绝对值。
msgflg的值可以设置为IPC_NOWAIT或者0。当设置为IPC_NOWAIT时，若当前队列没有消息，则msgrcv会立即返回；若设置为0，当队列没有消息时，会一直阻塞，直到有了指定的消息或者消息队列被删除了
send.c函数
#include<stdio.h>
#include<stdlib.h>
#include<string.h>
#include<sys/types.h>
#include<sys/ipc.h>
#include<sys/msg.h>
struct my_msg{
long type;
char mtext[512];
};
int main()
{
struct my_msg my_msg;
int msg_id;
key_t key;
key = ftok("/usr/local", 1);
if(key == -1)
key = 1234;
msg_id = msgget(key, IPC_CREAT|0600);
if(msg_id == -1)
{
perror("error msgget\n");
return -1;
}
my_msg.type = 1;
memset(my_msg.mtext, 0, sizeof(my_msg.mtext));
strcpy(my_msg.mtext, "write someting about my_msg.type=1");
if(msgsnd(msg_id, (void *)&my_msg, (size_t)strlen(my_msg.mtext), IPC_NOWAIT))
{
perror("error msgsnd\n");
return -1;
}
system("ipcs -q");
sleep(20);
msgctl(msg_id, IPC_RMID, NULL);
return 0;
}
recv.c函数
#include<stdio.h>
#include<stdlib.h>
#include<string.h>
#include<sys/types.h>
#include<sys/ipc.h>
#include<sys/msg.h>
struct my_msg{
long type;
char mtext[512];
};
int main()
{
struct my_msg my_msg;
int msg_id;
key_t key;
int len;
key = ftok("/usr/local", 1);
if(key == -1)
key = 1234;
msg_id = msgget(key, IPC_CREAT|0600);
if(msg_id == -1)
{
perror("msgget error\n");
return -1;
}
len = msgrcv(msg_id, (void *)&my_msg, sizeof(my_msg.mtext), 0, 0);
if(len ==-1)
{
perror("error msgrcv\n");
}
printf("type is %ld \nmtext is %s\n", my_msg.type, my_msg.mtext);
system("ipcs -q");
sleep(20);
system("ipcs -q");
return 0;
}