消息传递（Message Passing）基础：Send/Receive/Reply 原语、同步与异步、通道与连接

好，咱们正式开始聊QNX里最核心的通信机制——消息传递。说实话，我当年刚接触QNX时，最震撼的就是这套Send/Receive/Reply模型。它不像Linux那种socket或者pipe，需要一堆配置和缓冲。QNX的消息传递，说白了就是三个原语搞定一切：谁发、谁收、谁回复。

Send/Receive/Reply 原语：三剑客

这三个原语是QNX消息传递的基石。我习惯把它们想象成一次面对面的对话：

• Send：你开口说话，把信息递过去。
• Receive：对方竖起耳朵听，准备接收。
• Reply：对方听完后，给你一个回应。

在代码里，它们长这样：

// 发送端
int msg = 42;
Send(server_chid, &msg, sizeof(msg), &reply, sizeof(reply));

// 接收端
int rcvid = Receive(chid, &msg, sizeof(msg));
printf("收到消息: %d\n", msg);
Reply(rcvid, &reply_msg, sizeof(reply_msg));

嗯，这里要注意一个细节：rcvid 不是进程ID，而是接收端的标识符。我刚开始写代码时，总以为它是PID，结果调试了半天才发现自己搞混了。

同步与异步：什么时候该用哪个？

你可能会问：那如果我不想阻塞怎么办？嗯，这就是同步和异步的区别了。

同步消息传递：发送端等回复，接收端等消息。双方步调一致。我一般在需要强一致性的场景下用，比如控制命令的下发。举个例子，我在做机器人关节控制时，每个控制指令都必须确认执行完毕才能发下一条。这时候同步就是最好的选择。

异步消息传递：发送端发完就走，不等待回复。接收端慢慢处理。这种模式适合日志记录、状态上报等场景。你想想看，如果每个日志都要等确认，系统性能肯定扛不住。

QNX里实现异步的方式有两种：

• 使用 MsgSendPulse：发送一个脉冲消息，不需要回复。
• 使用 MsgSend 配合 MsgReply 的延迟回复：发送端可以继续执行，接收端稍后回复。

我个人习惯在性能敏感的场景下用脉冲，因为它开销最小。但要注意，脉冲消息不能携带大量数据，只能带几个整数。

通道（Channel）与连接（Connection）：通信的管道

通道和连接，是QNX消息传递的物理载体。我刚开始学的时候，总觉得这两个概念有点绕。其实很简单：

• 通道（Channel）：接收端创建的通信端点。一个进程可以创建多个通道，每个通道有自己的ID。
• 连接（Connection）：发送端创建的通信链路。一个连接对应一个通道，发送端通过连接发送消息。

用代码来理解：

// 接收端：创建通道
int chid = ChannelCreate(0);
// 等待消息
int rcvid = Receive(chid, &msg, sizeof(msg));

// 发送端：连接到通道
int coid = ConnectAttach(0, pid, chid, 0, 0);
// 发送消息
Send(coid, &msg, sizeof(msg), &reply, sizeof(reply));

这里有个关键点：ConnectAttach 需要知道目标进程的PID和通道ID。我见过不少新手直接写死PID，结果进程重启后就连不上了。我建议用名字服务（如 name_attach）来动态查找。

概念	角色	创建方式	特点
通道（Channel）	接收端	ChannelCreate()	一个进程可以有多个通道
连接（Connection）	发送端	ConnectAttach()	一个连接对应一个通道

实际应用：一个简单的客户端-服务器模型

说了这么多，咱们来点实际的。下面是一个简单的服务器和客户端代码：

// 服务器端
#include <sys/neutrino.h>
#include <stdio.h>

int main() {
    int chid = ChannelCreate(0);
    if (chid == -1) {
        perror("ChannelCreate");
        return 1;
    }
    printf("服务器通道ID: %d\n", chid);

    while (1) {
        int msg;
        int rcvid = Receive(chid, &msg, sizeof(msg));
        if (rcvid == -1) {
            perror("Receive");
            continue;
        }
        printf("收到消息: %d\n", msg);
        int reply = msg * 2;
        Reply(rcvid, &reply, sizeof(reply));
    }
    return 0;
}

// 客户端
#include <sys/neutrino.h>
#include <stdio.h>

int main() {
    int chid = 1; // 假设服务器通道ID为1
    int pid = 12345; // 假设服务器PID为12345
    int coid = ConnectAttach(0, pid, chid, 0, 0);
    if (coid == -1) {
        perror("ConnectAttach");
        return 1;
    }

    int msg = 10;
    int reply;
    Send(coid, &msg, sizeof(msg), &reply, sizeof(reply));
    printf("收到回复: %d\n", reply);

    ConnectDetach(coid);
    return 0;
}

这段代码虽然简单，但涵盖了消息传递的核心流程。你想想看，实际项目中，服务器可能同时处理多个客户端，这时候就需要多线程或者多进程配合了。

下一章，咱们会深入聊消息传递的高级用法，比如优先级继承和消息队列。到时候见！