进程间通迅之消息队列

消息队列类型有POSLX消息队列和V系统消息队列。其中POSLX为可移植的操作系统接口。

头文件：#include<sys/types.h>     #include<sys/ipc.h>     #include<sys/msg.h>

A:打开/创建消息队列

int msgget(key_t key,int msgflg)

1、key:键值，由ftok获得

2、msgflg:标识位

成功返回消息队列的描述符，失败-1。

B：发送消息

int msgsnd(int msqid,struct msgbuf *msgp,int msgz,int msgflg)

1、msqid:由msgget返回的描述符

2、msgp:存放消息队列的结构

struct msgbuf 最好使用结构体，不要使用指针，容易出现段错误。

struct msgbuf
{
    long mtype;       /* message type, must be > 0 */
    char mtext[MAX_SIZE];    /* message data */
};

3、msgz：消息数据的长度

4、msgflg：标识符

C:接收消息

int msgrcv(int msqid,struct mybuf *msgp,int msgz,long mtype,int msgflg)

1,msgqid:由msgget返回的描述符

2、msgp:存放消息队列的结构

3、msgz:接收消息的长度

4、mtype：消息队列的类型

5、msgflg:标识位

D:删除消息队列

int msgctl(int msqid, int cmd, struct msqid_ds *buf)

例子：两个进程通过消息队列相互发送数据

server.c

/*************************************************************************
    > File Name: shmserver.c
    > Author: xu
    > Mail: eeexu123@163.com 
    > Created Time: 2016年10月11日 星期二 13时40分05秒
 ************************************************************************/

#include<stdio.h>
#include<unistd.h>
#include<stdlib.h>
#include<string.h>
#include<sys/types.h>
#include<sys/ipc.h>
#include<sys/msg.h>
#include<sys/stat.h>
#include<fcntl.h>
#define MAX_SIZE 128

struct msgbuf
{
    long mtype;       /* message type, must be > 0 */
    char mtext[MAX_SIZE];    /* message data */
};

int main()
{
    key_t key;
    pid_t pid;
    int msqid;
    struct msgbuf mysndbuf,myrcvbuf;
    
    
    //创建键值
    key = ftok("./t.c",'b');
    if(key < 0)
    {
        perror("ftok");
        exit(1);
    }
    //创建消息队列
    msqid = msgget(key,IPC_CREAT|S_IRWXU);
    if(msqid < 0)
    {
        perror("msgget");
        exit(1);
    }
    //创建父子进程
    pid = fork();
    if(pid == 0)
    {
        type = my
        //接收服务端消息
        while(1)
        {
            memset(myrcvbuf.mtext,0,MAX_SIZE);
            msgrcv(msqid,(void *)&myrcvbuf,MAX_SIZE,200,0);
            printf("he massages queue data:%s
",myrcvbuf.mtext);
        }
    }
    else if(pid > 0)
    {
        mysndbuf.mtype = 100;
        //客户端发送信息
        while(1)
        {            
            printf("please input data:
");
            fgets(mysndbuf.mtext,MAX_SIZE,stdin);
            msgsnd(msqid,(void *)&mysndbuf,sizeof(mysndbuf.mtext),0);
        }        
    }
    //删除消息队列
    msgctl(msqid,IPC_RMID,NULL);
    return 0;
}

client.c

/*************************************************************************
    > File Name: shmclient.c
    > Author: xu
    > Mail: eeexu123@163.com 
    > Created Time: 2016年10月11日 星期二 13时40分14秒
 ************************************************************************/

#include<stdio.h>
#include<unistd.h>
#include<stdlib.h>
#include<string.h>
#include<sys/types.h>
#include<sys/ipc.h>
#include<sys/msg.h>
#include<sys/stat.h>
#include<fcntl.h>
#define MAX_SIZE 128
struct msgbuf
{
    long mtype;       /* message type, must be > 0 */
    char mtext[MAX_SIZE];    /* message data */
};

int main()
{
    key_t key;
    pid_t pid;
    int msqid;
    struct msgbuf mysndbuf,myrcvbuf;
    
    
    //创建键值
    key = ftok("./t.c",'b');
    if(key < 0)
    {
        perror("ftok");
        exit(1);
    }
    //创建消息队列
    msqid = msgget(key,IPC_CREAT|S_IRWXU);
    if(msqid < 0)
    {
        perror("msgget");
        exit(1);
    }
    //创建父子进程
    pid = fork();
    if(pid == 0)    //此为子进程
    {
        mysndbuf.mtype = 200;
        //服务端发送信息
        while(1)
        {
            printf("please input data:
");
            fgets(mysndbuf.mtext,MAX_SIZE,stdin);
            msgsnd(msqid,(void *)&mysndbuf,sizeof(mysndbuf.mtext),0);
        }        
    }
    else if(pid > 0)
    {
        //接收客户端消息
        while(1)
        {
            memset(myrcvbuf.mtext,0,MAX_SIZE);
            msgrcv(msqid,(void *)&myrcvbuf,MAX_SIZE,100,0);
            printf("he massages queue data:%s
",myrcvbuf.mtext);
        }
    }
    //删除消息队列
    msgctl(msqid,IPC_RMID,NULL);
    return 0;
}