当前位置:  编程技术>c/c++/嵌入式

进程间通信之深入消息队列的详解

    来源: 互联网  发布时间:2014-10-15

    本文导语:      最近在Hi3515上调试Qt与DVR程序,发现他们之间使用消息队列通信的,闲暇之余,就总结了一下消息队列,呵呵,自认为通俗易懂,同时,在应用中也发现了消息队列的强大之处。    关于线程的管理(互斥量和条件变量)见...

    最近在Hi3515上调试Qt与DVR程序,发现他们之间使用消息队列通信的,闲暇之余,就总结了一下消息队列,呵呵,自认为通俗易懂,同时,在应用中也发现了消息队列的强大之处。

   关于线程的管理(互斥量和条件变量)见:Linux线程管理必备:解析互斥量与条件变量的详解

一、消息队列的特点

    1.消息队列是消息的链表,具有特定的格式,存放在内存中并由消息队列标识符标识.
    2.消息队列允许一个或多个进程向它写入与读取消息.
    3.管道和命名管道都是通信数据都是先进先出的原则。
    4.消息队列可以实现消息的随机查询,消息不一定要以先进先出的次序读取,也可以按消息的类型读取.比FIFO更有优势。

    目前主要有两种类型的消息队列:POSIX消息队列以及系统V消息队列,系统V消息队列目前被大量使用。系统V消息队列是随内核持续的,只有在内核重起或者人工删除时,该消息队列才会被删除。

二、相关函数

1. 获得key值

    key_t ftok(char *pathname, int projid)

#include
#include
参数:
    pathname:文件名(含路径),通常设置为当前目录“.” 比如projid为'a',则为"./a"文件
    projid:项目ID,必须为非0整数(0-255).

2. 创建消息队列
    int msgget(key_t key, int msgflag)
#include
#include
#include
功能:
    用于创建一个新的或打开一个已经存在的消息队列,此消息队列与key相对应。
参数:
    key:函数ftok的返回值或IPC_PRIVATE。
    msgflag:
        IPC_CREAT:创建新的消息队列。
        IPC_EXCL:与IPC_CREAT一同使用,表示如果要创建的消息队列已经存在,则返回错误。
        IPC_NOWAIT:读写消息队列要求无法满足时,不阻塞。
返回值:
    调用成功返回队列标识符,否则返回-1.

在以下两种情况下,将创建一个新的消息队列:
    1、如果没有与键值key相对应的消息队列,并且msgflag中包含了IPC_CREAT标志位。
    2、key参数为IPC_PRIVATE。

3. 消息队列属性控制
    int msgctl(int msqid,  int cmd,  struct msqid_ds *buf)
功能:
 对消息队列进行各种控制操作,操作的动作由cmd控制。
参数:
    msqid:消息队列ID,消息队列标识符,该值为msgget创建消息队列的返回值。
    cmd:
        IPC_STAT:将msqid相关的数据结构中各个元素的当前值存入到由buf指向的结构中.
        IPC_SET:将msqid相关的数据结构中的元素设置为由buf指向的结构中的对应值.
        IPC_RMID:删除由msqid指示的消息队列,将它从系统中删除并破坏相关数据结构.
buf:消息队列缓冲区
     struct msqid_ds {
               struct ipc_perm msg_perm;          /* Ownership and permissions*/
               time_t         msg_stime;                 /* Time of last msgsnd() */
               time_t         msg_rtime;                  /* Time of last msgrcv() */
               time_t         msg_ctime;                 /* Time of last change */
               unsigned long  __msg_cbytes;    /* Current number of bytes in  queue (non-standard) */
               msgqnum_t      msg_qnum;          /* Current number of messages  in queue */
               msglen_t       msg_qbytes;           /* Maximum number of bytesallowed in queue */
               pid_t          msg_lspid;                  /* PID of last msgsnd() */
               pid_t          msg_lrpid;                  /* PID of last msgrcv() */
                     };

     struct ipc_perm {
               key_t key;                        /* Key supplied to msgget() */
               uid_t uid;                         /* Effective UID of owner */
               gid_t gid;                        /* Effective GID of owner */
               uid_t cuid;                       /* Effective UID of creator */
               gid_t cgid;                      /* Effective GID of creator */
               unsigned short mode;    /* Permissions */
               unsigned short seq;       /* Sequence number */
                   };

4.发送信息到消息队列
    int msgsnd(int msqid,  struct msgbuf *msgp,  size_t msgsz,  int msgflag)
#include
#include
#include
功能:

    将新消息添加到队列尾端,即向消息队列中发送一条消息。
参数:
    msqid:已打开的消息队列id
    msgp:存放消息的结构体指针。
    msgflag:函数的控制属性。
    消息结构msgbuf为:
    struct msgbuf
    {
         long mtype;//消息类型
         char mtext[1];//消息正文,消息数据的首地址,这个数据的最大长度为8012吧,又可把他看成是一个结构,也有类型和数据,recv时解析即可。
    }
    msgsz:消息数据的长度。
    msgflag:
         IPC_NOWAIT: 指明在消息队列没有足够空间容纳要发送的消息时,msgsnd立即返回。
         0:msgsnd调用阻塞直到条件满足为止.(一般选这个)

5. 从消息队列接收信息
    ssize_t msgrcv(int msqid,  struct msgbuf *msgp,  size_t msgsz,  long msgtype,  int msgflag)
#include
#include
#include
功能:

    从队列中接收消息
参数:
    msqid:已打开的消息队列id
    msgp:存放消息的结构体指针。msgp->mtype与第四个参数是相同的。
    msgsz:消息的字节数,指定mtext的大小。
    msgtype:消息类型,消息类型 mtype的值。如果为0,则接受该队列中的第一条信息,如果小于0,则接受小于该值的绝对值的消息类型,如果大于0,接受指定类型的消息,即该值消息。
    msgflag:函数的控制属性。
    msgflag:
        MSG_NOERROR:若返回的消息比nbytes字节多,则消息就会截短到nbytes字节,且不通知消息发送进程.
        IPC_NOWAIT:调用进程会立即返回.若没有收到消息则返回-1.
        0:msgrcv调用阻塞直到条件满足为止.
在成功地读取了一条消息以后,队列中的这条消息将被删除。

三、相关例子

例1:消息队列之简单收发测试
#include
#include
#include
#include
#include

struct msg_buf{
     int mtype;//消息类型
     char data[255];//数据
};

int main(int argc,  char *argv[])
{
      key_t key;
      int msgid;
      int ret;
      struct msg_buf msgbuf;
      //获取key值
      key = ftok(".",  'a');
      printf("key = [%x]n",  key);

      //创建消息队列
      msgid = msgget(key,  IPC_CREAT|0666);/*通过文件对应*/
      if(msgid == -1)
      {
            printf("creat errorn");
            return -1;
      }

      //以当前进程类型,非阻塞方式发送"test data"到消息队列
      msgbuf.mtype = getpid();
      strcpy(msgbuf.data,  "test data");
      ret = msgsnd(msgid,  &msgbuf,  sizeof(msgbuf.data),  IPC_NOWAIT);
      if(ret == -1)
      {
            printf("send message errn");
            return -1;
      }

      //以非阻塞方式接收数据
      memset(&msgbuf,  0,  sizeof(msgbuf));
      ret = msgrcv(msgid,  &msgbuf,  sizeof(msgbuf.data), getpid(),  IPC_NOWAIT);
      if(ret == -1)
      {
            printf("receive message errn");
            return -1;
      }
      printf("receive msg = [%s]n",  msgbuf.data);
      return 0;
}
例2:进程间消息队列通信
#include
#include
#include
#include
#include
#include

struct msgbuf{
      int mtype;
      char mtext[100];
};

int main(void)
{
      key_t key;
      pid_t pid;
      int msgid;
      struct msgbuf msg;

      key=ftok(".", 0x01);
      if ( (msgid = msgget(key,  IPC_CREAT|0666))


    
 
 

您可能感兴趣的文章:

  • 单个消息队列能实现进程间聊天功能吗?
  • 关于后台服务进程不能读消息队列的问题?200分求答急急。。。
  • 关于多进程同时从消息队列取消息的问题
  • 是否可以通过消息队列在进程之间传递套接字?
  • 进程间通信-消息队列重大问题
  • 进程数据同步:消息队列还是共享内存+信号
  • 用户进程加载后在哪加入的调度队列的?
  • linux下编程显示所有进程,消息队列,急!!!!!!!!!!
  • 如何创建一个内核进程并设定一个消息队列?
  • linux不同机器间的进程如何共享一个消息队列,并由此互相通信?
  • unix/linux平台下进程间通信的问题(消息队列)(紧急求助)
  • 关于消息队列和进程互斥的问题,虽然比较急但还是祝各位新年快乐
  • 删除消息队列的进程需要什么权限
  • linux下多进程访问共享内存队列同步的问题
  • 多进程中使用队列queue为什么会core了呢?
  • [急切求助]使用SYS V消息队列实现进程间通讯问题!!!
  • linux不同机器间的进程如何共享一个消息队列,并由此互相通信? iis7站长之家
  • 两个进程间通过消息队列通信失败,帮忙分析原因,谢谢!
  • 利用消息队列在进程间通信
  • Linux进程等待队列的地址?
  • linux下进程占用内存空间详解
  • 解析后台进程对Android性能影响的详解
  • php-fpm两种进程管理模式详解
  • APUE笔记之:进程环境详解
  • 如何查看进程实际的内存占用情况详解
  • 深入C语言内存区域分配(进程的各个段)详解
  • C#网络编程基础之进程和线程详解
  •  
    本站(WWW.)旨在分享和传播互联网科技相关的资讯和技术,将尽最大努力为读者提供更好的信息聚合和浏览方式。
    本站(WWW.)站内文章除注明原创外,均为转载、整理或搜集自网络。欢迎任何形式的转载,转载请注明出处。












  • 相关文章推荐
  • 深入分析父子线程、进程终止顺序不同产生的结果
  • 深入探讨linux下进程的最大线程数、进程最大数、进程打开的文件数
  • 解析C#中用Process类杀死进程,执行命令的深入分析
  • linux僵尸(zombie)进程介绍及清除
  • 进程Afork进程B,进程Bfor进程C,如果进程C退出发出SIGCHLD,A进程是否可以收到
  • Ubuntu查看内存,进程相关命令介绍
  • 如果一个server进程要fork许多子进程,但不等待子进程终止,也不希望子进程结束后处于僵进程状态直到父进程终止。请问可采用什么方法实现
  • Linux进程的内核栈和用户栈概念,相互关系及切换过程
  • 在多进程中父进程frok子进程,怎样让子进程自举,脱离父进程,而且父进程不退出
  • android 4.0 托管进程介绍及优先级和回收机制
  • fock()开出的子进程的进程ID是否进程ID都大于父进程的?
  • linux下进程间通信:共享内存原理及具体用法举例(基于c/c++语言)
  • 父进程等待子进程n秒,如果子进程正常退出,父进程立即继续向下执行,如果子出现进程故障一直不退出,父进程等待n秒后继续向下执行,请问
  • 多进程问题 子进程读取内容 读完挂起,父进程写 写入后唤醒子进程
  • 一个进程首先监听一个端口,等到有连接了就新开一个进程,让新进程来处理后面的通讯。请问母进程中已经打开了端口,子进程怎么来使用同一
  • 我在一个父进程中,生成了4个子进程,子进程的优先级是一样的。我现在想结束子进程。该如何做?
  • 子进程wait/waitpid//子进程不结束,父进程会等待子进程吗?
  • 在一个进程中我定义了几个全局变量,然后我又fork了几个子进程,子进程中是否可以各自对全局变量进行修改,如果各子进程都对其进行修改,
  • 怎样一次杀掉父进程创建的所有子进程?我在父进程中用kill(0,SIGKILL),结果父进程也给干掉了,参数0难道不是表示除自己外的所有同uid的进
  • 进程创建进程组后,然后创建该组中的进程,然后终止。这里的终止....?
  • 如何实现子进程根据父进程的信号来确定是否终止子进程???
  • 高手请教!linux怎样通过pid获取进程信息,如:进程名、进程状态等?
  • 如何通过进程号获得进程的一些信息,例如:进程运行的目录
  • 【如何彻底杀死子进程】Kill -9子进程后进程呈僵死状态


  • 站内导航:


    特别声明:169IT网站部分信息来自互联网,如果侵犯您的权利,请及时告知,本站将立即删除!

    ©2012-2021,,E-mail:www_#163.com(请将#改为@)

    浙ICP备11055608号-3