Redis Sub Endpoint

Redis Endpoint v0.22.0+ 用来创建和启动Redis订阅服务，它可以订阅不同主题数据，然后路由到不同规则链进行处理。

提示

该组件是扩展组件，需要引入额外的扩展库：rulego-components (opens new window)

# Type

endpoint/redis

# 启动配置

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

字段	类型	是否必填	说明	默认值
server	string	是	redis server地址	无
password	string	否	密码,非必填	无
db	int	否	Redis数据库index	0

# 响应

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

响应参数配置：

字段	类型	是否必填	说明	默认值
responseTopic	string	是	主题	-

# 示例

以下是使用endpoint的示例代码：

在 GitHub 上编辑此页

上次更新: 2024/10/23, 10:13:01

← Nats Endpoint Redis Steam Endpoint→