进程间通信 + 消息队列

阿里云国内75折 回扣 微信号:monov8
阿里云国际,腾讯云国际,低至75折。AWS 93折 免费开户实名账号 代冲值 优惠多多 微信号:monov8 飞机:@monov6

进程间通信

每个进程有各自不同的用户地址空间任何一个进程的全局变量在另一个进程中都看不到所以进程之间要交换数据必须通过内核在内核中开辟一块缓冲区进程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);

image-20230518194048886

消息队列实例

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

  1. 创建消息队列
#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;
}

  1. 发送消息
#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;
}

  1. 接收消息
#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() 函数从消息队列中接收了一条消息并打印出来。

阿里云国内75折 回扣 微信号:monov8
阿里云国际,腾讯云国际,低至75折。AWS 93折 免费开户实名账号 代冲值 优惠多多 微信号:monov8 飞机:@monov6