linux 消息队列，简单的测试代码

/*msg_block_read.c*/

#include
#include
#include
#include
#include
#include
 
 
struct msg_buf
{
    int mtype;
//    char aaa[255];   //此结构体只能包含两个成员
    char data[255];
};
 
int main()
{
        key_t key;
        int msgid;
        int ret;
        struct msg_buf msgbuf;
 
        key=ftok("/tmp/2",'a');
        printf("key =[%x]\n",key);
        msgid=msgget(key,IPC_CREAT|0666); /*Íš¹ýÎÄŒþ¶ÔÓŠ*/
 
        if(msgid==-1)
        {
                printf("create error\n");
                return -1;
        }
/*  
        msgbuf.mtype = getpid();
        strcpy(msgbuf.data,"test haha, aaaaaaaaaaaaaaaaaa");
        ret=msgsnd(msgid,&msgbuf,strlen(msgbuf.data),0);
        if(ret==-1)
        {
                printf("send message err\n");
                return -1;
        }
 */
        memset(&msgbuf,0,sizeof(msgbuf));
        ret=msgrcv(msgid,&msgbuf,sizeof(msgbuf.data),0,0); //阻塞读取，第一个消息
        if(ret==-1)
        {
                printf("recv message err\n");
                return -1;
        }
        printf("recv msg =[%s], len = %d\n",msgbuf.data, strlen(msgbuf.data));
 
}



/*msg_block_write.c*/

#include
#include
#include
#include
#include
#include
 
 
struct msg_buf
{
    int mtype;
//    char aaa[255];  //此结构体只能包含两个成员
    char data[255];
};
 
int main()
{
        key_t key;
        int msgid;
        int ret;
        struct msg_buf msgbuf;
 
        key=ftok("/tmp/2",'a');
        printf("key =[%x]\n",key);
        msgid=msgget(key,IPC_CREAT|0666); /*Íš¹ýÎÄŒþ¶ÔÓŠ*/
 
        if(msgid==-1)
        {
                printf("create error\n");
                return -1;
        }
 
        msgbuf.mtype = getpid();
        strcpy(msgbuf.data,"test haha, aaaaaaaaaaaaaaaaaa");
        ret=msgsnd(msgid,&msgbuf,strlen(msgbuf.data),0); // 阻塞发送
        if(ret==-1)
        {
                printf("send message err\n");
                return -1;
        }
/* 
        memset(&msgbuf,0,sizeof(msgbuf));
        ret=msgrcv(msgid,&msgbuf,sizeof(msgbuf.data),getpid(),0);
        if(ret==-1)
        {
                printf("recv message err\n");
                return -1;
        }
        printf("recv msg =[%s], len = %d\n",msgbuf.data, strlen(msgbuf.data));
 */
}