RedisMQ订阅推送

通过本文你可以了解到通过Redis方式从DTS订阅实体状态消息的流程。

示例

创建订阅者

进入订阅管理，选择订阅者列表。为服务端或订阅者创建订阅者身份。创建一个名为“XXX客户端”的订阅者，选择自动生成签名。

订阅资源

为“XXX客户端”添加订阅资源。进入订阅列表添加一个新的订阅，设置订阅的资源，选择订阅的产品。订阅类型勾选上订阅资源、属性上报、事件上报。订阅方式设定为RedisMQ，订阅者选择“XXX客户端”。

查询订阅通道

进入订阅管理，查看“XXX客户端”的详情。选择Topic通道下的通信Topic可查看使用Reids订阅的通道路径。

测试使用Redis订阅通道

使用Navicat连接Redis服务器测试获取订阅数据内容。也可使用其他Redis工具或通过编写代码连接。订阅者接收到消息后可以对数据自行进行逻辑处理。

在Navicat下新建Redis连接，输入Redis服务器地址，测试连接通过后点击确定。

打开连接，选择Pub/Sub功能，新建一个Pub/sub对话。

选择订阅，输入需要订阅的通道。从通信Topic下复制出属性订阅的通道号/serverSubscription/${appSecret}/${consumerSecret}/property/sub，注意：需要将其中appSecret替换为订阅者的身份签名APPSecret。

若未创建消费者，需${consumerSecret}使用通配符*替代。

输入完成后，点击订阅。

同样的方式创建接收事件订阅的订阅通道/serverSubscription/${appSecret}/${consumerSecret}/event/sub。

智能冰箱、智能插座发生属性、事件变化时，就可通过订阅的通道查看到实体数据。

详细的数据格式可参考订阅资源流转-协议格式。