linux消息队列通信

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

#define QUEUE_NAME "/my_queue"
#define MSG_SIZE 1024

int main() {
    key_t key = ftok("/tmp", 'R');
    if (key == -1) {
        perror("ftok");
        exit(1);
    }

    int msgid = msgget(key, 0666 | IPC_CREAT);
    if (msgid == -1) {
        perror("msgget");
        exit(1);
    }

    struct msgbuf message;
    message.mtype = 1;
    strncpy(message.mtext, "Hello, World!", MSG_SIZE);

    if (msgsnd(msgid, &message, MSG_SIZE, 0) == -1) {
        perror("msgsnd");
        exit(1);
    }

    printf("Message sent\n");
    return 0;
}

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

#define QUEUE_NAME "/my_queue"
#define MSG_SIZE 1024

int main() {
    key_t key = ftok("/tmp", 'R');
    if (key == -1) {
        perror("ftok");
        exit(1);
    }

    int msgid = msgget(key, 0666 | IPC_CREAT);
    if (msgid == -1) {
        perror("msgget");
        exit(1);
    }

    struct msgbuf message;
    message.mtype = 1;
    ssize_t recv_size = msgrcv(msgid, &message, MSG_SIZE, 1, 0);
    if (recv_size == -1) {
        perror("msgrcv");
        exit(1);
    }

    printf("Received message: %s\n", message.mtext);
    return 0;
}