队列

/*
 * 创建消息队列
 * Lzy    2011-6-15
 */

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

int main(void)
{
    int qid;        //队列标识符
    key_t key;        //消息队列键值

    key = ftok("/work/msg", 'a');    //生成队列键值(文件必须存在)
    if(key < 0)
    {
        perror("ftok");
        exit(0);
    }

    qid = msgget(key,IPC_CREAT | 0666);    //打开或创建队列
    if(qid < 0)
    {
        perror("msgget");
        exit(0);
    }
    else
    {
        printf("Done!\n");
    }

    return 0;
}

/*
 * 消息队列控制
 * 消息队列的删除
 * Lzy    2011-6-15
 */

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

int main(int argc, char *argv[])
{
    int qid;
    int ret;

    qid = atoi(argv[1]);        //将传进来的消息队列键值，赋给qid
    ret = msgctl(qid, IPC_RMID, NULL);//删除消息队列
    if(ret < 0)
    {
        perror("msgctl");
        exit(0);
    }
    else
    {
        printf("Done!\n");
    }

    return 0;
}

/*
 * 消息队列的读写
 * 实现两个进程之间的消息传递
 * 消息发送程序
 *Lzy    2011-6-15
 */

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

struct msgbuf
{
    long mtype;        //消息类型
    char mtext[1024];    //消息内容
};

int main(void)
{
    int qid;            //消息队列标识符
    key_t key;            //消息队列键值
    struct msgbuf buf;
    int ret;

    key = ftok("msg", 'a');    //获取键值
    if(key < 0)
    {
        perror("ftok");
        exit(0);
    }

    qid = msgget(key, IPC_CREAT | 0666);    //打开消息队列
    if(qid < 0)
    {
        perror("msgget");
        exit(0);
    }

    while(1)
    {
        buf.mtype = getpid();        //消息类型为自己的ID
        gets(buf.mtext);
        if(strncmp(buf.mtext, "quit", 4) == 0)    //循环退出
            break;

        ret = msgsnd(qid, &buf, sizeof(buf)-4*sizeof(long), 0);    //发送消息
        if(ret < 0)
        {
            perror("msgsnd");
            exit(0);
        }
    }

    return 0;
}

/*
 * 消息队列的读写
 * 实现两个进程之间的消息传递
 * 消息接收程序
 * Lzy    2011-6-15
 */

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

struct msgbuf
{
    long mtype;        //消息类型
    char mtext[1024];    //消息内容
};

int main(void)
{
    int qid;            //消息队列标识符
    key_t key;            //消息队列键值
    struct msgbuf buf;
    int ret;

    key = ftok("msg", 'a');    //获取键值
    if(key < 0)
    {
        perror("ftok");
        exit(0);
    }

    qid = msgget(key, IPC_CREAT | 0666);    //打开消息队列
    if(qid < 0)
    {
        perror("msgget");
        exit(0);
    }

    while(1)
    {
        bzero(&buf, sizeof(buf));
        ret = msgrcv(qid, &buf, sizeof(buf)-4*sizeof(long), 0, 0);    //接收消息
        if(ret < 0)
        {
            perror("msgsnd");
            exit(0);
        }
        else
            printf("%s\n",buf.mtext);
    }

    return 0;
}