场景描述
RocketMQ中的Topic是消息发布和订阅的核心概念之一。主题可以理解为消息的分类或者标签,用于将一组相关的消息进行归类和管理。
- 在RocketMQ中,消息发送者通过指定主题来发布消息,而消息消费者则通过订阅主题来接收消息。一个主题可以有多个生产者和多个消费者。生产者将消息发送到主题,而消费者从主题中订阅消息。
- 主题的创建和管理是由RocketMQ的管理员或者应用程序开发者负责的。创建主题时,需要指定主题的名称,并可以设置一些属性,如主题的存储策略、消息的过期时间等。主题的名称应该具有一定的描述性,能够清楚地表达所属消息的含义或用途。
- 主题在RocketMQ中具有一定的灵活性和扩展性。可以根据业务需求创建多个主题,每个主题用于处理不同类型或不同业务场景下的消息。通过合理地设计和管理主题,可以实现消息的高效传递和灵活的消息路由。
总之,主题是RocketMQ中用于分类和管理消息的重要概念,通过主题可以实现消息的发布和订阅,帮助开发者更好地组织和管理消息系统。
Topic列表
1、 进入Topic管理菜单查看Topic列表,若列表为空则新建Topic,创建Topic详情见具体操作步骤。
2、 支持按照集群、Broker和Topic查询,下拉选择或者输入查询内容,点击【查询】按钮即可展示需要的Topic数据。
3、 查看Topic基本信息,包括Topic名、brokerName、读队列数量、写队列数量、权限、是否有序。其中Topic权限包括读写、只读、只写3类权限。
Topic详情
展示当前Topic的统计指标、队列分布信息、消费组、生产组的情况。
1、队列信息
2、消费组
标识正在连接该topic的消费组列表。
消费方式分为两种:
- CONSUME_PASSIVELY为push消费模式
- CONSUME_ACTIVELY为pull消费模式
路由
展示topic的队列分布情况,队列分布在哪些broker上
RocketMQ的队列分布情况是根据Broker的配置和主题的配置来确定的。在RocketMQ中,每个主题可以有多个队列,每个队列可以有多个Broker来提供服务。
队列的分布情况可以通过以下几个因素来确定:
- Broker的配置:在RocketMQ中,每个Broker都有一个唯一的名称,可以通过名称来识别和配置Broker。当创建主题时,可以指定消息队列的数量和分布策略。分布策略可以是固定的,也可以是根据一定规则动态分配的。
- 主题的配置:在创建主题时,可以指定队列的数量和分布策略。分布策略可以是按照固定数量进行分配,也可以是根据一定规则进行动态分配。例如,可以将消息队列均匀地分布在不同的Broker上,也可以根据消息的属性将消息路由到不同的队列。
- 负载均衡策略:RocketMQ提供了多种负载均衡策略,用于在Broker集群中均衡地分布消息队列。负载均衡策略可以根据Broker的负载情况、网络延迟等因素来进行动态调整,以确保消息队列的均衡分布和高效处理。
总的来说,RocketMQ的队列分布情况是根据Broker的配置、主题的配置和负载均衡策略来确定的。通过合理的配置和使用负载均衡策略,可以实现消息队列的均衡分布和高效处理,提高消息系统的性能和可扩展性。
导出
将勾选的topic,导出其配置及路由情况,为excel文件,导出格式如下:
备注:
如果勾选了topic,则导出勾选的topic;如果没有勾选,则导出该集群,选定broker下的所有topic信息。
堆积量
展示该topic被哪些消费组消费,及该消费组对应的未消费的消息数量统计;
通过“offset查询”,可以查找队列相应偏移量的消息;
“TPS监控”:显示指定topic的生产、消费的tps趋势图。