zoukankan      html  css  js  c++  java
  • POSIX消息队列

    POSIX消息队列

             消息队列可认为是一个消息链表,有写权限的线程可以往消息队列中写消息,有读权限的线程可以从队列中读取消息,从而实现数据共享。每个消息都是一条记录,具有以下属性:

    优先级(无符号整数或长整数类型)

    消息的数据部分长度

    数据本身。

    1、 相关函数

    头文件:#include <mqueue.h>

    创建和打开:mqd_t mq_open(const char *name, int oflag, /*mode_t, struct mq_attr*attr */)

    其中name为消息队列的名称(需符合IPC规则——即一个文件的绝对路径名),oflag参数指定读写(O_RDONLY、O_RDWD)打开,也可按位或上O_CREAT、O_EXCL或O_NONBLOCK。

    其用法和open函数类似,当创建一个新队列时,要指定mode及attr。

    成功返回消息队列描述符,失败返回-1

    关闭:int mq_close(mgd_t mqdes) 成功返回0,若出错则为-1

    删除:int mg_unlink(const char *name)  用法同unlink。

    发送:mq_send(mqd_t mqdes, const char *ptr, size_t len, unsigned int prio)

    接收:mq_receive(mqd_t mqdes, char *ptr, size_t len, unsigned int *prio)

    获取和设置消息队列属性:

    int mg_getattr(mgd_t mqdes, struct mq_attr*attr);

    int mq_setattr(mqd_t mqdes, const structmq_attr *attr, struct mq_attr *oattr).

    mq_attr结构如下:

    struct mq_atrr{

    long mq_flag; //阻塞(0)与非阻塞(O_NOBLOCK)

    long mq_maxmsg; //消息队列最大消息数

    long mq_msgsize; //一条消息的最大字节数

    long mq_curmsg;  //消息队列的消息数

    }

             其中mq_send中的prio参数必须小于MQ_PRIO_MAX(可以通过sysconf(_SC_MQ_PRIO_MAX)获取), mq_receive的len参数的值不能小于能加到所指定队列中的消息的最大大小(mq_attr结构中的mq_msgsize成员)。如果len小于该值,mq_receive就立即返回EMSGSIZE错误。

             其他的限制还包括一个进程能够同时打开的消息队列数(可用sysconf(_SC_MQ_OPEN_MAX)获取)

    2、 特性

             POSIX消息队列至少具有随内核的持续性,即使当前没有进程打开着某个消息队列,该队列及其上的各个消息也将一直存在,直到删除该队列为止。

             当消息队列中有多个消息时,调用mq_receive将返回优先级最高的消息

             POSIX消息队列允许异步事件通知,以告知何时有一个消息放置到了某个空消息队列中。这种通知通过mq_notify函数实现,可以通过信号或创建一个异步调用线程方式实现。


  • 相关阅读:
    GitLab的基础使用-汉化配置
    GitLab的基础使用-数据备份与恢复
    Apache Hadoop集群扩容实战案例
    Hadoop 集群-完全分布式模式(Fully-Distributed Mode)
    HDFS参数调优总结
    网站压力测试 工具webbench
    2013年十大必知的大数据分析公司
    做电子商务网上开店应该读的书
    教你用大功率路由器覆盖3平方公里的WiFi广告
    中央推进城镇化建设 六行业分享25万亿蛋糕
  • 原文地址:https://www.cnblogs.com/OpenLinux/p/5020698.html
Copyright © 2011-2022 走看看