linux msg消息队列例程

下面是一个使用Linux msg消息队列的简单例程，它演示了如何发送和接收消息：

发送消息的代码：

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

#define MSGKEY 9876

struct msgbuf {
    long mtype;  // 消息类型，必须是正整数
    char mtext[256];  // 消息正文，最大长度为256字节
};

int main()
{
    int msgid;
    struct msgbuf msg;

    // 创建消息队列
    msgid = msgget(MSGKEY, IPC_CREAT | 0666);
    if (msgid == -1) {
        perror("msgget error");
        return -1;
    }

    // 填充消息数据
    msg.mtype = 1;
    sprintf(msg.mtext, "Hello, message queue!");

    // 发送消息
    if (msgsnd(msgid, &msg, sizeof(msg.mtext), 0) == -1) {
        perror("msgsnd error");
        return -1;
    }

    printf("Message sent successfully.\n");

    return 0;
}

接收消息的代码：

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

#define MSGKEY 9876

struct msgbuf {
    long mtype;
    char mtext[256];
};

int main()
{
    int msgid;
    struct msgbuf msg;

    // 打开消息队列
    msgid = msgget(MSGKEY, 0666);
    if (msgid == -1) {
        perror("msgget error");
        return -1;
    }

    // 接收消息
    if (msgrcv(msgid, &msg, sizeof(msg.mtext), 0, 0) == -1) {
        perror("msgrcv error");
        return -1;
    }

    printf("Received message: %s\n", msg.mtext);

    // 关闭消息队列
    if (msgctl(msgid, IPC_RMID, NULL) == -1) {
        perror("msgctl error");
        return -1;
    }

    return 0;
}

运行发送消息的程序后，再运行接收消息的程序，就可以看到从消息队列中接收到消息了。注意，在使用msg消息队列时，消息类型必须是正整数，并且发送和接收消息的长度必须相同。