Redis Steam Endpoint
Redis Endpoint v0.23.0+ 用来创建和启动Redis 流服务,它可以订阅不同流名称数据,然后路由到不同规则链进行处理。
提示
- 该组件是扩展组件,需要引入额外的扩展库:rulego-components (opens new window)
- 需要redis5.0以上版本支持
# Type
endpoint/redis/stream
# 启动配置
该组件允许通关过server
字段复用共享的连接客户端。参考组件连接复用 。
字段 | 类型 | 是否必填 | 说明 | 默认值 |
---|---|---|---|---|
server | string | 是 | redis server地址 | 无 |
password | string | 否 | 密码,非必填 | 无 |
db | int | 否 | Redis数据库index | 0 |
groupId | string | 否 | 消费者组ID | rulego |
# 响应
exchange.Out.SetBody
响应之前,需要通过exchange.Out.Headers()
或者exchange.Out.Msg.Metadata
指定responseTopic
参数,组件就会往指定的主题发送数据:
exchange.Out.GetMsg().Metadata.PutValue("responseTopic", "device.msg.response")
// or
exchange.Out.Headers().Add("responseTopic", "device.msg.response")
exchange.Out.SetBody([]byte("ok"))
1
2
3
4
5
2
3
4
5
响应参数配置:
字段 | 类型 | 是否必填 | 说明 | 默认值 |
---|---|---|---|---|
responseTopic | string | 是 | 响应主题/响应流 | - |
# 示例
以下是使用endpoint的示例代码:
在 GitHub 上编辑此页 (opens new window)
上次更新: 2024/09/24, 16:39:13