node-red - 读写操作redis

一、前期准备

1. 安装配置node-red环境：

• centos通过源文件的方式安装node-red
• nodered-环境搭建及使用

2. 安装配置redis:

• centos - docker安装redis
• Windows10安装redis(图文教程）

Redis支持的数据结构

回到目录

二、node-red安装redis节点

1.在node-red里面安装redis节点 ：

node-red-node-redis
node-red-contrib-redis

2. 刷新node-red:

回到目录

三、node-red操作使用redis节点

3.1 redis-out节点 - 存储数据到redis

  redis-out节点负责向redis中存储数据。通过函数传输数据：msg.payload = [“”]为存储的数据；return msg 返回传入到redis out 中。

充当发布者，使用RPUSH、LPUSH或PUBLISH
主题消息是要发布的密钥名称。
注意：输出仅适用于PUBLISH和返回订阅者数。

• 配置节点：
  (1) server:选择redis实例（可以新建）
  
  主要是Name里面填写带端口号的redis服务器地址:IP:端口 (如：127.0.0.1:6379)
  
  如果有密码，配置示例如下：
  
  （2）Name: 随意命名
  （3）Topic : 为redis中的Key
• 实例：循环每三秒往redis的test1主题中注入当时时间对应的毫秒数
  
  执行结果如下：
  
  点我查看JSON源码 - 附录1：redis -out节点示例代码
  点我回到目录

3.2 redis-cmd节点 - 存储redis数据

  在Redis内部执行命令，将payload数组作为参数发送，并将结果作为payload返回。

• 节点配置：
  
• 实例
  
  结果：
  
  
  点我查看JSON源码 - 附录2：redis -cmd节点示例代码
  点我回到目录

3.3 redis-in节点 - 查询redis数据

  redis-in节点负责从redis中读取数据。该节点实时监听redis对应实例的对应的topic的数据，一旦数据有变化，就会有输出返回。

• 节点配置：
  
• 实例：
  
  点我查看JSON源码 - 附录3：redis -in节点示例代码
  

点我回到目录

附录

附录1：redis -out节点示例代码

JSON源码：

[{"id": "bdc2f01da279df43","type": "inject","z": "4df8aefd826300cd","name": "","props": [{"p": "payload"},{"p": "topic","vt": "str"}],"repeat": "3","crontab": "","once": true,"onceDelay": 0.1,"topic": "","payload": "","payloadType": "date","x": 120,"y": 520,"wires": [["bbf61d6ecf48ed99"]]},{"id": "bbf61d6ecf48ed99","type": "function","z": "4df8aefd826300cd","name": "payload","func": "msg.payload= new Date().getTime();\nreturn msg;","outputs": 1,"noerr": 0,"initialize": "","finalize": "","libs": [],"x": 280,"y": 520,"wires": [["0d2e6e619a4af685"]]},{"id": "0d2e6e619a4af685","type": "redis-out","z": "4df8aefd826300cd","server": "a0efbb89.5e42d8","command": "rpush","name": "存储test1值","topic": "test1","obj": true,"x": 470,"y": 520,"wires": []},{"id": "a0efbb89.5e42d8","type": "redis-config","name": "127.0.0.1:6379","options": "{}","cluster": false,"optionsType": "json"}
]

点我回到目录

附录2：redis -cmd节点示例代码

[{"id": "29990986a0d459cd","type": "function","z": "4df8aefd826300cd","name": "payload","func": "msg.payload = { \"a\": 11, \"b\": 22 };\nreturn msg;","outputs": 1,"noerr": 0,"initialize": "","finalize": "","libs": [],"x": 240,"y": 1140,"wires": [["91d7135cb4ae24bb"]]},{"id": "b34217cbbf7cab5b","type": "inject","z": "4df8aefd826300cd","name": "","props": [{"p": "payload"},{"p": "topic","vt": "str"}],"repeat": "","crontab": "","once": false,"onceDelay": 0.1,"topic": "","payload": "","payloadType": "date","x": 90,"y": 1140,"wires": [["29990986a0d459cd"]]},{"id": "91d7135cb4ae24bb","type": "redis-command","z": "4df8aefd826300cd","server": "a0efbb89.5e42d8","command": "hmset","name": "","topic": "testHmSet","params": "[]","paramsType": "json","payloadType": "json","block": false,"x": 440,"y": 1140,"wires": [["78939c27dc84759b"]]},{"id": "78939c27dc84759b","type": "debug","z": "4df8aefd826300cd","name": "","active": true,"tosidebar": true,"console": false,"tostatus": false,"complete": "false","x": 650,"y": 1140,"wires": []},{"id": "a0efbb89.5e42d8","type": "redis-config","name": "127.0.0.1:6379","options": "{}","cluster": false,"optionsType": "json"}
]

附录3：redis -in节点示例代码

[{"id": "e2467fd2210cf09c","type": "redis-in","z": "4df8aefd826300cd","server": "a0efbb89.5e42d8","command": "blpop","name": "查看test01数据","topic": "test1","obj": true,"timeout": "3","x": 140,"y": 600,"wires": [["cc8e82282004f50d"]]},{"id": "cc8e82282004f50d","type": "debug","z": "4df8aefd826300cd","name": "","active": true,"tosidebar": true,"console": false,"tostatus": false,"complete": "true","targetType": "full","statusVal": "","statusType": "auto","x": 310,"y": 600,"wires": []},{"id": "a0efbb89.5e42d8","type": "redis-config","name": "127.0.0.1:6379","options": "{}","cluster": false,"optionsType": "json"}
]

点我回到目录