【从浅学到熟知Linux】进程间通信之消息队列(含消息队列的特点,msgget/msgsnd/msgrcv/msgtrl接口使用详解、消息队列实现Client&Server)
消息队列是进程间通信(IPC)的一种方式,它可以在不同进程之间传递数据。消息队列是一种先进先出的数据结构,可以存储多个消息,每个消息都是一个数据块,包含类型和内容。
特点:
- 消息队列是消息的链接列表,存放在内核中。
- 消息队列可以实现异步通信。
- 消息队列可以保存多个消息,消息的发送方和接收方不需要同时执行。
- 消息队列是按照FIFO(First In, First Out)原则进行排列的。
相关函数:
msgget()
- 创建或访问一个消息队列。msgsnd()
- 发送一个消息到消息队列。msgrcv()
- 从消息队列接收一个消息。msgctl()
- 控制消息队列。
示例代码:
#include <stdio.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <string.h>
// 消息结构体
struct my_msg_st {
long int my_msg_type;
char some_text[100];
};
int main() {
key_t key = ftok("message_queue.c", 'R'); // 生成key
int msgid = msgget(key, 0666 | IPC_CREAT); // 创建消息队列
if (msgid == -1) {
perror("msgget");
exit(1);
}
struct my_msg_st msg1, msg2;
msg1.my_msg_type = 1;
strcpy(msg1.some_text, "Hello, Msg 1");
// 发送消息
if (msgsnd(msgid, &msg1, sizeof(struct my_msg_st), 0) == -1) {
perror("msgsnd");
exit(1);
}
// 接收消息
if (msgrcv(msgid, &msg2, sizeof(struct my_msg_st), 1, 0) == -1) {
perror("msgrcv");
exit(1);
}
printf("Message received: %s\n", msg2.some_text);
// 删除消息队列
if (msgctl(msgid, IPC_RMID, NULL) == -1) {
perror("msgctl");
exit(1);
}
return 0;
}
在这个示例中,我们首先使用ftok()
生成一个key,然后使用msgget()
创建一个新的消息队列或访问一个已存在的消息队列。接着,我们定义了一个消息结构体my_msg_st
,并使用msgsnd()
函数发送一个消息到队列中。最后,我们使用msgrcv()
函数从队列中接收一个消息,并打印出来。最后,使用msgctl()
删除消息队列。
评论已关闭