linux.调整收发队列,linux消息队列通信
程序目的:学习linux消息队列通信
所用主要函数:msgget(),msgsnd(),msgrcv(),msgctl()
首先介绍每个函数的用法:
(1)msgget
使用格式:
#include
#include
#include
int msgget(key_t k e y, int f l a g) ;
功能:是打开一个现存队列或创建一个新队列。
返回值:成功执行时,返回消息队列标识值。失败返回-1,有时也会返回0,这个时候也是可以正常使用的。
参数key:消息队列关联的键,可以直接赋值设为固定的的键值。也可以用ftok()。
也介绍一下ftok函数key_t ftok( char * fname, int id )
fname就是你指定的文件名(已经存在的文件名),一般使用当前目录;id是子序号。
这样就能得到一个固定的key_t值。
参数f l a g:消息队列的建立标志和存取权限,建立标志一般为指定为IPC_CREAT和IPC_EXCL标志 。
IPC_CREAT:如果内核中没有此队列,则创建它。当IPC_CREAT和IPC_EXCL一起使用时,如果队列已经存在,则失败。
例:msgget(ftok("./file",123),IPC_CREAT |0666)
(2)msgsnd
功能:在消息队列上进行收发消息。为了发送消息,调用进程对消息队列必须有写权能。接收消息时必须有读权能。
使用格式:
#include
#include
#include
int msgsnd(int msqid, const void *msgp, size_t msgsz, int msgflg);
返回值:成功执行时,返回消息队列标识值。失败返回-1。
参数:
msqid:消息队列的识别码。
msgp:指向消息缓冲区的指针,此位置用来暂时存储发送和接收的消息,是一个用户可定义的通用结构,如下
struct msgbuf {
long mtype; //消息类型,必须 大于0
char mtext[1]; // 消息文本
};
msgsz:消息的大小。
msgflg:用来指明核心程序在队列没有数据的情况下所应采取的行动。当msgflg为IPC_NOWAIT不会阻塞。当msgflg为0时msgsnd()在队列呈满或呈空的情形时,采取阻塞等待的处理模式。
(3)msgrcv
使用格式:
#include
#include
#include
ssize_t msgrcv(int msqid, void *msgp, size_t msgsz, long msgtyp, int msgflg);
参数:(同上2)
msgtyp:消息类型
其他参数同上(2)。
(4)msgctl
原型: int msgctl ( int msgqid, int cmd, struct msqid_ds *buf );
返回值: 如果成功为0 错误返回- 1。
参数msgqid :是消息队列对象的标识符。
第二个参数cmd:是函数要对消息队列进行的操作,它可以是:
IPC_STAT取出系统保存的消息队列的msqid_ds 数据,并将其存入参数buf 指向的msqid_ds 结构
中。
IPC_SET设定消息队列的msqid_ds 数据中的msg_perm 成员。设定的值由buf 指向的msqid_ds
结构给出。
IPC_EMID将队列从系统内核中删除。
这三个命令的功能都是明显的。唯一需要强调的是在IPC_STAT
命令中队列的msqid_ds 数据中唯一能被设定的只有msg_perm 成员,是ipc_perm 类型的
数据。而ipc_perm 中能被修改的只有mode,pid 和uid 成员。其他的都是只能由系统来设定
的。
******************************有关范例*********************************************
下面就看一个用消息队列通信写的一个简单的银行取号小程序:
在这里我用到了两个进程:msgc.c 和 msg.c
(1)msg.c
#include
#include
#include
#include
#include
#define MSG_KEY 8888
struct mymesg{
long mtype;//消息类型
char mtext[512];//消息内容
};
int main(void)
{
int msgid;
struct msqid_ds buf;
struct mymesg mymsg;
msgid=msgget(MSG_KEY,IPC_CREAT |0600);//创建一个新队列
if(-1==msgid)
{
perror("msggit");
exit(EXIT_FAILURE);
}
while(1)
{
printf("请输入号码和内容:\n");
scanf("%d %s",&mymsg.mtype,mymsg.mtext);
msgsnd(msgid,&mymsg,strlen(mymsg.mtext)+1,0);//发送mymsg中的信息到msgid对应的消息队列
}
return 0;
}
(2)msg.c
#include
#include
#include
#include
#include
#define MSG_KEY 8888
struct mymesg{
long mtype;
char mtext[512];
};
int main(void)
{
int msgid;
struct mymesg mymsgrcv;
msgid=msgget(MSG_KEY,IPC_CREAT |0600);
if(-1==msgid)
{
perror("msggit");
exit(EXIT_FAILURE);
}
while(1)
{
printf("请选择号码:");
scanf("%d",&mymsgrcv.mtype);
int ms=msgrcv(msgid,&mymsgrcv,512,mymsgrcv.mtype,0);//接收消息队列相应类型(号码)信息
if(-1==ms)
{
perror("msgrcv");
exit(EXIT_FAILURE);
}
printf("received:%s\n",mymsgrcv.mtext);
}
int msg=msgctl(msgid,IPC_RMID,0);//将队列从系统内核中删除。
if(-1==msg)
{
perror("msgctl");
exit(EXIT_FAILURE);
}
return 0;
}
/*********************程序运行结果*********************
[root@localhost msg]#gcc -o msg.c msg.c
[root@localhost msg]# ./msg.c第一个进程
请输入号码和内容:
1 Personal business
请输入号码和内容:
2 company business
请输入号码和内容:
3 Other business
[root@localhost msg]# gcc -o msgc.c msgc.c
[root@localhost msg]# ./msgc.c第二个进程
请选择号码:1
received:Personal business
请选择号码:2
received:company business
……
***********************************************************/
本人初学者,在写本博文中可能有一些不当的地方,欢迎大家向我指正。
linux.调整收发队列,linux消息队列通信相关推荐
- Linux进程间通讯之消息队列
首先有个大体的概念:http://www.xefan.com/archives/83703.html 头文件: #include <sys/ipc.h> #include <sys/ ...
- linux 消息队列_Linux消息队列
消息队列,Unix的通信机制之一,可以理解为是一个存放消息(数据)容器.将消息写入消息队列,然后再从消息队列中取消息,一般来说是先进先出的顺序.可以解决两个进程的读写速度不同(处理数据速度不同),系统 ...
- Linux进程间通信二 System V 消息队列简介与示例
1. SystemV消息队列简介 消息队列,顾名思义即是存放消息的队列,内核为每个SystemV 维护了一个msg_queue的结构体,里面记录了每个消息队列的信息. struct msg_queue ...
- linux进程间通信:system V消息队列
文章目录 基本介绍 编程接口 代码实例 消息队列的发送和接收 消息队列中的消息对象的属性控制 基本介绍 支持不同进程之间以消息(messages)的形式进行数据交换,消息能够拥有自己的标识,且内核使用 ...
- 【Linux系统编程】进程间通信--消息队列
概述 消息队列提供了一种在两个不相关的进程之间传递数据的简单高效的方法,其特点如下: 1)消息队列可以实现消息的随机查询.消息不一定要以先进先出的次序读取,编程时可以按消息的类型读取. 2)消息队列允 ...
- 消息队列——RabbitMQ消息队列集群
RabbitMQ消息队列集群 消息队列/中间件 RabbitMQ详解 RabbitMQ单机部署 RabbitMQ集群部署 消息队列/中间件 一.前言 在我们秒杀抢购商品的时候,系统会提醒我们稍等排队中 ...
- rabbitmq导出队列_消息队列BCMQ在大云运维管理平台BCDeepWatch中的应用
友情提示:全文约2600字,预计阅读时间12分钟 摘要 消息队列作为重要的中间件,广泛用于分布式系统中各子系统间的异步解耦:本文主要介绍了大云消息队列中间件BC-MQ在BC-DeepWatch中的应用 ...
- 阿里Java面试题剖析:为什么使用消息队列?消息队列有什么优点和缺点?
面试题 为什么使用消息队列? 消息队列有什么优点和缺点? Kafka.ActiveMQ.RabbitMQ.RocketMQ 都有什么区别,以及适合哪些场景? 面试官心理分析 其实面试官主要是想看看: ...
- 队列和消息队列_消息队列概述[幻灯片]
队列和消息队列 昨天,我进行了一次演讲,探讨了使用消息队列的所有方面. 我以前曾写过"您可能不需要消息队列" –现在的结论有些细微差别,但我仍然坚持简单性的观点. 演讲探讨了使用消 ...
- 消息队列面试 - 为什么使用消息队列,消息队列有什么优点和缺点?
消息队列面试 - 为什么使用消息队列,消息队列有什么优点和缺点? 面试题 为什么使用消息队列? 消息队列有什么优点和缺点? Kafka.ActiveMQ.RabbitMQ.RocketMQ 都有什么区 ...
最新文章
- phpcms数据库操作
- GDOI2018 总结
- TCP/IP详解学习笔记(2)-数据链路层
- [Python从零到壹] 十四.机器学习之分类算法五万字总结全网首发(决策树、KNN、SVM、分类对比实验)
- redis.exceptions.ResponseError: WRONGTYPE Operation against a key holding the wrong kind of value
- android:layout_width=0.0dip,【教程】状态栏显示网速
- 大数据(big data)_如何使用Big Query&Data Studio处理和可视化Google Cloud上的财务数据...
- mysql建表主键_常见的MySQL命令大全second
- (转)基于MVC4+EasyUI的Web开发框架经验总结(5)--使用HTML编辑控件CKEditor和CKFinder...
- oracle转类型sql,[转]SQL Server 和Oracle 数据类型对应
- 《游戏设计艺术(第2版)》——学习笔记(15)第15章 玩家通过界面玩游戏
- [ubuntu][原创]ubuntu18.04安装rabbitvcs正确方法
- badboy 录制脚本,提示:“当前页面的脚本发生错误”
- 捋一捋Condition
- python3 笔记6 字符串
- 计算机论文一千五,1.论文字数不够,正文要五千字,至少增加1000,但不要抄袭.DOC...
- 基础算法--背包问题(01背包问题、完全背包问题、多重背包问题、分组背包问题)
- html实现手风琴菜单
- Java实现课程推荐算法
- 作用域插槽、slot-scope、v-slot指令