在前端开发中，使用工具库和框架可以大大提高开发效率和代码质量。而 npm 是目前最为流行的 JavaScript 包管理器，其中包含了大量的工具库和框架，它们可以帮助我们完成许多常见的任务，比如数据可视化、网络请求、前端框架等等。
node-red-contrib-scatter-gather 就是一个基于 npm 的工具包，它提供了一种用于流程控制的节点类型，可以通过它来并行执行一些任务并将结果聚合起来，适用于处理大量数据、高并发的场景。
安装
要使用 node-red-contrib-scatter-gather ，首先要确保已经安装了 Node.js 和 Node-RED 。接着，在 Node-RED 的工作目录下执行以下命令：
npm install node-red-contrib-scatter-gather
安装完成后，重启 Node-RED 以使其生效。现在，我们可以在 Node-RED 的编辑器中看到新添加的节点类型 scatter-gather。
使用
scatter-gather 节点包含两个子节点类型： scatter 和 gather 。scatter 节点用于将输入的数据拆分成多个部分，并将每个部分发往下游的多个 worker 节点进行处理，每个 worker 节点都可以并行地处理不同的数据部分。完成处理后，worker 节点会将结果发送回 gather 节点进行聚合，最终输出全部的处理结果。
1. 拆分数据
我们先看一下 scatter 节点的使用方法。将 scatter 节点拖放到编辑器中，右键单击节点并选择 Edit 进入编辑模式。在 Payload Type 中选择 msg ，在 Count 中设置拆分数据的数量，这里我们设置为 4。
接着，在 worker nodes 子节点中添加 4 个 function 节点，并将它们连接到 scatter 节点的输出端口。每个 function 节点中可以处理一个部分数据。我们可以在 function 节点中设置相关的处理逻辑：
-- -------------------- ---- -------
-- ---------
-- ---------------- --- -- -
----------- - ----- -- - - ------------
------ ----
-
-- ---------
---- -- ---------------- --- -- -
----------- - ----- -- - - ------------
------ ----
-
-- ---------
---- -- ---------------- --- -- -
----------- - ----- -- - - ------------
------ ----
-
-- ---------
---- -- ---------------- --- -- -
----------- - ----- -- - - ------------
------ ----
-2. 处理结果
当 worker 节点处理完毕后，结果将会被聚合到 gather 节点中。同样地，我们可以将 gather 节点拖放到编辑器中，并将 function 节点连接到它的输入端口。在 function 节点中可以对处理结果进行进一步的处理：
// 将处理结果连接为一个字符串
let result = '';
for (let i = 0; i < msg.parts.length; i++) {
result += msg.parts[i].payload + '\n';
}
msg.payload = result;
return msg;3. 测试
完成以上步骤后，我们可以点击编辑器的 Deploy 按钮保存并运行我们的流程。我们可以通过 inject 节点来给流程输入数据，或者通过其他节点获取数据并输出到当前流程中等。对于我们的 scatter-gather 流程，我们可以使用 inject 节点并输入以下数据：
[
{"name": "John", "age": 25},
{"name": "Lucy", "age": 30},
{"name": "David", "age": 20},
{"name": "Amy", "age": 28}
]运行后，流程会将输入的数据拆分成 4 个部分，并并行发送到 4 个 worker 节点进行处理。最终处理结果会被 gather 节点聚合起来，我们可以通过 debug 节点查看最终输出的结果信息。
总结
通过以上的使用教程，我们可以看到，在 Node-RED 中使用 scatter-gather 节点来处理大量数据、高并发的场景非常方便。通过 scatter 节点，我们可以将数据拆分成多个部分，通过 gather 节点，我们可以将所有部分的处理结果进行聚合。同时，多个 worker 节点可以并行处理不同的数据部分，大大提高了处理效率和并发能力。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/60055d1081e8991b448daa50