QNX中使用POSIX消息队列实现进程通信

本示例展示了在QNX操作系统下，使用POSIX消息队列实现进程间通信的方法，通过发送和接收消息实现跨进程数据交换。 （注释中给出具体解释和说明）

#include <mqueue.h>
#include <stdio.h>

#define QUEUE_NAME "/my_queue"  // 消息队列名称
#define MAX_MESSAGES 5  // 消息队列最大消息数
#define MAX_MSG_SIZE 256  // 消息队列消息最大长度

int main(int argc, char **argv) {
    mqd_t mq;  // 消息队列描述符
    struct mq_attr attr;  // 消息队列属性

    // 定义消息
    char *msg_send = "Hello QNX!";
    char msg_recv[MAX_MSG_SIZE]; 

    // 设置消息队列属性
    attr.mq_flags = 0;
    attr.mq_maxmsg = MAX_MESSAGES;
    attr.mq_msgsize = MAX_MSG_SIZE;
    attr.mq_curmsgs = 0;

    // 创建消息队列
    mq = mq_open(QUEUE_NAME, O_CREAT | O_RDWR, 0666, &attr);
    if(mq < 0) {
        perror("mq_open");
        return -1;
    }

    // 向消息队列中发送消息
    if(mq_send(mq, msg_send, sizeof(msg_send), 0) < 0) {
        perror("mq_send");
        return -1;
    }

    // 从消息队列中接收消息
    if(mq_receive(mq, msg_recv, sizeof(msg_recv), NULL) < 0) {
        perror("mq_receive");
        return -1;
    }

    printf("Received: %s\n", msg_recv);

    // 关闭消息队列
    mq_close(mq);
    mq_unlink(QUEUE_NAME);

    return 0;
}

免责申明：文章和图片全部来源于公开网络，如有侵权，请通知删除 server@dude6.com