背景信息
在实例创建完成后,需要创建主题和订阅组来进行消息实例的日常功能运转。
- 主题:在RocketMQ中,主题(Topic)是消息发布的逻辑分组。它类似于一个消息的分类或者标签,帮助用户将不同类型的消息进行归类和管理。通常情况下,一个主题可以包含多个消息生产者和多个消息消费者。通过使用主题,RocketMQ能够实现高效的消息发布和订阅机制,帮助用户更好地管理和组织消息。
- 订阅组:订阅组是 RocketMQ 中的一个重要概念,用于实现消息的发布与订阅模式。一个订阅组可以包含多个消费者实例,这些实例共同消费同一个主题下的消息。当消息被发送到主题时,订阅组中的每个消费者实例会按照一定规则来均衡地接收消息,并进行相应的处理。订阅组是 RocketMQ 提供的一种灵活且可扩展的方式,用于实现消息的发布与订阅模式,并保证消息在消费者之间的均衡分配和可靠处理。
- 集群:RocketMQ集群是一种由多个节点(或者称为Broker)组成的分布式消息中间件系统。每个节点都具有相同的功能并且可以处理和存储消息。通过将消息分发到不同的节点,RocketMQ集群能够实现高可用性和可伸缩性。通过使用RocketMQ集群,可以实现消息传输的并行处理、容错性和高可用性,满足高并发场景下的消息传递需求。
创建主题
1、 天翼云官网点击控制中心,选择产品分布式消息服务RocketMQ。
2、 登录分布式消息服务RocketMQ控制台,点击右上角地域选择对应资源池。
3、 进入实例列表,点击【管理】按钮进入管理菜单。
4、 进入主题管理菜单,点击【新建主题】按钮
5、 在弹出的新建主题页面,填写如下字段信息
1)默认展示当前集群名称,不可修改。
2)选择主题所在的Broker,按照实例创建时候选择的主备节点对数列出每个broker,可复选。
3)填写主题名称,名字限制2到64个字符,超过限制会导致创建主题失败,用户创建主题只能包含大小写字母数字以及_和-符号。
4)按照实际需求填写主题备注。
5)填写每个Broker分区数,分区数必须大于0,小于等于8,创建严格顺序队列时,设置分区数为1,且只能选择一个broker。
6)选择生产模式,RocketMQ是一个开源的分布式消息中间件,它支持两种消息生产模式:有序和无序。
- 有序消息生产模式(Ordered Message)是指按照特定规则将消息发送到相同的Message Queue中,并且确保消息在消费者端按照相同的顺序进行消费。这种模式适用于那些需要严格按照消息顺序进行处理的场景,比如订单处理、流程审批等。
- 无序消息生产模式(Unordered Message)是指消息发送到不同的Message Queue中,每个Queue都是独立的。消费者可以并行地从多个Queue中消费消息,而无需关心消息的顺序。这种模式适用于那些不需要严格按照消息顺序处理的场景,比如日志收集、异步通知等。
需要注意的是,无论是有序还是无序消息生产模式,RocketMQ都提供了高可靠性的消息传输和存储,并支持水平扩展和高吞吐量的特性。根据具体的业务需求,选择适合的消息生产模式能够更好地满足应用的要求。
7)选择主题的读写权限,支持读写、只读、只写3类权限。
6、 完成主题信息填写后,保存确认即可新增主题。
7、 若希望批量创建主题,可点击【批量创建】按钮
- 批量创建
注意:输入的主题名不要带空格等特殊字符。
通过上传csv文件,批量创建主题。格式:点击【主题模板】按钮下载。
- 主题模板
批量上传主题的模板,必须使用模板,才能够上传成功,模板格式如下:
创建订阅组
1、进入订阅管理菜单,点击【新建】按钮
2、 在弹出的新建订阅组窗口填写相应字段。
1)默认展示当前集群名称,不可修改。
2)填写订阅组名称,名字限制2到64个字符,超过限制会导致创建订阅组失败,用户创建订阅组只能包含大小写字母数字以及_和-符号。
3)按照实际需求填写主题备注。
4)选择订阅组所在的Broker,按照实例创建时候选择的主备节点对数列出每个broker,可复选。
5)选择是否开启消费,默认开启消费。
3、 完成订阅组信息填写后,保存确认即可新增订阅组。
4、 若希望批量创建订阅组,可点击【批量创建】按钮
- 批量创建
注意:注意输入的订阅组名不要带空格等特殊字符
通过csv格式模板上传,批量创建订阅组。格式:点击【订阅组模板】按钮下载。
- 订阅组模板
指批量上传订阅组的模板,必须使用模板,才能够上传成功,模板格式如下: