sys V 进程间通信之消息队列

**SysV 消息队列进程间通信**

在多进程环境中，进程之间的通信是非常重要的一环。SysV（System V）提供了一种称为消息队列的进程间通信机制。消息队列是一种特殊的内存区域，允许进程将信息发送给其他进程。

**消息队列的基本概念**

消息队列由一个名为`msg_queue`的结构体来描述，它包含以下几个成员：

* `msg_perm`:该成员用于保存消息队列的权限信息。
* `msg_first`:该成员指向消息队列中第一个元素的位置。
* `msg_last`:该成员指向消息队列中最后一个元素的位置。

**创建消息队列**

要使用消息队列，首先需要创建一个消息队列。可以使用`msgget()`函数来完成这一步骤。这个函数返回一个唯一标识符（key），用于区分不同的消息队列。

c#include <sys/msg.h>
#include <stdio.h>

int main() {
 int msgid = msgget(IPC_PRIVATE, IPC_CREAT |0644);
 if (msgid == -1) {
 perror("msgget");
 return1;
 }
 printf("创建消息队列成功，key值为：%d
", msgid);
 return0;
}

在上面的代码中，我们使用`IPC_PRIVATE`作为消息队列的key，这意味着该消息队列将被私有化。同时，我们使用`IPC_CREAT |0644`来指定创建一个新的消息队列，并赋予它读写权限。

**发送消息**

要向消息队列中发送信息，可以使用`msgsnd()`函数。这个函数需要三个参数：消息队列的key、消息内容以及消息长度。

c#include <sys/msg.h>
#include <stdio.h>

int main() {
 int msgid = msgget(IPC_PRIVATE, IPC_CREAT |0644);
 if (msgid == -1) {
 perror("msgget");
 return1;
 }

 struct msgbuf {
 long mtype;
 char mtext[100];
 } message;

 message.mtype =1; // 消息类型 strcpy(message.mtext, "Hello, world!"); // 消息内容 if (msgsnd(msgid, &message, sizeof(message), IPC_NOWAIT) == -1) {
 perror("msgsnd");
 return1;
 }
 printf("发送消息成功
");
 return0;
}

在上面的代码中，我们首先使用`msgget()`函数创建一个新的消息队列，然后定义一个结构体来保存消息内容。最后，我们使用`msgsnd()`函数向消息队列中发送信息。

**接收消息**

要从消息队列中接收信息，可以使用`msgrcv()`函数。这个函数需要四个参数：消息队列的key、缓冲区地址、缓冲区大小以及阻塞标志。

c#include <sys/msg.h>
#include <stdio.h>

int main() {
 int msgid = msgget(IPC_PRIVATE, IPC_CREAT |0644);
 if (msgid == -1) {
 perror("msgget");
 return1;
 }

 struct msgbuf {
 long mtype;
 char mtext[100];
 } message;

 if (msgrcv(msgid, &message, sizeof(message),0, IPC_NOWAIT) == -1) {
 perror("msgrcv");
 return1;
 }
 printf("接收消息成功，内容为：%s
", message.mtext);
 return0;
}

在上面的代码中，我们首先使用`msgget()`函数创建一个新的消息队列，然后定义一个结构体来保存消息内容。最后，我们使用`msgrcv()`函数从消息队列中接收信息。

**删除消息队列**

要删除一个消息队列，可以使用`msgctl()`函数。这个函数需要三个参数：消息队列的key、命令类型以及缓冲区地址。

c#include <sys/msg.h>
#include <stdio.h>

int main() {
 int msgid = msgget(IPC_PRIVATE, IPC_CREAT |0644);
 if (msgid == -1) {
 perror("msgget");
 return1;
 }

 if (msgctl(msgid, IPC_RMID, NULL) == -1) {
 perror("msgctl");
 return1;
 }
 printf("删除消息队列成功
");
 return0;
}

在上面的代码中，我们首先使用`msgget()`函数创建一个新的消息队列，然后使用`msgctl()`函数删除该消息队列。

**总结**

SysV 消息队列是一种进程间通信机制，允许进程将信息发送给其他进程。通过使用`msgget()、msgsnd()、msgrcv()`和`msgctl()`函数，可以创建、发送、接收和删除消息队列。