linux测试消息队列阻塞,Linux进程间通信:消息队列
一、消息队列的特点
1.消息队列是消息的链表,具有特定的格式,存放在内存中并由消息队列标识符标识.
2.消息队列允许一个或多个进程向它写入与读取消息.
3.管道和命名管道都是通信数据都是先进先出的原则。
4.消息队列可以实现消息的随机查询,消息不一定要以先进先出的次序读取,也可以按消息的类型读取.比FIFO更有优势。
目前主要有两种类型的消息队列:POSIX消息队列以及系统V消息队列,系统V消息队列目前被大量使用。系统V消息队列是随内核持续的,只有在内核重起或者人工删除时,该消息队列才会被删除。
二、相关函数
1. 获得key值
key_t ftok(char *pathname, int projid)
#include
#include
参数:
pathname:文件名(含路径),通常设置为当前目录“.”
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];//消息正文,消息数据的首地址
}
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
21/212>
linux测试消息队列阻塞,Linux进程间通信:消息队列相关推荐
- linux测试tcp长连接工具,Linux(服务器编程):44---TCP长连接、短连接(心跳检测)
一.TCP连接的相关说明 ①使用TCP协议时,会在客户端和服务器之间建立一条虚拟的信道,这条虚拟信道就是指连接,而建议这条连接需要3次握手,拆毁这条连接需要4次挥手,可见,我们建立这条连接是有成本的, ...
- linux测试读写的工具,Linux 下的硬盘读写速度测试工具
Linux 下的硬盘读写速度测试工具 执行一下以下命令看看你服务器的磁盘性能如何. hdparm -Tt /dev/sda 以下是 2块 希捷 ES2 SATA 500G 做 Raid0 的速度 [r ...
- linux测试并发的工具,Linux下使用Jmeter测试并发
安装前:必须安装java(此处忽略java安装,百度一大推) 一.安装:官网下载包 >>>http://jmeter.apache.org/download_jmeter.cgi ...
- linux 测试路由速度慢,LINUX服务器性能常用测试脚本 – 硬件信息/网速/延迟/路由等...
SuperBench.sh 脚本: wget -qO- git.io/superbench.sh | bash curl -LsO git.io/superbench.sh; chmod +x sup ...
- linux测试硬盘的ipos,Linux/Unix平台data-recovery常用的工具
数据恢复中经常会遇到linux或是Unix,如果无法把存储链接到windows的话,就没有办法使用像winhex这样的16进制磁盘编辑软件,也就更谈不上分析存储结构! 在这种情况下可以使用ddddd. ...
- linux测试dvi接口,支持Linux系统的高清DVI采集卡推荐
支持Linux系统的高清DVI采集卡推荐 作者:同三维视频网 发表时间: 2019-05-17阅读:次 虽然现在的电脑系统大多已经是windows系统了,但不乏有一些Linux系统的电脑也需要采集它的 ...
- django多任务开启rabbitmq,并进行声明队列、发送、阻塞监听消息
一,编写rabbitmq基础模块类 1,安装pika模块 pip install pika 这里需要注意的是: pika官网明确说明 pika==0.11.0版本只支持python2.6以前的版本. ...
- Linux测试常用命令
Linux测试常用命令 1.Linux安装 2.linux常用命令 1.一些Linux环境下的基本操作 2. 目录管理 3.文件管理 4.文件权限 5.备份压缩 6.系统设置及网络相关命令 3.总结 ...
- linux vmware文件互传,Linux与Windows文件互传(VMWare)
Linux与Windows文件互传(VMWare) 虚拟机无桌面的Linux 与 物理机Windows 文件互传有很多种方法,现在先说一种通过共享文件夹的形式,其他方法后续再补充 1.背景 1) 虚拟 ...
- Linux的进程间通信-消息队列
Linux的进程间通信-消息队列 微博ID:orroz 微信公众号:Linux系统技术 前言 Linux系统给我们提供了一种可以发送格式化数据流的通信手段,这就是消息队列.使用消息队列无疑在某些场景的 ...
最新文章
- mysql存储过程 delete select insert_mysql常见操作语句,建表,增删改查
- SAP HUM事务代码 HUMAT 之初探
- Ubuntu 16.04 安装Python 3.6
- 那份让我想死的化工原理补考试卷
- python标准库有pickle_Python标准库05 存储对象 (pickle包,cPickle包)-阿里云开发者社区...
- webpack:Cannot find module 'extract-text-webpack-plugin'
- Ogre实现简单地形
- python中求列表的最大最小值,如何在python中获取列表的最小和最大元素
- Raki的读paper小记:LOOKING BACK ON LEARNED EXPERIENCES FOR CLASS/TASK INCREMENTAL LEARNING
- 我的 Java 自学之路
- VB 2010中Excel文件处理的一个奇怪问题
- 强化学习Q-Learning实现机器人走迷宫
- 类似endnote_Mendeley与EndNote类似的免费文献管理软件简介 | 科研动力
- IERS EOP 文件的解读
- 凯文·凯利:AI将改变一切设计工作
- 世界时间UT和协调世界时间UTC
- 在LabVIEW中如何使用Flash动画
- SSA ASS (Advanced SubStation Alpha) 字幕
- 新媒体运营岗位有哪些
- SSH框架总结,超详细
热门文章
- web测试之功能测试总结
- 华为荣耀V9手机通过在Fastboot模式写ramdisk.img来获取ROOT权限 | 华为荣耀V9怎么获取ROOT权限 | 华为荣耀V9怎么用面具Magisk做ROOT权限
- 在线答题-问卷调查小系统(附源码)
- 基于 Mybatis 和 Springboot 的后台管理系统 BootDo | 软件推介
- linux识别riser卡,一种应用在GPU服务器中可灵活配置的Riser卡的制作方法
- pci-e服务器显卡性能,PCI-E带宽揭密 显卡究竟能吃多大的带宽
- 最火特效软件ae手机版制作抖音快手热门飞天腾云驾雾特效的教程。
- obs studio 开源直播软件 简介
- Adobe Photoshop CC 2014图文永久安装教程
- Hspice学习资源和心得