有奖捉虫:办公协同&微信生态&物联网文档专题 HOT

操作场景

主题发布消息有一个前提,即需要有订阅者订阅主题,如果没有订阅者存在,那么主题中的消息不会被投递,此时发布消息这一操作就失去了意义。主题(Topic)向订阅者投递消息的模型如下:


Topic 向订阅者投递消息时,遵循以下原则:
Topic 会尽最大努力将生产者 publish 的消息,投递(notification)到订阅者。
当投递重试多次仍失败后,消息会堆积在 Topic 中,等待下一次投递;若持续失败,将在消息最大生命周期(1天)结束后,丢弃该消息。

本文档介绍在使用 TDMQ CMQ 版时,如何对一个主题下的订阅进行管理。

前提条件

已提前创建好对应主题。

操作步骤

创建订阅者

1. 在主题列表页面,单击目标主题的“ID”,进入主题详情页面。
2. 在页面上方选择订阅者页签,单击新建,填写订阅者相关信息。



订阅者类型
Queue 队列服务:订阅者可以选择一个 Queue,使用队列来接收发布的消息。
URL地址:订阅者也可以不与 Queue 结合,自己来处理消息。
添加订阅者标签:添加订阅者时,需增加 FilterTag。增加 FilterTag 后,该订阅者仅能收到带该 FilterTag 的消息,单个订阅者最多可添加5个 tag。只要其中某个 tag 能匹配 Topic 的过滤标签,订阅者即可收到该次 Topic 投递的消息,若消息不带任何标签,则该订阅者无法收到该类型消息。
标签:详细规则参考 标签匹配功能说明
路由匹配:详细规则请参考 路由键匹配功能说明
重试策略:主题发布消息之后,会自动将消息推送给订阅,当推送失败时,有两种重试策略:
退避重试:重试3次,间隔时间为10 - 20s之间的一个随机值,超过3次后,该条消息对于该订阅者丢弃,不会再重试。
衰退指数重试:重试176次,总计重试时间为1天,间隔时间依次为:2^0,2^1, …,512,512, …,512秒。默认为衰退指数重试策略。
3. 单击提交,在订阅者列表可以看到刚刚创建好的订阅者。

编辑订阅者

订阅者 列表页面,单击操作列的编辑,可修改订阅者属性。
说明:
仅支持修改订阅者的消息过滤标签重试策略

删除订阅者

订阅者 列表页面,单击操作列的删除,可删除订阅者。