Linux 消息队列

感觉Linux消息队列跟什么pipe、socket差不多，都是发信息的。只不过这个是以一截一截的形式来发，而且还可以跟发的这个“截”起一个类型（type）编号。可以取指定类型的最前端的消息。

而消息具体到代码就是一个数据结构

struct msgtype { 
    long mtype; 
    char buffer[BUFFER]; 
};

这个数据结构是自定义的。但是你自己可以更改的地方也就是BUFFER这个值罢了。消息的格式就是一个消息类型（type）和消息内容。

1.

那个ftok函数，按我的理解，他就是要产生一个key值而已，而这个文件地址参数，只是随便拿来用的而已。但是两个进程中用的这个文件地址要对应噢。其实就是想取这个文件的inode中的值而已。其返回值一般是取fname的索引节点号，然后加上id。

2.

 ssize_t msgrcv(int msqid, void *msgp, size_t msgsz, long msgtyp, int msgflg);

这个是接受消息的函数，第三个参数size_t msgsz，指的是 “消息内容” 的字长数，而不是整个消息的长度！！！这里特别强调。

下面是一个小例子：一个server， 一个client

//server.c

#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <errno.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <sys/stat.h>

#define   MSG_FILE "msgserver.c" 
#define   BUFFER 255 
#define   PERM S_IRUSR|S_IWUSR 
/* 服务端创建的消息队列最后没有删除,我们要使用ipcrm命令来删除的 */
/* ipcrm -q <msqid> */

struct msgtype { 
    long mtype; 
    char buffer[BUFFER+1]; 
};

int main() 
{ 
    struct msgtype msg; 
    key_t key; 
    int msgid; 
    
    if((key=ftok(MSG_FILE,'a'))==-1) 
    { 
        fprintf(stderr,"Creat Key Error:%s\n", strerror(errno)); 
        exit(1); 
    }

    if((msgid=msgget(key, PERM|IPC_CREAT|IPC_EXCL))==-1) 
    {
        fprintf(stderr, "Creat Message Error:%s\n", strerror(errno)); 
        exit(1);
    } 
    printf("msqid = %d\n", msgid);
    while(1)
    { 
        //取类型为1的消息
        msgrcv(msgid, &msg, BUFFER + 1, 1, 0); 
        fprintf(stderr,"Server Receive:%s\n", msg.buffer); 
        msg.mtype = 2; 
        strcpy(msg.buffer + strlen(msg.buffer), "\nthis is sent by server.\n\0");
        msgsnd(msgid, &msg, BUFFER + 1, 0); 
    } 
    exit(0); 
}

//client
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <errno.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <sys/stat.h>
#include <unistd.h>

#define   MSG_FILE "msgserver.c" 
#define   BUFFER 255 
#define   PERM S_IRUSR|S_IWUSR

struct msgtype { 
    long mtype; 
    char buffer[BUFFER+1]; 
};

int main(int argc, char **argv) 
{ 
    struct msgtype msg; 
    key_t key; 
    int msgid; 
    
    if(argc != 2) 
    { 
        fprintf(stderr,"Usage:%s string/n", argv[0]); 
        exit(1); 
    } 
    
    if((key=ftok(MSG_FILE,'a'))==-1) 
    { 
        fprintf(stderr,"Creat Key Error:%s/n", strerror(errno)); 
        exit(1); 
    } 
    
    if((msgid=msgget(key, PERM))==-1) 
    { 
        fprintf(stderr,"Creat Message  Error:%s/n", strerror(errno)); 
        exit(1); 
    } 
    
    msg.mtype = 1; 
    strncpy(msg.buffer, argv[1], BUFFER); 
    msgsnd(msgid, &msg, BUFFER + 1, 0);  
    memset(&msg, '\0', sizeof(struct msgtype)); 
    msgrcv(msgid, &msg, BUFFER + 1, 2, 0); 
    fprintf(stderr, "Client receive:%s\n", msg.buffer); 
    exit(0);
}   

具体可以看下面几个比较好的链接，我参考的下面的：

http://blog.csdn.net/zhsp1029/article/details/2171462/

http://www.cnblogs.com/codebean/archive/2011/06/16/2082791.html

http://hi.baidu.com/arm_dsp/item/d3ea88006826c0813c42e2b7