进程间通信 + 消息队列-Toy模板网

这篇具有很好参考价值的文章主要介绍了进程间通信 + 消息队列。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

进程间通信

每个进程有各自不同的用户地址空间，任何一个进程的全局变量在另一个进程中都看不到，所以进程之间要交换数据必须通过内核，在内核中开辟一块缓冲区，进程1吧数据从用户空间考到内核缓冲区，进程2再从内核缓冲区吧数据读走，内核提供的这种机制成为进程间通信

管道

管道是一种最基本的ipc机制，由pipe函数创建

#include<unistd.h>

int pipi(int filedes[2])

调用pipe函数时在内核开辟一块缓冲区（管道）用于通信，它有一个读端和一个写端，然后通过filedes参数传出给用户程序两个文件描述符，filedes[0]指向管道的读端，filedes[1]指向管道的写端（就像0是标准输入，1是标准输出一样）。

消息队列

系统内维护了一个存放消息的队列，不同用户可以向队列中发送消息，或者从队列中接收消息

#include<sys/types.h>

#include<sys/ipc.h>

#include<msg.h>

int msgget(key_t key,int msgflg);

int msgsnd(int msqid,const void *msgp,size_t msgsz,int msgflg);

ssizet msgrcv(int msqid,void *msgp,sizet msgsz,long msgtyp,int msgflg);

进程间通信 + 消息队列

消息队列实例

System V消息队列是一种在Linux系统中实现消息队列的方式，它可以在进程间传递消息。下面是一个使用System V消息队列的简单示例：

创建消息队列

#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>

int main()
{
    key_t key;
    int msgid;

    key = ftok("msgq.txt", 'A');
    msgid = msgget(key, IPC_CREAT | 0666);
    return 0;
}

发送消息

#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <string.h>

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

int main()
{
    key_t key;
    int msgid;
    struct message msg;

    key = ftok("msgq.txt", 'A');
    msgid = msgget(key, 0666);
    msg.mtype = 1;
    strcpy(msg.mtext, "Hello Message Queue!");
    msgsnd(msgid, &msg, sizeof(msg), 0);
    return 0;
}

接收消息

#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <stdio.h>

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

int main()
{
    key_t key;
    int msgid;
    struct message msg;

    key = ftok("msgq.txt", 'A');
    msgid = msgget(key, 0666);
    msgrcv(msgid, &msg, sizeof(msg), 1, 0);
    printf("%s\n", msg.mtext);
    return 0;
}

这个示例中，我们使用了 msgget() 函数创建了一个消息队列，使用 msgsnd() 函数向消息队列中发送了一条消息，使用 msgrcv() 函数从消息队列中接收了一条消息并打印出来。文章来源地址https://www.toymoban.com/news/detail-488049.html

到了这里，关于进程间通信 + 消息队列的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！