Linux 消息队列小示例程序

/*msg.c*/
#include
#include
#include
#include
#include
#include
#include

#define BUFSZ 512

/*消息缓冲区*/
struct message
{
    long msg_type;          //消息标识符
    char msg_text[BUFSZ];   //消息，这个字段不但可以存储字符，还可以存储其他类型数据
};

int main()
{
    int qid;
    /*IPC关键字*/
    key_t key;
    int len;
    struct message msg;
    /*产生IPC关键字,用当前目录*/
    if((key=ftok(".",'a'))==-1)
    {
        perror("ftok");
        exit(1);
    }
    /*创建一个新的消息队列,返回消息队列标识符*/
    if((qid=msgget(key,IPC_CREAT|0666))==-1)
    {
        perror("msgget");
        exit(1);
    }
    printf("opened queue %d\n",qid);
    puts("Please enter the message to queue:");
    /*用户输入消息,到msg.msg_text去*/
    if((fgets(msg.msg_text,BUFSZ,stdin))==NULL)
    {
        puts("no message");
        exit(1);
    }
    /*消息标识符*/
    msg.msg_type = getpid();
    len = strlen(msg.msg_text);
    /*发送消息*/
    if((msgsnd(qid,&msg,len,0))<0)
    {
        perror("message posted");
        exit(1);
    }
    /*从消息队列读出消息,到msg*/
    if(msgrcv(qid,&msg,BUFSZ,0,0)<0)
    {
        perror("msgrcv");
        exit(1);
    }
    printf("message is:%s\n",(&msg)->msg_text);
    /*消息队列控制，这里删除消息队列*/
    if((msgctl(qid,IPC_RMID,NULL))<0)
    {
        perror("msgctl");
        exit(1);
    }
    exit(0);
}

程序说明：

１、此程序是自己往消息队列中发送一个消息后，又自己读取的过程。

２、perror函数说明：

perror ( )用 来 将 上 一 个 函 数 发 生 错 误 的 原 因 输 出 到 标 准 错误 (stderr) 。参数 s 所指的字符串会先打印出,后面再加上错误原因字符串。此错误原因依照全局变量errno 的值来决定要输出的字符串。

　　在库函数中有个error变量，每个error值对应着以字符串表示的错误类型。当你调用"某些"函数出错时，该函数已经重新设置了error的值。perror函数只是将你输入的一些信息和现在的error所对应的错误一起输出。

例如：上述程序中“ perror("msgctl");  ”若执行时，结果就为msgctl:error信息。