让你学会使用Linux中的消息队列mqueue（linux mqueue）

消息队列是一种常见的进程间通信（IPC）机制，是Linux内核中提供的一种支持POSIX规范的消息队列，允许应用程序通过消息传递进行进程间通讯。本文将介绍如何在Linux中使用消息队列mqueue。

在使用消息队列mqueue之前，我们需要了解它的核心概念，如队列，消息等。队列为消息提供一个公共储存空间，发送消息的进程把消息放到队列，接收消息的进程从队列接收消息。消息由四部分组成：消息头、消息参数、消息特殊数据和消息正文。

在使用消息队列mqueue之前，必须先设置内核，加载mqueue内核模块，并创建消息队列。在Linux 2.6.20之前，内核是没有支持mqueue机制的，所以首先要内核支持，在内核的配置工具“make menuconfig”中可以看到：

Device Drivers --> POSIX Message Queue support
            [/ ]   POSIX Message Queue support

使能“POSIX Message Queue support”驱动，将它设置成*号，然后编译，完成后重新加载内核驱动的可执行文件，就可以使用mqueue了。

接下来，就可以开始使用mqueue了，首先创建消息队列：

“`cpp

// 创建队列

mqd_t mq_open(

const char *name,

int oflag,

mode_t mode,

struct mq_attr *attr);

name参数为队列名称，oflag是一个正整数，用于控制创建队列的方式，mode参数控制文件的权限，attr参数用于控制队列的大小和参数，mq_open函数成功后返回队列的描述符，失败返回-1。

然后就可以使用消息队列进行消息传递了，可以使用以下函数进行发送或接收：

```cpp
// 发送消息
int mq_send(mqd_t mqdes, const char *msg_ptr, size_t msg_len, unsigned int msg_prio);

// 接收消息
ssize_t mq_receive(mqd_t mqdes, char *msg_ptr, size_t msg_len, unsigned int *msg_prio);

发送消息函数mq_send的第一个参数为队列的描述符，第二个参数是消息的正文，第三个参数是消息正文的长度，第四个参数msg_prio为消息的优先级，越小优先级越高，返回0说明发送成功，-1发送失败，接收消息函数mq_receive比较简单了，只需要传递上面提到的几个参数，接收成功返回消息的长度，失败返回-1。

当消息传递完毕后，必须关闭消息队列：

“`cpp

// 关闭队列

mq_close(mqd_t mqdes);

总体来说，Linux中使用消息队列mqueue进行消息传递，还是比较简单的，在添加内核支持、使用mq_open函数创建队列、发送消息、接收消息和最后关闭队列四个部分，就完成了消息队列mqueue的使用。