安裝
node-red的安裝很簡單
npm install -g --unsafe-perm node-red
啟動
直接通過腳本 node-red 啟動夕玩,然后通過 http://localhost:1880/ 進(jìn)行訪問
工作界面介紹
配置
默認(rèn)安裝后是不需要登錄的媒抠,找到 ~/.node-red/settings.js 啟用admin登錄和projects支持
// 啟用后臺登錄
adminAuth: {
type: "credentials",
users: [{
username: "admin",
password: "xxxx",
permissions: "*"
}]
}
// 啟用git支持
projects: {
enabled: true,
}
重啟后刷新會出現(xiàn)登錄界面,
菜單里也出現(xiàn)了Project選項床绪,和git完美集成凉唐。
因為node-red的所有代碼极颓,默認(rèn)都在flow.json一個文件中,通過Projects特性可以更直觀的查看每次變更的內(nèi)容
常用node
node-red是基于流的购桑,所有工作都是通過節(jié)點(diǎn)完成畅铭。引擎內(nèi)置了很多類型的node,但常用的并不多:
1勃蜘、inject+debug硕噩,多用于調(diào)試和日志
2、function 支持編寫js代碼處理邏輯
3缭贡、switch 根據(jù)不同場景決定把消息發(fā)送到下游不同節(jié)點(diǎn)
4炉擅、http in + http response,基于express框架處理http請求和響應(yīng)的節(jié)點(diǎn)
5阳惹、catch 可以捕獲流程內(nèi)所有節(jié)點(diǎn)的異常谍失,進(jìn)行統(tǒng)一處理
inject + debug
node之間的通信,是通過node.send(msg)把事件傳遞到下游節(jié)點(diǎn)莹汤。每個msg會有一個唯一標(biāo)識: _msgid快鱼。
這是一個最簡單flow,由inject和debug兩個節(jié)點(diǎn)組成
點(diǎn)擊inject節(jié)點(diǎn)輸入按鈕纲岭,會在msg的payload屬性攜帶一個時間戳攒巍,并發(fā)送到下游接節(jié)點(diǎn)。debug節(jié)點(diǎn)接收到msg后荒勇,打印到debug窗口
打開flow.json 可以查看這些node是如何被描述的
[
{
"id": "b1959eb6b9ae4f30", // 節(jié)點(diǎn)的唯一id
"type": "inject", // 節(jié)點(diǎn)類型是 inject
"z": "1c44045758d8a7e0", // x、y是節(jié)點(diǎn)在界面上的位置闻坚,z是節(jié)點(diǎn)所屬的tab id
"name": "", // 節(jié)點(diǎn)名稱
...
"x": 160,
"y": 140,
"wires": [ // 下游的節(jié)點(diǎn)id列表
[
"20035fe327d63d99"
]
]
},
{
"id": "20035fe327d63d99",
"type": "debug", // debug 類型節(jié)點(diǎn)
...
},
]
http in + http response
開發(fā)rest接口就需要使用 http in 和 http response節(jié)點(diǎn)
因為底層是是基于express開發(fā)的沽翔,所以各種特性都可以直接使用
訪問 http://localhost:1880/demo/xxx 可以看到debug窗口打印的msg對象,里面有req和res兩個屬性窿凤,就是express的request盒response對象
catch
系統(tǒng)運(yùn)行過程中肯定會遇到各種各樣的異常仅偎,如果不進(jìn)行妥善的處理,可能會導(dǎo)致系統(tǒng)奔潰雳殊。node-red提供了catch節(jié)點(diǎn)橘沥,可以針對制定節(jié)點(diǎn)產(chǎn)生的異常捕獲并處理
我們插入一個function節(jié)點(diǎn),隨機(jī)拋出一個異常
const random = Math.ceil(Math.random() * 10 )
if (random % 2) {
throw new Error("隨機(jī)拋出異常")
}
msg.payload = {
"random": random
}
return msg;
然后插入一個catch和function節(jié)點(diǎn)夯秃,捕獲到異常時返回錯誤提示
安裝新節(jié)點(diǎn)
mysql
實(shí)際應(yīng)用中基本離不開數(shù)據(jù)庫操作座咆,可以通過設(shè)置—面板—安裝節(jié)點(diǎn)痢艺,查找到mysql并安裝。
左側(cè)會出現(xiàn)mysql節(jié)點(diǎn)類型介陶。增加一個mysql節(jié)點(diǎn)并簡單配置
增加一個查詢店鋪的節(jié)點(diǎn)
// mysql節(jié)點(diǎn)接收的msg堤舒, topic 為sql, payload為綁定參數(shù)
msg.topic = "SELECT * FROM yoshop_store"
return msg;
再訪問接口哺呜,可以看到返回結(jié)果是一個 店鋪信息的數(shù)組
sqlbuilder
數(shù)據(jù)庫操作直接拼sql太底層了而且不好維護(hù)舌缤,逛了下官方市場,發(fā)現(xiàn)一個封裝了knex查詢的node某残,可以簡化數(shù)據(jù)庫的操作国撵,果斷安裝
用新的sqlbuilder節(jié)點(diǎn)替換原先的function節(jié)點(diǎn),部署后重新訪問玻墅,正常返回了店鋪列表
可重用的子流程
在實(shí)際的項目開發(fā)中介牙,往往會有有很多公共邏輯,比如認(rèn)證椭豫、鑒權(quán)耻瑟、統(tǒng)一異常處理等。node-red支持把常用的邏輯提煉成subflow赏酥,使用時可以當(dāng)做普通的node使用
這里新增一個subflow來處理異常信息: 有 1 個輸入喳整,0個輸出(直接通過http response返回錯誤信息),相應(yīng)的狀態(tài)碼置為500
var err = msg._error || msg.error
console.log(err.stack)
msg.payload = {
code: err.code || 500,
message: err.message,
source: err.source
}
return msg;
把原先的catch的下游節(jié)點(diǎn)刪除裸扶,連接到新的異常處理子流程
http response節(jié)點(diǎn)是把 msg.payload 轉(zhuǎn)為json后直接返回框都。我們增加一個 json響應(yīng) 的子流程,統(tǒng)一下返回的數(shù)據(jù)結(jié)構(gòu)
{
"code": 0,
"message": "操作成功",
"data": {
xxx
}
}
同時設(shè)置下相應(yīng)的Content-Type
了解完node-red的基本概念呵晨,就可以開始開發(fā)一個正經(jīng)的系統(tǒng)了