Node-RED项目中合并两个消息负载的技术求助

嘿，我之前在Node-RED里也碰到过一模一样的需求——不想挨个处理两个消息，而是直接把它们的负载合并成一个再往下传。给你几个亲测好用的方案：

这是Node-RED官方提供的专门用来合并消息的节点，完全不用写代码：

• 把两个输入消息的节点都连接到Join节点上
• 双击打开Join节点配置：
  • 选择手动模式（因为你明确要合并2个消息）
  • 合并方式选合并成对象（这样两个消息的payload会整合成一个键值对对象；如果需要把payload放到数组里，就选合并成数组）
  • 如果你想给每个输入的payload指定明确的键名，可以先在每个输入节点后面加个Change节点，给消息设置一个topic（比如第一个消息设topic: "temperature"，第二个设topic: "humidity"），然后在Join节点里选择按topic合并，这样最终的payload就是{temperature: ..., humidity: ...}
• 举个实际例子：
  第一个消息：{payload: {value: 25}}（topic设为"temp"）
  第二个消息：{payload: {value: 60}}（topic设为"humidity"）
  经过配置好的Join节点后，输出的消息就是{payload: {temp: {value:25}, humidity: {value:60}}}

如果你的合并逻辑比较特殊（比如需要对数据做预处理再合并），可以用Function节点手动实现：

基础版（按顺序接收消息） #

适合你能确定两个消息的发送顺序的场景：

// 从上下文暂存区读取之前的消息
const storedMsg = context.get('storedMsg');

if (!storedMsg) {
    // 如果还没存过第一个消息，就把当前消息存起来，不输出
    context.set('storedMsg', msg);
    return null;
} else {
    // 合并两个消息的payload，这里用扩展运算符把两个对象合并
    const combinedPayload = {...storedMsg.payload, ...msg.payload};
    // 清空暂存区，避免影响下一次合并
    context.set('storedMsg', null);
    // 返回合并后的消息
    return {payload: combinedPayload};
}

进阶版（不限制消息顺序） #

如果两个消息的发送顺序不确定，可以给每个消息加标识（比如topic），然后根据标识来暂存：

// 从上下文读取两个消息的暂存值
const tempData = context.get('tempData');
const humidityData = context.get('humidityData');

// 根据topic判断当前消息是哪一个，存入对应暂存区
if (msg.topic === 'temperature') {
    context.set('tempData', msg.payload);
} else if (msg.topic === 'humidity') {
    context.set('humidityData', msg.payload);
}

// 只有当两个数据都存在时，才合并输出
if (tempData && humidityData) {
    const combined = {
        temperature: tempData,
        humidity: humidityData
    };
    // 清空暂存区
    context.set('tempData', null);
    context.set('humidityData', null);
    return {payload: combined};
}

// 还没凑齐两个消息，不输出
return null;

• 键名冲突：如果两个消息的payload里有相同的键名，合并后后面的消息会覆盖前面的，建议提前用Change节点给键名重命名或者加前缀
• 上下文清理：用Function节点时一定要记得清空暂存的旧消息，不然会导致后续的合并出现重复数据
• 批量合并：如果之后需要合并更多消息，Join节点的自动模式可以设置合并数量，达到数量后自动输出合并结果

内容的提问来源于stack exchange，提问作者WhoAmIWhereAmIWhatIAmDoing