linux消息队列函数简析

linux消息队列函数  -----------------------------------------------------linux消息队列函数--------------------------------头文件：#include <sys/types.h>#include <sys/ipc.h>#include <sys/msg.h>  www.2cto.com  ------------------------------------------1、系统建立IPC通讯（如消息队列、共享内存时）必须指定一个ID值。通常情况下，该id值通过ftok函数得到。ftok原型如下：key_t ftok( char * fname, int id )fname就时你指定的文件名，id是子序号。在一般的UNIX实现中，是将文件的索引节点号取出，前面加上子序号得到key_t的返回值。如指定文件的索引节点号为65538，换算成16进制为0x010002，而你指定的ID值为38，换算成16 进制为0x26，则最后的key_t返回值为0x26010002。查询文件索引节点号的方法是： ls -i当删除重建文件后，索引节点号由操作系统根据当时文件系统的使用情况分配，因此与原来不同，所以得到的索引节点号也不同。如果要确保key_t值不变，要目确保ftok的文件不被删除，要么不用ftok，指定一个固定的key_t 值，比如:#define IPCKEY 0x111char path[256];    sprintf( path, "%s/etc/config.ini", (char*)getenv("HOME") );    msgid=ftok( path, IPCKEY );[/code]同一段程序，用于保证两个不同用户下的两组相同程序获得互不干扰的IPC键值。由于 etc/config.ini（假定）为应用系统的关键配置文件，因此不存在被轻易删除的问题——即使被删，也会很快被发现并重建（此时应用系统也将被重起）。ftok()的设计目的也在于此。 ----------------------------------------------------2、int msgget(key_t key, int msgflg); //创建消息队列参数：    key：消息队列关联的键。为IPC_PRIVATE时表示创建自己的消息队列    msgflg：消息队列的建立标志和访问权限。msgflg 的低位用来确定消息队列的访问权限。        IPC_CREAT：如果 key不存在，创建        IPC_EXCL：如果 key 存在，返回失败        IPC_NOWAIT：如果需要等待，直接返回错误        如果单独使用IPC_CREAT，则msgget()要么返回一个新创建的消息队列的标识符，要么返回具有相同关键字值的队列的标识符。如果 IPC_EXCL和IPC_CREAT一起使用，则msgget()要么创建一个新的消息队列，要么如果队列已经存在则返回一个失败值-1。    返回说明：如果成功，返回消息队列标识符如果失败，则返回-1：errno=EACCESS(权限不允许)EEXIST(队列已经存在，无法创建)EIDRM(队列标志为删除)ENOENT(队列不存在)ENOMEM(创建队列时内存不够)ENOSPC(超出最大队列限制)   www.2cto.com  举例：msgid=msgget(IPC_PRIVATE,IPC_CREAT|IPC_EXCL|00666); //创建消息队列 --------------------------------------------------3、int msgsnd(int msqid, const void *msgp, size_t msgsz, int msgflg); //将消息送入消息队列参数：      msqid：消息队列的标识符。    msgp：指向消息缓冲区的指针，此位置用来暂时存储发送和接收的消息，是一个用户可定义的通用结构，形态如下 struct msgbuf {    long mtype;     /* 消息类型，必须 > 0 */    char mtext[1];  /* 消息文本 */};    msgsz：消息的大小。    msgflg：用来指明进程在队列数据满(msgsnd)或空(msgrcv)的情况下所应采取的行动。        如果设置为 IPC_NOWAIT，则在消息队列已满时不发送消息并且调用进程立即返回错误信息EAGAIN。        如果设置为 0，则调用进程阻塞直至消息队列不为满。        返回说明：  成功执行时，msgsnd()返回0, 失败返回-1 举例：msgsnd(g_msg_id,&msg_snd,sizeof(msg_snd.msg_item),IPC_NOWAIT); //非阻塞发送消息     ----------------------------------------------------------4、ssize_t msgrcv(int msqid, void *msgp, size_t msgsz, long msgtyp, int msgflg); //从消息队列读取信息参数：    msgtyp:    msgtyp = 0：收取队列中的第一条消息，任意类型。    msgtyp > 0：收取第一条 msgtyp 类型的消息。    msgtyp < 0：收取第一条最低类型（小于或等于 msgtyp 的绝对值）的消息。     其他参数参考msgsnd函数。    返回说明：  成功执行时，msgrcv()返回0, 失败返回-1 举例：msgrcv(msgid,&msg_rbuf,sizeof(msg_rbuf.msg_item),10,0); //阻塞接收  www.2cto.com  ----------------------------------------------------------5、int msgctl (int msqid, int cmd, struct msqid_ds *buf); //消息队列属性控制 参数：    msqid：消息队列的标识符。    cmd：执行的控制命令，即要执行的操作。包括以下选项：        IPC_STAT：读取消息队列属性。取得此队列的msqid_ds 结构，并将其存放在buf指向的结构中。         IPC_SET ：设置消息队列属性。        IPC_RMID：删除消息队列。        IPC_INFO：读取消息队列基本情况。此命令等同于 ipcs 命令。        这 4 条命令（IPC_STAT、IPC_SET、IPC_INFO 和 IPC_RMID）也可用于信号量和共享存储。    buf：临时的 msqid_ds 结构体类型的变量。用于存储读取的消息队列属性或需要修改的消息队列属性。    举例：msgctl(qid, IPC_RMID, NULL)  //删除消息队列    摘自 pj81102的专栏