创建和管理 Topic

Topic 是 SOFAStack 消息队列里对消息的一级归类,消息生产者将消息发送到 Topic,而消息消费者则通过订阅该 Topic 来获取和消费消息。

创建 Topic

  1. 进入消息队列控制台页面,左侧导航栏选择 Topic 管理,进入 Topic 列表页面。

  2. 单击列表左上方的 创建 Topic,在新弹出的对话框中,输入或选择 Topic 信息:

    • Topic:Topic 名称,命名不能以 “CID” 和 “GID”开头,只能包含英文、数字、 短横线(-)和下划线(_),且长度需控制在 3-64 个字符之间。

    • 消息类型:支持的消息类型有普通消息、分区顺序消息、事务消息和定时/延时消息。详细消息类型的说明,可参见 消息类型

    • 描述:可选,对该 Topic 的备注内容。创建 topic

  3. 单击 确定,即可创建成功。

Topic 创建成功后,您可以选择 进入详情页发送测试消息

查看 Topic 详情

在 Topic 列表中,单击您想要查看的 Topic 名称,即可进入该 Topic 的详情页。详情页提供了以下信息:

  • 基本信息:包括 Topic 名称、类型、权限、创建时间和描述。

  • 订阅关系:包括最近发送时间以及订阅了该 Topic 的所有 Group ID 及其相关信息,如消费模式等。查看 Topic 详情

  • 资源监控:可查看选定时段内该 Topic 的每分钟与每秒钟的消息生产数据、每分钟的数据量、消息平均大小等相关数据变化信息,如下图所示。topic资源监控

发送测试消息

发送测试消息用于快速验证 Topic 资源的可用性,主要用作测试,发送成功之后可在消息查询查看发送情况。正式生产请使用 调用 SDK 发送消息

  1. 在 Topic 列表中,找到想要的 Topic,单击其操作列的 发送测试消息

  2. 发送测试消息 窗口中,输入以下信息:

    • Tag:可选,消息标签,二级消息分类,用来进一步区分某个 Topic 下的消息分类。详见 Topic 与 Tag

    • Key:可选,消息的业务标识,由消息生产者设置,唯一标识某个业务逻辑。

    • 消息体:必填,需要发送的具体消息内容。验证 topic

  3. 单击 确定,即可发送测试消息。

消息发送后,您可以直接单击 进入消息查询 查看该消息的发送情况,或复制该消息的 MessageID 稍后手动查询该消息。有关消息查询的更多信息,参见 消息查询

删除 Topic

不再使用的 Topic 请及时删除,避免产生不必要的费用。

  1. 在 Topic 列表中,找到待删除的 Topic,单击其操作列的 删除

  2. 在弹出的确认窗口中,单击 确定,即可完成删除。

    注意

    Topic 删除之后,相关的生产者、消费者将会立即停止服务,且将在 10 分钟后完成所有相关资源的清理,请谨慎操作。

更多信息

阿里云首页 金融分布式架构 相关技术圈