VxWorks中使用消息队列实现进程间通信

VxWorks操作系统中，消息队列是一种常用的进程间通信方式。本示例展示了如何在两个进程之间使用消息队列进行通信，其中一个进程负责发送消息，另一个进程负责接收消息。

发送消息的进程：

#include "vxWorks.h"
#include "msgQLib.h"

#define MSG_Q_NAME "/my_msg_q"   // 消息队列的名称
#define MSG_Q_MAX_LENGTH 10      // 消息队列中最多可以存储的消息数量

MSG_Q_ID msg_q_id;              // 消息队列ID

void send_message()
{
    char message[] = "Hello, VxWorks!";  // 发送的消息内容
    if (msgQSend(msg_q_id, (char *)message, strlen(message), WAIT_FOREVER, MSG_PRI_NORMAL) == ERROR)
        printf("Failed to send message.\n");
}

int main()
{
    msg_q_id = msgQCreate(MSG_Q_MAX_LENGTH, sizeof(char) * 20, MSG_Q_FIFO);  // 创建消息队列
    if (msg_q_id == NULL)
    {
        printf("Failed to create message queue.\n");
        return ERROR;
    }

    send_message();  // 发送消息

    return OK;
}

接收消息的进程：

#include "vxWorks.h"
#include "msgQLib.h"

#define MSG_Q_NAME "/my_msg_q"   // 消息队列的名称

MSG_Q_ID msg_q_id;              // 消息队列ID

void receive_message()
{
    char message[20];  // 存储接收到的消息内容
    UINT16 message_length;  // 存储接收到的消息长度
    if (msgQReceive(msg_q_id, (char *)message, sizeof(message), WAIT_FOREVER) == ERROR)
        printf("Failed to receive message.\n");
    else
        printf("Received message: %s\n", message);
}

int main()
{
    msg_q_id = msgQCreate(MSG_Q_MAX_LENGTH, sizeof(char) * 20, MSG_Q_FIFO);  // 创建消息队列
    if (msg_q_id == NULL)
    {
        printf("Failed to create message queue.\n");
        return ERROR;
    }

    receive_message();  // 接收消息

    return OK;
}

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