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 "）; 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 "）; 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 "）; return -1; } len = msgrcv（msg_id, （void *）&my_msg, sizeof（my_msg.mtext）, 0, 0）; if（len ==-1） { perror（"error msgrcv "）; } printf（"type is %ld mtext is %s ", my_msg.type, my_msg.mtext）; system（"ipcs -q"）; sleep（20）; system（"ipcs -q"）; return 0;}