linux c消息队列msgsnd多进程发送
时间: 2023-07-06 14:07:54 浏览: 191
linux c 进程间通信 消息队列
在 Linux C 中使用消息队列进行进程间通信是一种常见的方式。使用 `msgsnd` 函数可以向消息队列中发送消息。下面是一个多进程发送消息到消息队列的示例代码:
```c
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#define MSG_SIZE 1024
struct msgbuf {
long mtype;
char mtext[MSG_SIZE];
};
int main() {
key_t key;
int msgid;
char *msg = "Hello, world!";
struct msgbuf buf;
// 创建消息队列
key = ftok(".", 'a');
msgid = msgget(key, IPC_CREAT | 0666);
if (msgid == -1) {
perror("msgget");
exit(EXIT_FAILURE);
}
// 发送消息
for (int i = 0; i < 3; ++i) {
buf.mtype = i + 1;
strncpy(buf.mtext, msg, MSG_SIZE);
if (msgsnd(msgid, &buf, strlen(buf.mtext) + 1, 0) == -1) {
perror("msgsnd");
exit(EXIT_FAILURE);
}
printf("Sent message '%s' to queue with type %ld\n", buf.mtext, buf.mtype);
}
return 0;
}
```
在这个示例中,我们首先使用 `ftok` 函数创建一个用于生成消息队列的 key。然后使用 `msgget` 函数创建一个消息队列,如果创建失败则输出错误信息并退出程序。
接下来,我们使用 `msgsnd` 函数向消息队列中发送消息。`msgsnd` 函数接收三个参数:消息队列 ID、消息指针和消息长度。在这里,我们将消息类型设置为 `i+1`,并将消息内容设置为 "Hello, world!"。发送完毕后,输出成功发送的消息内容和消息类型。
在实际应用中,我们可以使用 `fork` 函数创建多个进程,每个进程都可以通过 `msgsnd` 向消息队列发送消息。同时,我们也可以使用 `msgrcv` 函数从消息队列中接收消息。
阅读全文