Chinaunix首页 | 论坛 | 博客
  • 博客访问: 382207
  • 博文数量: 102
  • 博客积分: 1395
  • 博客等级: 中尉
  • 技术积分: 1050
  • 用 户 组: 普通用户
  • 注册时间: 2012-11-05 18:09
文章分类

全部博文(102)

文章存档

2013年(25)

2012年(77)

分类: C/C++

2012-11-25 14:43:01

linux下提供了以下几个接口,用于消息队列的使用:

头文件:

#include

#include

#include

函数原型:

key_t ftok( char * fname, int id )

int msgget(key_t key, int msgflg)

        int msgrcv(int msqid, struct msgbuf *msgp, int msgsz, long msgtyp, int msgflg); 

int msgsnd(int msqid, struct msgbuf *msgp, int msgsz, int msgflg); 

int msgctl(int msqid, int cmd, struct msqid_ds *buf);

每个消息都类似如下的数据结构:

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


一般使用步骤:

1. 用ftok产生一个key。

2. 调用msgget(使用key作为参数)产生一个队列

3. 进程可以用msgsnd发送消息到这个队列,相应的别的进程用msgrcv读取。

    这里需要注意msgsnd可能会失败的两个情况: 

    a) 可能被中断打断(包括msgsnd和msgrcv). 尤其是大流量应用中更容易出现. 比较安全的用法是判断操作是否被中断打断,如果被打断,            则需要继续尝试。

    b) 消息队列满。产生这个错误,则需要考虑提高系统消息队列规格,或者查看消息接收处是否有问题

4. msgctl函数可以用来删除消息队列
    消息队列产生之后,除非明确的删除(可以用),产生的队列会一直保留在系统中。linux下消息队列的个数是有限的,注意不要泄露。如果       使用已经达到上限,msgget调用会失败,产生的错误码对应的提示信息为no space left on device.

注意点:

1.消息的类型 mtype 不需为非0值。如果使用0,则msgsnd会失败,并得到”Invalid argument“错误。

2.msgflg为0表示阻塞等待,如果msgflg为IPC_NOWAIT表示非阻塞。

3.最好使用root权限执行消息队列,否则msgrcv 提示 "Permission denied"。

阅读(4571) | 评论(0) | 转发(0) |
给主人留下些什么吧!~~