linux消息队列概念

消息队列的概念:

消息队列提供了一种从进程向另一个进程发送一个数据块的方法。每个数据块都被认为是用一个类型,接收者进程接收的数据块可以有不同的类型值。我们可以通过发送消息来避免命名管道的同步和阻塞的问题。消息队列与管道不同的事,消息队列是基于消息的,而管道是基于字节流的,且消息队列的读取不一定是先入先出。消息队列和命名管道有一样的不足,就是每个消息的最大长度是有上限的(MSGMAX),每个消息队列的总的字节数是有上限的(MSGMNB),系统上消息队列的总数也是有一个上限(MSGMNI)。

IPC对象数据结构:

struct ipc_perm

{

key_t __key;

uid_t uid;

gid_t gid;

uid_t cuid;

gid)t cgid;

unsigned short mode;

unsigned short short__seq;

};

创建新消息队列或取得已存在消息队列:

int msgget(key_t key,int msgflg)

key:可以认为是一个端口号,也可以由函数ftok生成;

msgflg:

IPC_CREAT:如果IPC不存在,则创建一个IPC资源,否则打开操作。

IPC_EXCL:只有在共享内存不存在的时候,新的内存共享才建立,否则就产生错误。

如果单独使用IPC_CRETA,XXXget()函数要么返回一个已经存在的共享内存的操作符,要么返回一个新建的共享内存的标识符。

如果将IPC_CRETA和IPC_EXCL标志一起使用,XXXget()将返回一个新建的IPC标识符;如果IPC资源存在,则返回-1。

IPC_EXEL标志本身并没有太大的意义,但是和IPC_CREAT标志一起使用可以用来保证所得对象是新建的,而不是打开已有的对象。

向队列读/写消息:

读消息:ssize_t magrcv(int msqid,void* msgp,size_t masgsz,long msgtyp,int msgflg);

写消息:int msgsnd(int msqid,const void* msgp,size_t msgsz,int msgflg);

参数:

msgqid:消息队列的标识码;

msgp:指向消息缓冲区的指针,此位置用来暂时存储发送和接收的消息,是一个用户可定义的通用结构,

struct msgstru

{

long mytype;//大于0

char mtext[用户指定大小];

};

msgsz:消息的大小;

msgtyp:从消息队列内读取的消息形态。如果值为零,则表示消息队列中的所有消息都会被读取;

msgflg:用来指明核心程序在队列没有数据的情况下所应采取的行动。如果msgflg和常数IPC_NOWAIT合用,则在msgsnd()执行时若是消息队列已满,则msgsnd()将不会阻塞,而是立即返回-1,如果执行的是msgrcv(),则在消息队列呈空时,不做等待马上返回-1,并设定错误码为ENOMSG。当msgflg为0时,msgsnd()和msggrc()在队列呈空的情形时,采取阻塞等待的处理模式。

设置消息队列的属性:

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

参数:

msgctl系统调用对msgqid标识的队列消息执行cmd操作,系统定义了3种cmd操作:IPC_STAT,IPC_SET,IPC_RMID

IPC_STAT:该命令用来获取消息队列对应的msgqid_ds数据结构,并将其保存到buf指定的地址空间。

IPC_SET:该命令用来设置消息队列的属性,要设置的属性存储在buf中。

IPC_RMID:从内核中删除msgqid标识的消息队列。

ftok函数:把一个已存在的路径名和一个整数标识转换成一个key_t值,称为IPC键。

key_t ftok(const char* pathname,int proj_id)

ftok的典型实现调用stat函数,然后组合一下三个值:

1、pathname所在的文件系统的信息(stat结构的st_dev成员);

2、该文件在本文系统内的索引节点号(stat结构的st_ino成员)

3、proj_id的低序8位(不能为0)

不能保证两个不同的路径名与同一个proj_id的组合产生不同的键,因为上面所列三个条目(文件系统标识符、索引节点、proj_id)中的信息位数可能大于一个整数的信息位数。

时间: 2024-11-05 10:02:56

linux消息队列概念的相关文章

LINUX消息队列实战之一

前言 能说能抄能论皆不算,能写能打才是真功夫. 唠叨 反正我也是一个孤独的程序猿,多说一些奇奇怪怪的唠叨也无妨,第一次写消息队列,书本的东西和实战很不同,根据实战总结的一些注意事项会和大家分享,也敲打敲打自己,以后别总是想当然,要头顶蓝天,脚踩大地,做一个能文亦能武的敦厚男人. 简介 消息队列是linux提供的一种便利的IPC机制,不具有任何血缘关系的程序可以通过消息队列进行便利的通信:不同的程序通过同样的key访问同一个消息队列,支持不同优先级的消息队列,效率较高且使用便利. 消息队列常用的几

Linux消息队列基础

消息队列基本概念 消息队列提供了一个从一个进程向另外一个进程发送一块数据的方法(仅局限与本机) 每个数据块都被认为是有一个类型,接收者进程接收的数据块可以有不同的类型值 消息队列也有管道一样的不足,就是每个消息的最大长度是有上限的(MSGMAX),每个消息队列的总的字节数是有上限的(MSGMNB),系统上消息队列的总数也有一个上限(MSGMNI) 管道 vs. 消息队列: 管道: 流管道          消息: 有边界 先进先出            可以后进入.先出来 消息队列大小三大限制

Linux消息队列实践(1)

消息队列基本概念 消息队列提供了一个从一个进程向另外一个进程发送一块数据的方法(仅局限与本机) 每个数据块都被认为是有一个类型,接收者进程接收的数据块可以有不同的类型值 消息队列也有管道一样的不足,就是每个消息的最大长度是有上限的(MSGMAX),每个消息队列的总的字节数是有上限的(MSGMNB),系统上消息队列的总数也有一个上限(MSGMNI) 管道 vs. 消息队列: 管道: 流管道          消息: 有边界 先进先出            可以后进入.先出来 消息队列大小三大限制

消息队列概念与认知

本文是-消息队列学习的概念与介绍篇.目的是能够对消息队列能够有一个简单的了解和大体的认知. 参考/学习资料整理(好东西要学会分享 ) B站上的黑马ActiveMQ的视频教程 Hollis公众号上的消息队列文章 架构之家公众号上的消息队列文章 JavaGuide(一份涵盖大部分Java程序员所需要掌握的核心知识的文档类项目) CS-Notes(技术面试必备基础知识) JCSprout(处于萌芽阶段的 Java 核心知识库) 一个在线绘图的工具 一.消息队列简介 消息队列 MQ(message qu

linux 消息队列 参数

消息队列 一.函数 mq_open 头文件 mqueue.h: 原型 mqd_t mq_open(const char *name, int oflag, .../*mode_t mode,struct mq_attr* attr*/); 函数功能 创建消息队列: 参数 name :消息队列的名字,根据消息队列的规则,为了更好的可移植性,该名字必须以‘/’开头,创建一个消息队列的时候无须路径,给出名字就好,其存放位置可有自己指定(创建前后都可以). oflag:O_RDONLY(只读) O_WR

Linux 消息队列编程

消息队列.信号量以及共享内存被称作 XSI IPC,它们均来自system V的IPC功能,因此具有许多共性. 键和标识符: 内核中的每一种IPC结构(比如信号量.消息队列.共享内存)都用一个非负整数的标识符加以标示(如共享内存的shmid.信号量的semid.以及消息队列的msgid).不同于文件描述符,IPC标识符不是一个小的非负整数,它是一个int型的整数,当一个标识符被创建,以后又被删除时,这个整数持续加1,达到整型的最大值后,重新回到0. 但是每一个IPC对象在内核中的标识符只能在内部

linux消息队列操作

对消息队列的操作无非有以下三种类型: 1. 打开或创建消息队列消息队列的内核持续性要求每一个消息队列都在系统范围内相应唯一的键值,所以,要获得一个消息队列的描写叙述字,仅仅需提供该消息队列的键值就可以: 注:消息队列描写叙述字是由在系统范围内唯一的键值生成的,而键值能够看作相应系统内的一条路经. 2. 读写操作 消息读写操作很easy,对开发者来说,每一个消息都相似例如以下的数据结构: struct msgbuf{ long mtype; char mtext[1]; }; mtype成员代表消

linux消息队列应用编程

消息队列:  消息队列提供了一个从一个进程向另外一个进程发送一块数据的方法   每个数据块都被认为是有一个类型,接收者进程接收的数据块可以有不同的类型值   消息队列也有管道一样的不足,就是每个消息的最大长度是有上限的(MSGMAX),每个消息队列的总的字节数是有上限的(MSGMNB),系统上消息队列的总数也有一个上限(MSGMNI) 对比管道和消息: 管道:流管道        消息:有边界 先进先出              可以后进入.先出来 消息大小三大限制 cat /proc/sys/

linux消息队列相关操作

/* 发送消息队列 */ #include <stdio.h>#include <stdlib.h>#include <string.h>#include <sys/types.h>#include <sys/stat.h>#include <fcntl.h>#include <sys/ipc.h>#include <sys/msg.h> struct mymsg { long mtype; /* messag