C语言消息队列(MQ)函数详解及应用示例393

在C语言中，并没有直接内置的消息队列(Message Queue, MQ)函数。消息队列是一种进程间通信(IPC)机制，允许不同进程之间通过发送和接收消息进行异步通信。要使用消息队列，需要借助操作系统提供的API，最常见的是POSIX消息队列（使用mq_open, mq_send, mq_receive等函数）以及System V消息队列（使用msgget, msgsnd, msgrcv等函数）。本文将详细介绍POSIX消息队列的相关函数及其使用方法，并提供完整的代码示例。

POSIX消息队列

POSIX消息队列提供了一种更现代、更灵活的消息队列机制。它比System V消息队列更易于使用，并且具有更好的可移植性。下面列出了一些关键的POSIX消息队列函数：
mqd_t mq_open(const char *name, int oflag, mode_t mode, struct mq_attr *attr);: 创建或打开一个消息队列。

name: 消息队列的名称，用于标识消息队列。
oflag: 打开模式标志，例如O_RDONLY, O_WRONLY, O_RDWR, O_CREAT, O_EXCL等。
mode: 文件权限模式，与chmod命令类似。
attr: 消息队列属性结构体，用于设置消息队列的属性，例如最大消息数和最大消息大小。

int mq_send(mqd_t mqdes, const char *msg_ptr, size_t msg_len, unsigned int msg_prio);: 发送消息到消息队列。

mqdes: 消息队列描述符，由mq_open返回。
msg_ptr: 消息指针。
msg_len: 消息长度。
msg_prio: 消息优先级。

ssize_t mq_receive(mqd_t mqdes, char *msg_ptr, size_t msg_len, unsigned int *msg_prio);: 从消息队列接收消息。

mqdes: 消息队列描述符。
msg_ptr: 接收消息的缓冲区指针。
msg_len: 缓冲区大小。
msg_prio: 接收消息的优先级。

int mq_close(mqd_t mqdes);: 关闭消息队列。
int mq_unlink(const char *name);: 删除消息队列。
int mq_getattr(mqd_t mqdes, struct mq_attr *attr);: 获取消息队列属性。
int mq_setattr(mqd_t mqdes, const struct mq_attr *attr, struct mq_attr *oattr);: 设置消息队列属性。

示例代码：

以下是一个简单的示例，演示了如何使用POSIX消息队列进行进程间通信：```c
#include
#include
#include
#include
#include
#include
#include
#define MQ_NAME "/my_message_queue"
#define MAX_MSG_SIZE 1024
int main() {
mqd_t mqd;
struct mq_attr attr;
char buffer[MAX_MSG_SIZE];
unsigned int prio;
// 设置消息队列属性
attr.mq_maxmsg = 10;
attr.mq_msgsize = MAX_MSG_SIZE;
attr.mq_curmsgs = 0;
attr.mq_flags = 0;

// 创建消息队列
mqd = mq_open(MQ_NAME, O_RDWR | O_CREAT | O_EXCL, 0666, &attr);
if (mqd == -1) {
perror("mq_open failed");
exit(1);
}
// 发送消息
char *message = "Hello from process 1!";
if (mq_send(mqd, message, strlen(message) + 1, 1) == -1) {
perror("mq_send failed");
exit(1);
}
printf("Sent message: %s", message);
// 接收消息 (在另一个进程中运行)
ssize_t bytes_received = mq_receive(mqd, buffer, MAX_MSG_SIZE, &prio);
if (bytes_received == -1) {
perror("mq_receive failed");
exit(1);
}
printf("Received message: %s, priority: %u", buffer, prio);
// 关闭消息队列
mq_close(mqd);
// 删除消息队列 (在程序结束时删除)
mq_unlink(MQ_NAME);
return 0;
}
```