精通Unix下C语言编程与项目实践》之八 消息队列发送模型

简介:



《精通Unix下C语言编程与项目实践》之八

消息队列发送模型 
作者:朱云翔,胡平

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所示:
代码12-6 消息发送程序(节自/code/chapter12/msg1.c
#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值为57QNUM值为4,代表我们成功的写入了4条消息共57个字符信息。请确保执行程序msg1前消息队列0x1234不存在,或队列为空,否则显示的结果将不一致。



 本文转自 zhuyunxiang 51CTO博客,原文链接:http://blog.51cto.com/zhuyunxiang/135721,如需转载请自行联系原作者


相关文章
|
22天前
|
存储 C语言
C语言中的if语句编程
C语言中的if语句编程
28 0
|
16天前
|
算法 测试技术 C语言
初阶编程题积累(1)------[C语言]
初阶编程题积累(1)------[C语言]
15 2
|
16天前
|
算法 C语言
初阶编程题积累(2)------[C语言]
初阶编程题积累(2)------[C语言]
11 1
|
29天前
|
存储 安全 程序员
C语言:深入探索与实践
这篇文章探讨了C语言的关键特性和广泛应用。C语言以其结构化编程、指针操作、中间级语言特性和出色的可移植性,在操作系统、嵌入式系统、游戏开发及应用程序等领域中占据重要地位。文中通过代码示例展示了C语言的基本用法,如输入输出、数组与循环以及函数应用。尽管C语言在内存管理和错误处理上存在挑战,但它仍然是编程领域不可或缺的工具,随着技术进步,其影响力预计将持续。
|
29天前
|
网络协议 编译器 数据处理
C语言:其独特的魅力、广泛的应用领域与深入的代码实践
C语言以其简洁语法和高效性能在编程世界中闪耀,适用于系统编程、嵌入式、游戏开发和网络通信等领域。其独特魅力包括底层访问能力、高效稳定、灵活数据结构和良好可移植性。通过代码示例展示其基本语法和功能,C语言是理解计算机科学和创建高性能程序的关键工具。
|
16天前
|
C语言
C语言学习记录——鹏哥扫雷项目实现及递归展开、记录雷坐标
C语言学习记录——鹏哥扫雷项目实现及递归展开、记录雷坐标
19 0
|
17天前
|
C语言
C语言结构体教程:从入门到实践(保姆式教学)
C语言结构体教程:从入门到实践(保姆式教学)
13 0
|
17天前
|
C语言
C语言中求x的n次方:从入门到实践(保姆式教学)
C语言中求x的n次方:从入门到实践(保姆式教学)
19 0
|
22天前
|
存储 C语言
C语言中的switch语句编程
C语言中的switch语句编程
12 0
|
24天前
|
存储 C语言
向函数传递字符串: C语言中的技术与实践
向函数传递字符串: C语言中的技术与实践
43 0

热门文章

最新文章