《精通Unix下C语言编程与项目实践》之八 消息队列发送模型 推荐
2009-03-06 11:54
357 查看
文章试读 | 不拘一个遍程序系列:编程序不能一个脑袋钻到底,有时要学会变通,即所谓的曲线救国。一、二、三、四 职场规划:一些杂七杂八的职场感悟吧。不值钱的软件人才 精力充沛与事业成功 让系分来得更猛烈些吧 不值钱的系统分析师 我的诗歌:都是我的打油诗,但是很值得一读。不要工作还衣食无忧之四难歌 香格里拉美人图 宝宝图片:超可爱的小宝宝 写博客 考试培训:主要是关于考研、软考和等级的相关题解。2009考研试题分析 2008年12月程序员试题分析 2009年软考备考全攻略 2008年5月程序员试题解析 |
[align=center]消息队列发送模型 [/align]
[align=center]作者:朱云翔,胡平[/align]
12.4.2 消息队列发送模型
本处设计一个小例子描述发送消息的实际步骤,本例要求以阻塞方式向消息队列(关键字为KEY)中写入字符串“Hello Unix!”,消息类型为TYPE。全部过程共分为5个步骤:
1. 定义消息结构
参照代码12-4,定义以下消息结构:struct msgbuf
{
long mtype; /* 消息类型 */
char ctext[100]; /* 消息数据 */
};
2. 打开(创建)消息队列
int msgid;msgid = msgget(KEY, 0666|IPC_CREAT);
if (msgid < 0) 打开(创建消息失败)
如果msgid值非负,表示打开(或创建)消息队列成功。
3. 组装消息
设置消息类型和拷贝消息数据:struct msgbuf buf; /* 申请消息缓冲 */
buf.mtype = 100; /* 设置消息类型 */
strcpy(buf.ctext, "HELLO Unix!"); /* 拷贝消息数据 */
4. 发送消息
万事俱备,只欠东风,调用函数msgsnd完成消息发送:int ret;
ret = msgsnd(msgid, &msg, strlen(msg.ctext), 0);
注意,参数msgsz只是消息数据的长度,不包含消息类型长度。
5. 发送判断
在计算机程序设计中,售后处理非常重要,如下所示:if (ret == -1)
{
if (errno == EINTR) 信号中断,重新发送;
else 系统错误
}
进程在发送消息过程中如果接收到信号,将中止消息发送并返回EINTR错误,此时重新发送即可。
实例
本处设计一个消息发送的例子,它循环读取键盘输入,并将输入的字符串信息写入到消息队列(关键字为0x1234)中,如代码12-6所示:[align=center]代码12-6 消息发送程序(节自/code/chapter12/msg1.c)[/align]
#include <sys/msg.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <stdio.h>
#include <sys/errno.h>
extern int errno;
struct mymsgbuf /* 定义消息结构 */
{
long mtype; /* 消息类型 */
char ctext[100]; /* 消息数据 */
};
void main()
{
struct mymsgbuf buf; /* 申请消息缓冲 */
int msgid;
/* 打开(或创建)消息队列 */
if ((msgid = msgget(0x1234, 0666|IPC_CREAT)) < 0)
{
fprintf(stderr, "open msg %X failed.\n", 0x1234);
return ;
}
while (strncmp(buf.ctext, "exit", 4))
{
memset(&buf, 0, sizeof(buf));
/* 从键盘输入消息数据内容 */
fgets(buf.ctext, sizeof(buf.ctext), stdin);
/* 设置消息类型为进程ID */
buf.mtype = getpid();
/* 发送消息 */
while ((msgsnd(msgid, &buf, strlen(buf.ctext), 0)) < 0)
{
if (errno == EINTR) continue; /* 信号中断,重新发送 */
return;
}
}
}
编译和运行代码12-6:
# make msg1
cc -O -o msg1 msg1.c
# ./msg1
Please input:Hello World!
Please input:Hello Every Body!
Please input:读者朋友们,你们好!
Please input:exit
函数strncmp对字符串大小进行判断,当两个字符串参数完全相等时返回0,否则返回其它值。
程序调用fgets直接使用消息数据缓冲区存储输入,请确保输入字符串不要超过最大缓冲区限制,即本例中定义的99个字符(最后一个存储ASCII码的“0”),当用户输入“exit”时程序结束。上例中共发送了4条消息。
执行ipcs命令查询消息发送信息:
# ipcs -a -q
T ID KEY MODE OWNER GROUP CREATOR CGROUP CBYTES QNUM QBYTES LSPID LRPID STIME RTIME CTIME
Message Queues:
q 162 0x00001234 --rw-rw-rw- root sys root sys 57 4 65532 1285 0 12:08:45 no-entry 12:08:28
如上所示,CBYTES值为57,QNUM值为4,代表我们成功的写入了4条消息共57个字符信息。请确保执行程序msg1前消息队列0x1234不存在,或队列为空,否则显示的结果将不一致。
相关文章:
封面 前言 目录 策划 作者
动态库 变长参数 文件锁 外设 僵死进程
定时器 I/O重定向 消息队列
相关文章推荐
- rabbitmq用法--直接发送消息给队列
- 消息队列普通消息的发送
- PHP 命令行模式实战之cli+mysql 模拟队列批量发送邮件(在Linux环境下PHP 异步执行脚本发送事件通知消息实际案例)
- Android 的消息队列模型
- 消息队列实现接收发送的例子
- Activemq 消息发送、接收java代码实现队列模式
- MSMQ-发送消息到远程专用队列path格式
- MSMQ-发送消息到远程专用队列 实例
- 消息队列的发送与接收
- 用消息发送队列提高网络应用处理效率
- jsdt 插件 httpclient模型发送消息至服务端
- Android消息队列模型——Thread,Handler,Looper,Massage Queue
- 2--消息队列(报文队列)实践到内核--消息的发送
- Apache ActiveMQ 5.9.0发送消息成功后,在WEB界面点击队列中的Message ID 查看消息提示提示Error!
- Android 的消息队列模型
- Posix消息队列的基本操作——发送消息
- 转:Android 的消息队列模型
- Android进程和线程 --消息队列模型 (Looper, MessageQueue, Handler) (1)
- Android消息队列模型介绍
- SpringBoot的RabbitMQ消息队列: 一、消息发送接收第一印象