消息队列实现接收发送的例子

msg消息队列，实线不同进程之间的通信，主要依靠key来识别：

发送端

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/types.h>
#include <sys/msg.h>
#include <unistd.h>
#include <time.h>
#include <sys/ipc.h>
struct msgmbuf{
    int mtype;
    char mtext[40];
};

int main()
{
    int ret = -1;
    int msg_flags,msg_id;
    key_t key;
    struct msqid_ds msg_info;
    struct msgmbuf msg_mbuf;
    key = 1024;
    msg_flags = IPC_CREAT;

    while(1)
    {
        msg_id = msgget(key,msg_flags|0666);
        if(-1==msg_id)
        {
            printf("create message failed!
");
            return 0;
        }
        printf("Input message to send:");
        scanf("%s",msg_mbuf.mtext);
        getchar();
        msg_mbuf.mtype = 10;
        ret = msgsnd(msg_id,&msg_mbuf,sizeof(struct msgmbuf),0);
        if(-1==ret)
        {
            printf("send message failed!
");
        }
    
    }
    return 0;
}

接收端：

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/types.h>
#include <sys/msg.h>
#include <unistd.h>
#include <time.h>
#include <sys/ipc.h>
struct msgmbuf{
        int mtype;
        char mtext[40];
    };

int main()
{
    int ret = -1;
    int msg_flags,msg_id;
    key_t key;
    struct msgmbuf msg_mbuf;
    key =1024;
    msg_flags = IPC_CREAT;
    while(1)
    {
        msg_id = msgget(key,msg_flags|0666);
        if(-1==msg_id)
        {
            printf("create message failed!
");
            return 0;
        }
    
        ret = msgrcv(msg_id,&msg_mbuf,sizeof(struct msgmbuf),0,0);
        if(-1==ret)
        {
            printf("receive message failed!
");
        }
        else
        {
            printf("receive message successful!message[%s]
",msg_mbuf.mtext);
        }

    }
    return 0;
}