一、目录
1. 实验目的
- 掌握 node-red 其他特有的 API
2. 实验步骤
2.1 node 相关 api 的应用
- 函数控件的功能强大，甚至可以用函数控件实现其它所有功能控件的功能。在函数空间中，除了可以调用 JS 自带的各种方法以外，含有一些 node-red 特有的 API 可以使用，说明如下：
node.id : 函 数 节 点 的ID， 在0 .19 版 本 添 加
node.name : 函 数 节 点 的 名 字， 在0 .19 版 本 增 加
node.log ( . . ) : 记 录 一 条 消 息
node.warn ( . . ) : 记 录 一 条 警 告 消 息
node.error ( . . ) : 记 录 一 条 错 误 消 息
node.debug ( . . ) : 记 录 一 条 调 试 消 息
node.trace ( . . ) : 记 录 跟 踪 消 息
node.on ( . . ) : 注 册 一 个 事 件 处 理 函 数
node.status ( . . ) : 更 新 节 点 的 状 态
node.send ( . . ) : 发 送 消 息
2.2 使用 send 发送数据
-
在实验四中，我们已经可以使用函数简单判断字符串的走向，但如果使用 if-else 的判断当字符串满足其中一个条件就输出对应的口，但是当某个字符串既满足条件 1 又满足条件 3 的情况下，条件 3 就不会执行。
-
有没有既可以发送数据，又不会结束函数的方法？当然有。我们查询了节点可以调用的 API，发现有send 函数，满足我们的要求。可以将判断节点做如下的修改：
该修改首先是放弃了 if-else 的写法，而使用了 if 的写法，使用 node.send 往下一个流发送数据。然后部署并观察现象，可以发现，当点击 apple 的输入按钮时，OUT1 与 OUT3 都可以收到消息。
实现
1.按照上图，拖拽节点，效果如下图
2.设置节点参数
设置第一个节点的参数设置，剩余的2个，重复以下操作
设置函数节点配置
设置函数节点代码
if (msg.topic ==="apple")
{
node.send([msg, null, null]);
}
if (msg.topic === "banana")
{
node.send([null, msg, null]);
}
if (msg.topic.indexOf("e") != -1)
{
node.send([null, null, msg]);
}
把所有的节点连接起来
3.部署查看效果
2.3 流程之间传递函数
-
Context 元素除了可以传递变量以外，也可以传递函数。我们在流 1 中新建一个名为 hello 的函数，在流 2 中调用它。总体部署如下：
-
第一个流中的 function 节点写法：
-
第二个流中的 function 节点写法，调用第一个流的中的函数：
- 注意: 第二个节点可以调用第一个节点的函数，是因为第一个节点创建的函数已经保存到了全局变量 global 里。部署后，先点击 IN1 的输入按钮，再点击 IN2 的输入按钮，可以看到 OUT2 中打印出了 helloworld，其中的“hello”是通过调用流 1 的 hello() 函数打印出来的，说明实验成功了。
实现
1.按照上图拖拽节点，并连接，如下图
2.设置节点代码
设置第一个节点代码
context.global.hello = function () { return "hello" };
msg.payload = context.global.hello();
return msg;
设置第二个节点代码
msg.payload = context.global.hello()+"World";
return msg;
3.部署，查看效果
2.4 使用状态标识
delay 节点用于产生一个随机数，在运行的时候显示出了一个表示时间的字符，显示这个随机的时间是多少，这个功能很直观的可以显示出我们感兴趣的一些数据或状态，可以省去到处用 debug 节点打印的烦恼。我们也可以使用 node.status 来更新节点的状态.
-
step1: 搭建 flow 首先要搭建一个可变的输入信息，并且要持续一段时间，避免状态变得太快看不到。用函数节点 +delay 节点可以实现。先拖拽节点，形成数据流。
-
step2: 第一个节点用于发送 5 个数字：
-
step3: 延时节点设置为每秒只接收一个字符信息：
-
step4: 第二个节点显示节点信息：
实现
1.按照上图，拖拽节点并连接
2.设计节点函数
设置第一个函数节点
for (var i = 0; i < 5; i++)
{
node.send({ payload: i });
}
return null;
设置延时节点参数
设置第二个函数节点
node.status
(
{
fill: "green",
shape: "dot",text: "Received " + msg.payload
}
);
return msg;
-
step5: 部署，运行，查看效果
3. 全部代码
[
{
"id": "fd24dd19e0ab88ca",
"type": "tab",
"label": "流程 5",
"disabled": false,
"info": "",
"env": []
},
{
"id": "bbdf1e33d3b2040c",
"type": "inject",
"z": "fd24dd19e0ab88ca",
"name": "",
"props": [
{
"p": "payload"
},
{
"p": "topic",
"vt": "str"
}
],
"repeat": "",
"crontab": "",
"once": false,
"onceDelay": 0.1,
"topic": "apple",
"payload": "apple",
"payloadType": "str",
"x": 90,
"y": 100,
"wires": [
[
"e5f5bc529125975f"
]
]
},
{
"id": "db1fec6ee1aa2c71",
"type": "inject",
"z": "fd24dd19e0ab88ca",
"name": "",
"props": [
{
"p": "payload"
},
{
"p": "topic",
"vt": "str"
}
],
"repeat": "",
"crontab": "",
"once": false,
"onceDelay": 0.1,
"topic": "banana",
"payload": "banana",
"payloadType": "str",
"x": 100,
"y": 160,
"wires": [
[
"e5f5bc529125975f"
]
]
},
{
"id": "98fbcf4584a2f73f",
"type": "inject",
"z": "fd24dd19e0ab88ca",
"name": "",
"props": [
{
"p": "payload"
},
{
"p": "topic",
"vt": "str"
}
],
"repeat": "",
"crontab": "",
"once": false,
"onceDelay": 0.1,
"topic": "orange",
"payload": "orange",
"payloadType": "str",
"x": 100,
"y": 220,
"wires": [
[
"e5f5bc529125975f"
]
]
},
{
"id": "e5f5bc529125975f",
"type": "function",
"z": "fd24dd19e0ab88ca",
"name": "function 13",
"func": "if (msg.topic === \"apple\") \n{\n node.send([msg, null, null]);\n}\nif (msg.topic === \"banana\") \n{\n node.send([null, msg, null]);\n}\nif (msg.topic.indexOf(\"e\") != -1) \n{\n node.send([null, null, msg]);\n}\n",
"outputs": 3,
"noerr": 0,
"initialize": "",
"finalize": "",
"libs": [],
"x": 290,
"y": 160,
"wires": [
[
"e0df73d7264cf691"
],
[
"db705ff2959f7d84"
],
[
"975fc285f54b1bfa"
]
]
},
{
"id": "e0df73d7264cf691",
"type": "debug",
"z": "fd24dd19e0ab88ca",
"name": "debug 24",
"active": true,
"tosidebar": true,
"console": false,
"tostatus": false,
"complete": "payload",
"targetType": "msg",
"statusVal": "",
"statusType": "auto",
"x": 460,
"y": 100,
"wires": []
},
{
"id": "db705ff2959f7d84",
"type": "debug",
"z": "fd24dd19e0ab88ca",
"name": "debug 25",
"active": true,
"tosidebar": true,
"console": false,
"tostatus": false,
"complete": "false",
"statusVal": "",
"statusType": "auto",
"x": 460,
"y": 160,
"wires": []
},
{
"id": "975fc285f54b1bfa",
"type": "debug",
"z": "fd24dd19e0ab88ca",
"name": "debug 26",
"active": true,
"tosidebar": true,
"console": false,
"tostatus": false,
"complete": "false",
"statusVal": "",
"statusType": "auto",
"x": 480,
"y": 220,
"wires": []
},
{
"id": "cfde4bc22548a5da",
"type": "inject",
"z": "fd24dd19e0ab88ca",
"name": "",
"props": [
{
"p": "payload"
},
{
"p": "topic",
"vt": "str"
}
],
"repeat": "",
"crontab": "",
"once": false,
"onceDelay": 0.1,
"topic": "",
"payload": "",
"payloadType": "date",
"x": 130,
"y": 360,
"wires": [
[
"833d9441148aa8b0"
]
]
},
{
"id": "833d9441148aa8b0",
"type": "function",
"z": "fd24dd19e0ab88ca",
"name": "function 14",
"func": "context.global.hello = function () { return \"hello\" };\nmsg.payload = context.global.hello();\nreturn msg;\n",
"outputs": 1,
"noerr": 0,
"initialize": "",
"finalize": "",
"libs": [],
"x": 290,
"y": 360,
"wires": [
[
"02d01bfca0ec64bb"
]
]
},
{
"id": "02d01bfca0ec64bb",
"type": "debug",
"z": "fd24dd19e0ab88ca",
"name": "debug 27",
"active": true,
"tosidebar": true,
"console": false,
"tostatus": false,
"complete": "false",
"statusVal": "",
"statusType": "auto",
"x": 500,
"y": 360,
"wires": []
},
{
"id": "d0896441365092f6",
"type": "inject",
"z": "fd24dd19e0ab88ca",
"name": "",
"props": [
{
"p": "payload"
},
{
"p": "topic",
"vt": "str"
}
],
"repeat": "",
"crontab": "",
"once": false,
"onceDelay": 0.1,
"topic": "",
"payload": "",
"payloadType": "date",
"x": 130,
"y": 440,
"wires": [
[
"7162a1b78eacc220"
]
]
},
{
"id": "7162a1b78eacc220",
"type": "function",
"z": "fd24dd19e0ab88ca",
"name": "function 15",
"func": "msg.payload = context.global.hello()+\"World\";\nreturn msg;\n",
"outputs": 1,
"noerr": 0,
"initialize": "",
"finalize": "",
"libs": [],
"x": 290,
"y": 440,
"wires": [
[
"7e957b78d99d7970"
]
]
},
{
"id": "7e957b78d99d7970",
"type": "debug",
"z": "fd24dd19e0ab88ca",
"name": "debug 28",
"active": true,
"tosidebar": true,
"console": false,
"tostatus": false,
"complete": "false",
"statusVal": "",
"statusType": "auto",
"x": 500,
"y": 440,
"wires": []
},
{
"id": "ca10b10e2b9597b1",
"type": "inject",
"z": "fd24dd19e0ab88ca",
"name": "",
"props": [
{
"p": "payload"
},
{
"p": "topic",
"vt": "str"
}
],
"repeat": "",
"crontab": "",
"once": false,
"onceDelay": 0.1,
"topic": "",
"payload": "",
"payloadType": "date",
"x": 130,
"y": 620,
"wires": [
[
"84f68edfbbf9836a"
]
]
},
{
"id": "84f68edfbbf9836a",
"type": "function",
"z": "fd24dd19e0ab88ca",
"name": "function 16",
"func": "for (var i = 0; i < 5; i++) \n{\n node.send({ payload: i });\n}\nreturn null;\n",
"outputs": 1,
"noerr": 0,
"initialize": "",
"finalize": "",
"libs": [],
"x": 130,
"y": 700,
"wires": [
[
"8e34506111ecdc36"
]
]
},
{
"id": "8e34506111ecdc36",
"type": "delay",
"z": "fd24dd19e0ab88ca",
"name": "",
"pauseType": "rate",
"timeout": "5",
"timeoutUnits": "seconds",
"rate": "1",
"nbRateUnits": "1",
"rateUnits": "second",
"randomFirst": "1",
"randomLast": "5",
"randomUnits": "seconds",
"drop": false,
"allowrate": false,
"outputs": 1,
"x": 150,
"y": 780,
"wires": [
[
"ea85e1d28efac455"
]
]
},
{
"id": "ea85e1d28efac455",
"type": "function",
"z": "fd24dd19e0ab88ca",
"name": "function 17",
"func": "node.status\n(\n {\n fill: \"green\", \n shape: \"dot\",text: \"Received \" + msg.payload \n }\n);\nreturn msg;\n",
"outputs": 1,
"noerr": 0,
"initialize": "",
"finalize": "",
"libs": [],
"x": 150,
"y": 860,
"wires": [
[
"2902fbb971fd1fb8"
]
]
},
{
"id": "2902fbb971fd1fb8",
"type": "debug",
"z": "fd24dd19e0ab88ca",
"name": "debug 29",
"active": true,
"tosidebar": true,
"console": false,
"tostatus": false,
"complete": "false",
"statusVal": "",
"statusType": "auto",
"x": 140,
"y": 940,
"wires": []
}
]
