创建和管理 Topic
Topic 是 SOFAStack 消息队列里对消息的一级归类,消息生产者将消息发送到 Topic,而消息消费者则通过订阅该 Topic 来获取和消费消息。
创建 Topic
进入消息队列控制台页面,左侧导航栏选择 Topic 管理,进入 Topic 列表页面。
单击列表左上方的 创建 Topic,在新弹出的对话框中,输入或选择 Topic 信息:
Topic:Topic 名称,命名不能以 “CID” 和 “GID”开头,只能包含英文、数字、 短横线(-)和下划线(_),且长度需控制在 3-64 个字符之间。
消息类型:支持的消息类型有普通消息、分区顺序消息、事务消息和定时/延时消息。详细消息类型的说明,可参见 消息类型。
描述:可选,对该 Topic 的备注内容。
单击 确定,即可创建成功。
Topic 创建成功后,您可以选择 进入详情页 或 发送测试消息。
查看 Topic 详情
在 Topic 列表中,单击您想要查看的 Topic 名称,即可进入该 Topic 的详情页。详情页提供了以下信息:
基本信息:包括 Topic 名称、类型、权限、创建时间和描述。
订阅关系:包括最近发送时间以及订阅了该 Topic 的所有 Group ID 及其相关信息,如消费模式等。
资源监控:可查看选定时段内该 Topic 的每分钟与每秒钟的消息生产数据、每分钟的数据量、消息平均大小等相关数据变化信息,如下图所示。
发送测试消息
发送测试消息用于快速验证 Topic 资源的可用性,主要用作测试,发送成功之后可在消息查询查看发送情况。正式生产请使用 调用 SDK 发送消息。
在 Topic 列表中,找到想要的 Topic,单击其操作列的 发送测试消息。
在 发送测试消息 窗口中,输入以下信息:
Tag:可选,消息标签,二级消息分类,用来进一步区分某个 Topic 下的消息分类。详见 Topic 与 Tag。
Key:可选,消息的业务标识,由消息生产者设置,唯一标识某个业务逻辑。
消息体:必填,需要发送的具体消息内容。
单击 确定,即可发送测试消息。
消息发送后,您可以直接单击 进入消息查询 查看该消息的发送情况,或复制该消息的 MessageID 稍后手动查询该消息。有关消息查询的更多信息,参见 消息查询。
删除 Topic
不再使用的 Topic 请及时删除,避免产生不必要的费用。
在 Topic 列表中,找到待删除的 Topic,单击其操作列的 删除。
在弹出的确认窗口中,单击 确定,即可完成删除。
注意Topic 删除之后,相关的生产者、消费者将会立即停止服务,且将在 10 分钟后完成所有相关资源的清理,请谨慎操作。