x/redisClient组件：redis客户端。可以执行redis命令。

配置

该组件允许通关过server字段复用共享的redis连接客户端。参考组件连接复用 。

字段	类型	说明	默认值
server	string	redis服务器地址	无
password	string	密码	无
poolSize	int	连接池大小	0
db	int	数据库	无
cmd	string	redis执行命令，例如：SET/GET/Del，可以使用${}占位符替换metadata元数据	无
paramsExpr v0.23.0+	string	动态参数表达式。	无
params	array	执行命令参数，可以使用组件配置变量	无

paramsExpr和params同时存在则优先使用paramsExpr。例如：["myhash2", "field1", "value1"]

表达式可以通过以下变量取值：

• 通过id变量访问消息ID
• 通过ts变量访问消息时间戳
• 通过data变量访问消息原始内容
• 通过msg变量访问消息体，如果消息的dataType是json类型，可以通过 msg.XX方式访问msg的字段。例如:msg.values;
• 通过metadata变量访问消息元数据。例如 metadata.customerName
• 通过type变量访问消息类型
• 通过dataType变量访问数据类型

表达式例子：

• upper(msg.name)
• metaData.productType
• msg.temperature+50
• replace(metaData.productType,'oldValue','newValue')

更多expr表达式语法参考： expr (opens new window)

Relation Type

• Success: 执行成功，把消息发送到Success链
• Failure: 执行失败，把消息发送到Failure链

执行结果

执行结果替换到msg.Data，流转到下一个节点。

配置示例

{
  "id": "s5",
  "type": "x/redisClient",
  "name": "保存到redis",
  "debugMode": true,
  "configuration": {
    "cmd": "SET",
    "params": ["${key}", "${msg.data}"],
    "poolSize": 10,
    "Server": "192.168.1.1:6379"
  }
}

应用示例

应用示例参考：redisClient (opens new window)

{
  "ruleChain": {
    "id":"chain_msg_type_switch",
    "name": "测试规则链-msgTypeSwitch",
    "root": false,
    "debugMode": false
  },
  "metadata": {
    "nodes": [
      {
        "id": "s1",
        "type": "msgTypeSwitch",
        "name": "过滤",
        "debugMode": true
      },
      {
        "id": "s2",
        "type": "log",
        "name": "记录日志1",
        "debugMode": true,
        "configuration": {
          "jsScript": "return msgType+':s2--'+JSON.stringify(msg);"
        }
      },
      {
        "id": "s3",
        "type": "log",
        "name": "记录日志2",
        "debugMode": true,
        "configuration": {
          "jsScript": "return msgType+':s3--'+JSON.stringify(msg);"
        }
      },
      {
        "id": "s5",
        "type": "x/redisClient",
        "name": "保存到redis",
        "debugMode": true,
        "configuration": {
          "cmd": "SET",
          "params": ["${key}", "${msg.data}"],
          "poolSize": 10,
          "Server": "192.168.1.1:6379"
        }
      },
	{
        "id": "s6",
        "type": "x/redisClient",
        "name": "保存到redis",
        "debugMode": true,
        "configuration": {
          "cmd": "SET",
          "params": ["${key}", "${value}"],
          "poolSize": 10,
          "Server": "192.168.1.1:6379"
        }
      }
    ],
    "connections": [
      {
        "fromId": "s1",
        "toId": "s2",
        "type": "TEST_MSG_TYPE1"
      },
      {
        "fromId": "s1",
        "toId": "s3",
        "type": "TEST_MSG_TYPE2"
      },
      {
        "fromId": "s3",
        "toId": "s5",
        "type": "Success"
      },
  		{
        "fromId": "s2",
        "toId": "s6",
        "type": "Success"
      }
    ]
  }
}