IPC msgQueue

tsMsgQueueRd.c

#include <unistd.h>
#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <errno.h>
#include <sys/msg.h>

//消息的数据结构
struct msg_st{
    long int msg_type;
    char text[1024];
};

int main()
{
    int msgid=-1;
    struct msg_st data;
    long int msgtype = 0;     //接收为0，发送为1
    int ret=-1;
    
    //建立消息队列
    msgid = msgget((key_t)1234, 0666 | IPC_CREAT);
    if(msgid==-1)
    {
        perror("msgget create fail!");
        return -1;
    }
    
    while(1)
    {
        //从队列中获取消息，直到遇到quit为止
        ret=msgrcv(msgid,(void*)&data,1024,msgtype,0);
        if(ret==-1)
        {
            perror("msgrcv fail");
            break;
        }
        
        printf("msg receive:%s\n",data.text);
        
        if(strncmp(data.text,"quit",4)==0)
        {
            printf("msg receive end!\n");
            break;
        }
        
    }
    
    //删除消息队列
    ret=msgctl(msgid,IPC_RMID,0);
    if(ret==-1)
    {
        perror("msgctl delete fail!");
        return -1;
    }
    
    return 0;
}

tsMsgQueueWr.c

#include <unistd.h>
#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <errno.h>
#include <sys/msg.h>

//消息的数据结构
struct msg_st{
    long int msg_type;
    char text[1024];
};

int main()
{
    int msgid=-1;
    struct msg_st data;
    long int msgtype = 0;     //接收为0，发送为1
    char buf[1024];
    int ret=-1;
    
    //建立消息队列
    msgid = msgget((key_t)1234, 0666 | IPC_CREAT);
    if(msgid==-1)
    {
        perror("msgget create fail!");
        return -1;
    }
    
    while(1)
    {
        //输入要发送的消息
        printf("please send msg:");
        fgets(buf, 1024, stdin);
        data.msg_type=1;
        strcpy(data.text,buf);
        
        //向队列发送数据
        ret=msgsnd(msgid,(void*)&data, 1024, 0);
        if(ret==-1)
        {
            perror("msgsnd fail!");
            break;
        }
        
        //输入end结束输入
		if(strncmp(buf, "quit", 4) == 0)
		{
		    printf("send msg end!\n");
		    break;
		}
		
    }
    
    
    return 0;
}