消息队列通信

  消息队列就是一个消息(一个结构)的链表。而一条消息则可看作一个记录,具有特定的格式。进程可以从中按照一定的规则添加新消息;另一些进程则可以从消息队列中读走消息。

  每一个消息都是一个结构体:

struct msgbuf{

  long mtype;      //表示结构体类型,来区分不同的消息

  char mtext[1];     //消息数据

};

一、函数学习

1创建消息队列

1).函数名

  msgget

2).函数原型

  int msgget(key_t key,int msgflg)

3).函数功能

  打开或创建消息队列

4).所属头文件

  <sys/types.h><sys/ipc.h><sys/msg.h>

5).返回值

  成功:消息队列ID

  失败:-1

6).参数说明

  key:键值

  msgflg:打开标志,IPC_CREAT:表明新创建一个消息队列

2从消息队列中读出数据

1).函数名

  msgrcv

2).函数原型

  ssize_t msgrcv(int msgqid,void  *msgp,size_t msgsz,long msgtyp,int msgflg;)

3).函数功能

  从消息队列中接受消息

4).所属头文件

  <sys/types.h><sys/ipc.h><sys/msg.h>

5).返回值

  失败;-1

  成功:实际接收到消息长度

6).参数说明

  msgqid:消息队列id

  msgp:存放取出的消息

  msgsz:期望取到消息的最大长度

  msgtyp:消息的类型  0:忽略类型,直接取队列中的第一条消息

  >0:取消息队列中类型等于msgtyp的第一条消息

  <0:取类型比msgtyp的绝对值要小于或者等于的消息,如果有多条消息满足该条件,则取类型最小的一条

  msgflg:标志

3向消息队列写信息

1).函数名

  msgsnd

2).函数原型

  int msgsnd(int msqid,const void *msgp,size_t  msgsz,int msgflg);

3).函数功能

  向消息队列发送消息

4).所属头文件

  <sys/types.h><sys/ipc.h><sys/msg.h>

5).返回值

  失败:-1

  成功:0

6).参数说明

  msqid:消息队列的的id

  msgp:指向要发送的消息

  msgsz:消息的长度、消息中的这个成员char mtext[1]的长度

  msgflg:标志位

4删除消息队列(通过消息队列控制实现删除)

1).函数名

  msgctl

2).函数原型

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

3).函数功能

  控制消息队列

4).所属头文件

  <sys/types.h><sys/ipc.h><sys/msg.h>

5).返回值

  成功:0

  失败:-1

6).参数说明

  msqid:消息队列id

  cmd:对消息队列执行的操作命令,IPC_EMID用于删除消息

  buf:获取内核中的msqid_ds结构

二、实例学习

2.1首先编辑send.c文件

 #include <stdio.h>
 #include <sys/types.h>
 #include <sys/ipc.h>
 #include <sys/msg.h>
 #include <string.h>
 struct msgt{
     long msgtype;
     ];
 };

 int main()
 {
     int msqid;
     int msg_type;
     ];
     struct msgt msgs;
     //创建消息队列
     msqid = msgget(,IPC_CREAT);

     //while
     )
     {
         printf("Please input message type,0 for quit!\n");
          //获取消息类型
         scanf("%d",&msg_type);

         //如果用户输入的消息类型为0,退出该循环
         if(!msg_type)
             break; 

         //获取消息数据
         printf("please input message content!\n");
         scanf("%s",str);

         msgs.msgtype = msg_type;
         strcpy(msgs.msgtext,str); 

         //发送数据
         msgsnd(msqid,&msgs,);
     }  

     //删除消息队列
     msgctl(msqid,IPC_RMID,);
     ;
 }

2.2编辑read.c文件

 #include <stdio.h>
 #include <sys/types.h>
 #include <sys/ipc.h>
 #include <sys/msg.h>
 #include <string.h> 

 ;

 struct msgt{
     long msgtype;
     ];
 };
 int childprocess()
 {
     struct msgt msgs;
     )
     {
         //接收消息队列
         msgrcv(msqid,&msgs,,);   

         //打印消息队列中的数据
         printf("msg text: %s\n",msgs.msgtext);
     }
     ;
 }

 int main()
 {
     int msqid;
     int i;
     int cpid;
     //打开消息队列
     msqid = msgget(,IPC_EXCL);

     //创建3个子进程
     ;i<;i++)
     {
         cpid = fork();
         )
             printf("creat child process error!\n");
         )
             childprocess();
     }
     //
     ;
 }

2.3编译分别在两个linux终端运行两个进程

消息队列通信,王明学learn的更多相关文章

  1. 管道通信,王明学learn

    管道通信 一.通讯目的 1.数据传输 一个进程需要将数据发送给另一个进程. 2.资源共享 多个进程之间共享同样的资源. 3.通知事件 一个进程需要向另一个/组进程发送消息,通知它们发生了某事件. 4. ...

  2. 信号量互斥,王明学learn

    信号量互斥 信号量(又名:信号灯)与其他进程间通信方式不大相同,主要用途是保护临界资源(进程互斥).进程可以根据它判定是否能够访问某些共享资源.除了用于访问控制外,还可用于进程同步. 一.信号量分类 ...

  3. linux驱动程序设计的硬件基础,王明学learn

    linux驱动程序设计的硬件基础(一) 本章讲总结学习linux设备程序设计的硬件基础. 一.处理器 1.1通用处理器 通用处理器(GPP)并不针对特定的应用领域进行体系结构和指令集的优化,它们具有一 ...

  4. 共享内存同行,王明学learn

    共享内存同行 一.共享内存概念 共享内存是IPC机制中的一种,它允许两个不相关的进程访问同一段内存, 这是传递数据的一种非常有效的方式. 二.函数学习 这里主要有创建共享内存.映射共享内存.分离共享内 ...

  5. 进程控制理论,王明学learn

    进程控制理论 一.进程 进程是一个具有一定独立功能程序的一次运行活动. 1.1进程特点 1.动态性:进程的实质是程序的一次执行过程,进程是动态产生,动态消亡的 2.并发性:任何进程都可以同其他进程一起 ...

  6. linux内核的组成,王明学learn

    linux内核的组成 一.linux内核源代码目录结构 arch: 包含和硬件体系结构相关的代码, 每种平台占一个相应的目录, 如 i386.ARM.PowerPC.MIPS 等. block:块设备 ...

  7. linux设备驱动概述,王明学learn

    linux设备驱动学习-1 本章节主要学习有操作系统的设备驱动和无操作系统设备驱动的区别,以及对操作系统和设备驱动关系的认识. 一.设备驱动的作用 对设备驱动最通俗的解释就是“驱使硬件设备行动” .设 ...

  8. usb设备驱动描述,王明学learn

    usb设备驱动 本章主要内容包含以下:USB总线介绍,USB协议分析,USB系统架构 一.USB总线介绍 1.1USB发展史 USB(Universal Serial Bus)通用串行总线,是一种外部 ...

  9. 信号量进程同步,王明学learn

    信号量进程同步 一组并发进程进行互相合作.互相等待,使得各进程按一定的顺序执行的过程称为进程间的同步. 信号量在进程同步时初始值为:0 信号量在进程互斥时初始值为:大于0的 本章节主要使用信号量,使的 ...

随机推荐

  1. Struts2的OGNL表达式语言

    一.OGNL的概念 OGNL是Object-Graph Navigation Language的缩写,全称为对象图导航语言,是一种功能强大的表达式语言,它通过简单一致的语法,可以任意存取对象的属性或者 ...

  2. JNI_Android项目中调用.so动态库实现详解

    转自:http://www.yxkfw.com/?p=7223 1. 在Eclipse中创建项目:TestJNI 2. 新创建一个class:TestJNI.java package com.wwj. ...

  3. PHP7特性概览

    了解了PHP7的一些特性,搭建PHP7源码编译环境,并运行官网这些新特性的代码. 在64位平台支持64位integer 在64位平台支持64位integer,长度为2^64-1 字符串. 更详细查看 ...

  4. QML与Qt C++ 交互机制探讨与总结

    介绍 QML和 C++对象可以通过,signals,slots和 属性修改进行交互.对于一个C++对象,任何数据都可以通过Qt的 Meta-Object System暴露给QML(何总方法,后面介绍) ...

  5. Dorado7与@ManyToMany的矛盾分析

    在Dorado7开发时,通过UpdateAction提交数据,默认只会提交DataSet中DirtyTree,这样如果子对象数据未发生修改时是不会提交的,后台拿到的子对象为空.如果两对象之间,通过JP ...

  6. 利用Fiddler修改请求信息通过Web API执行操作(Action)实例

    本人微信和易信公众号: 微软动态CRM专家罗勇 ,回复261或者20170724可方便获取本文,同时可以在第一间得到我发布的最新的博文信息,follow me!我的网站是 www.luoyong.me ...

  7. 编译预处理命令define

    #include 包含指令 将一个源文件嵌入到当前源文件中该点处. #include<文件名>  按标准方式搜索,文件位于C++系统目录的include子目录下 #include" ...

  8. Hibernate学习笔记二

    Hibernate持久化类的编写规则 Hibernate是持久层的ORM映射框架,专注于数据的持久化工作.所谓持久化,就是将内存中的数据永久存储到关系型数据库中. 持久化类 一个java类与数据库表建 ...

  9. UiAutomator2.0 - 与AccessibilityService的关联

    目录 一.Android中的 Accessibility 二.UiAutomator2.0 与 AccessibilityService 三.验证与 AccessibilityService的关联 A ...

  10. 【转】JVM内存结构 VS Java内存模型 VS Java对象模型

    JVM内存结构 我们都知道,Java代码是要运行在虚拟机上的,而虚拟机在执行Java程序的过程中会把所管理的内存划分为若干个不同的数据区域,这些区域都有各自的用途. 其中有些区域随着虚拟机进程的启动而 ...