system V消息队列

开始 ->
if(key == IPC_PRIVATE)
{
    if(系统表格满了)    
    {
        // 出错返回
    }
    else
    {
        // 创建成功，返回标识符
    }
}
else // 不是私有的
{
    if(key已经存在)    
    {
        if(IPC_CREAT和IPC_EXCL都设置了)
        {
            // 出错返回
        }
        else
        {
            if(访问权限允许)
            {
                // 成功打开消息队列，返回标识符
            }
            else
            {
                // 出错返回
            }
        }
    }
    else   // key 不存在
    {
        if(IPC_CREAT设置了)
        {
            if(系统表格满了)    
              {
                // 出错返回
            }
            else
            {
                // 创建成功，返回标识符
            }
        }
        else // 不存在就无法打开
        {
            // 出错返回
        }
    }
}

#include<stdio.h>
#include<sys/types.h>
#include<sys/ipc.h>
#include<sys/msg.h>

#include"comm.h"
int main()
{
    //int msgid = msgget(1234,0666 | IPC_CREAT | IPC_EXCL);// 已存在则失败
    int msgid = msgget(1234,0666 | IPC_CREAT);
    //int msgid = msgget(IPC_PRIVATE,0666 | IPC_CREAT);
    if(msgid < 0)
        ERR_EXIT("msgget");
    printf("msgget success\n");
    printf("msgid = %d\n", msgid);

    return 0;
}

#include<stdio.h>
#include<sys/types.h>
#include<sys/ipc.h>
#include<sys/msg.h>

#include"comm.h"

void stattest(int msgid)
{
    struct msqid_ds buf;

    int ret = msgctl(msgid, IPC_STAT, &buf);
    if(ret < 0)
        ERR_EXIT("msgctl");
    printf("mode = %o\n", buf.msg_perm.mode);
    printf("bytes = %ld\n", buf.__msg_cbytes);
    printf("number = %d\n", (int)buf.msg_qnum);
    printf("msgmnb = %d\n", (int)buf.msg_qbytes);
}

void rmtest(int msgid)
{
    int ret = msgctl(msgid, IPC_RMID, NULL);
    if(ret < 0)
        ERR_EXIT("msgctl");

    printf("remove msg success\n");
}
void settest(int msgid)
{
    struct msqid_ds buf;

    int ret = msgctl(msgid, IPC_STAT, &buf);
    if(ret < 0)
        ERR_EXIT("msgctl stat");
    sscanf("600", "%o", (unsigned int*)&buf.msg_perm.mode);
    ret = msgctl(msgid, IPC_SET, &buf);
    if(ret < 0)
        ERR_EXIT("msgctl set");
}


int main()
{
    int msgid = msgget(1234,0);
    if(msgid < 0)
        ERR_EXIT("msgget");
    printf("msgget success\n");
    printf("msgid = %d\n", msgid);
    //stattest(msgid);
    //rmtest(msgid);
    settest(msgid);
    return 0;
}

#include<stdio.h>
#include<sys/types.h>
#include<sys/ipc.h>
#include<sys/msg.h>

#include"comm.h"

struct msgbuf{
    long mtype;
    char mtext[1];
};

int main(int argc, char *argv[])
{
    if(argc != 3)
    {
        printf("Usage:<%s> <type> <len>\n", argv[0]);
        return -1;
    }
    int type = atoi(argv[1]); // 表示发送的类型
    int len = atoi(argv[2]); // 表示发送的数据大小

    int msgid = msgget(1234,0);
    if(msgid < 0)
        ERR_EXIT("msgget");
    printf("msgget success\n");
    printf("msgid = %d\n", msgid);

    struct msgbuf *buf = (struct msgbuf*)malloc(sizeof(buf));
    buf->mtype = type;
    int ret = msgsnd(msgid, (void*)buf, len, 0);// 满了就等待
    //int ret = msgsnd(msgid, (void*)buf, len, IPC_NOWAIT);// 满了就会失败
    if(ret < 0)
        ERR_EXIT("msgsnd");
    return 0;
}

#include<stdio.h>
#include<sys/types.h>
#include<sys/ipc.h>
#include<sys/msg.h>
#include<unistd.h>

#include"comm.h"

struct msgbuf{
    long mtype;
    char mtext[1];
};

#define MSGMAX 8192

int main(int argc, char *argv[])
{
    int flag = 0;
    int type = 0;
    int opt;
    while(1)
    {
        /* 接受命令行参数。形式如下： ./a.out -n -t 3    
            -n 表示不等待
            -t 3 ：表示接收类型为3的消息。
        */
        opt = getopt(argc, argv, "nt:"); // 这个n表示接受n参数（但是-n后面不能接参数），t后面的冒号表示t后面可以接参数。具体用法网上再查一下。
        if(opt == '?')
            exit(EXIT_FAILURE);
        if(opt == -1)
            break;
        switch(opt)
        {
        case 'n':
            flag |= IPC_NOWAIT;
            break;
        case 't':
            type = atoi(optarg);
            break;
        default:
            break;
        }
    }
    int msgid = msgget(1234,0);
    if(msgid < 0)
        ERR_EXIT("msgget");
    printf("msgget success\n");
    printf("msgid = %d\n", msgid);

    struct msgbuf *buf = (struct msgbuf*)malloc(sizeof(long) + MSGMAX);
    buf->mtype = type;
    int ret = msgrcv(msgid, buf, MSGMAX, type, flag);
    if(ret < 0)
        ERR_EXIT("msgsnd");
    printf("recv msg, type:%ld len:%d\n", buf->mtype, ret); // 打印接受到的类型和长度

    return 0;
}