消息队列通信

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

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

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. trigger() --工作中问题nav样式

    自动执行某元素的某个事件 $("#div").trigger("click");  //让系统自动执行单击事件 适用于nav样式中,下面横线绝对定位于nav.o ...

  2. 转:Eclipse Search Tips

    from:  https://github.com/ajermakovics/eclipse-instasearch/wiki/Eclipse-search-tips Eclipse Search T ...

  3. phpcms调用一个指定的栏目的url和栏目名称

    {$CATEGORY[$catid]['url']} 指定栏目URL代码 {$CATEGORY[$catid]['catname']} 指定栏目名称代码 {$CATEGORYS[41]['url']} ...

  4. C语言中main函数的参数

    转自:http://blog.csdn.net/cnctloveyu/article/details/3905720 我们经常用的main函数都是不带参数的.因此main 后的括号都是空括号.实际上, ...

  5. 大概了解了flexbox

    <!doctype html> <html> <head> <meta charset="utf-8"> <title> ...

  6. 夺命雷公狗---node.js---4net模块(上)

    node.js为我们提供了一个net模块,主要是为了提供了一些底层通信的小工具,包含了创建服务器/客户端方法,引入方式也很简单: var net = require('net'); net模块也为我们 ...

  7. 成功的GIT开发分支模型和策略

    详细图文并茂以及git flow工具解释参考: http://danielkummer.github.io/git-flow-cheatsheet/index.zh_CN.html 原文地址:http ...

  8. Oracle学习(七):集合运算

    1.知识点:能够对比以下的录屏进行阅读 SQL> -- 查询10和20号部门的员工的3种方法 SQL> --1. select * from emp where deptno in (10 ...

  9. Java [leetcode 20]Valid Parentheses

    题目描述: Given a string containing just the characters '(', ')', '{', '}', '[' and ']', determine if th ...

  10. 【剑指Offer学习】【面试题19 :二叉树的镜像】

    题目:请完毕一个函数,输入一个二叉树,该函数输出它的镜像. 二叉树结点的定义: /** * 二叉树的树结点 */ public static class BinaryTreeNode { int va ...