62 lines
2.1 KiB
C
62 lines
2.1 KiB
C
|
#include <stdio.h>
|
|||
|
|
#include <sys/types.h> // 系统数据类型定义
|
|||
|
|
#include <sys/ipc.h> // IPC相关头文件
|
|||
|
|
#include <sys/msg.h> // 消息队列相关头文件
|
|||
|
|
#include <string.h> // 字符串操作
|
|||
|
|
#include <stdlib.h> // atol 函数
|
|||
|
|
|
|||
|
|
// 消息结构体
|
|||
|
|
typedef struct msg_
|
|||
|
|
{
|
|||
|
|
long mType; // 消息类型，必须是 long ，必须在第一个位置
|
|||
|
|
char content[100]; // 消息内容，需要小于消息队列的限制值(8192)
|
|||
|
|
char title[32]; // 消息标题
|
|||
|
|
|
|||
|
|
} MSG;
|
|||
|
|
|
|||
|
|
// msgget 函数用于创建消息队列，参数1是键值，参数2是权限
|
|||
|
|
int main(int argc, char *argv[])
|
|||
|
|
{
|
|||
|
|
// 参数个数判断
|
|||
|
|
if (argc != 2)
|
|||
|
|
{
|
|||
|
|
printf("Usage: %s <type>\n", argv[0]);
|
|||
|
|
return 1;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
key_t key = ftok("/", 200); // 获取消息队列的键值
|
|||
|
|
|
|||
|
|
int msgqid = msgget(key, IPC_CREAT | 0666); // 创建消息队列
|
|||
|
|
if (msgqid == -1)
|
|||
|
|
{
|
|||
|
|
perror("msgget");
|
|||
|
|
return 1;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 接收消息
|
|||
|
|
MSG msg; // 消息结构体
|
|||
|
|
long mtype = atol(argv[1]); // 消息类型
|
|||
|
|
|
|||
|
|
// 最后参数 0 表示阻塞，如果消息队列为空，接收消息的进程会阻塞
|
|||
|
|
ssize_t len = msgrcv(msgqid, &msg, sizeof(msg.content) + sizeof(msg.title), mtype, 0); // 接收消息
|
|||
|
|
printf("接收到的数据(%ld)，\n类型(%ld)，\n内容(%s)，\n标题(%s)\n", len, msg.mType, msg.content, msg.title); // 打印消息
|
|||
|
|
|
|||
|
|
return 0;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/*
|
|||
|
|
使用说明，配合 msgque2_sender.c (sender) 使用:
|
|||
|
|
1. 编译 msgque2_sender.c (sender) 和 msgque3_receiver.c (receiver)
|
|||
|
|
2. 运行 msgque2_sender.c (sender) 发送消息
|
|||
|
|
3. 运行 msgque3_receiver.c (receiver) 接收消息
|
|||
|
|
|
|||
|
|
使用时:
|
|||
|
|
./receiver <type>
|
|||
|
|
type 是消息类型，必须是整数，必须大于 0
|
|||
|
|
当 type 为 -5 时，接收到的消息是类型小于 5 的消息
|
|||
|
|
当 type 为 1 时，接收到的消息是类型为 1 的消息
|
|||
|
|
当 type 为 0 时，接收到的消息是类型为最小的消息
|
|||
|
|
|
|||
|
|
ipcs -q 可以查看消息队列
|
|||
|
|
ipcrm -q <msqid> 可以删除消息队列
|
|||
|
|
*/
|