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;

}