You need to enable JavaScript to run this app.
文档中心
消息队列 RocketMQ版

消息队列 RocketMQ版

复制全文
下载 pdf
Topic 管理
轻量主题管理
复制全文
下载 pdf
轻量主题管理
本文介绍如何管理轻量主题(LiteTopic)功能。
功能简介
LiteTopic 是消息队列 RocketMQ 5.x 版实例提供的一种适用于海量、细粒度、动态变化的通信场景的主题类型。与传统 Topic 相比,有如下优势:
  • 海量主题资源:支持百万级的动态 Topic 资源和自动化的生命周期管理。
  • 灵活订阅模型:同一消费组内每个消费者可以订阅不同的 LiteTopic 集合,并支持动态增减订阅,打破传统组内订阅关系一致的限制,实现订阅隔离与排他消费。
  • 顺序消息保证:每个 LiteTopic 内仅包含单一队列,消息严格顺序存储、顺序消费,且只能被一个消费者线程处理。
  • 自动化生命周期:发送或订阅时 LiteTopic 自动创建,过期无新消息后自动删除,无需手动维护资源创建与回收,大幅降低管理复杂度。
  • 精细化资源隔离:支持存储与权限的细粒度隔离,可针对单个 LiteTopic 实施独立权限控制与存储管理。
应用场景
  • AI 长会话管理
  • 在企业级大模型的长会话场景中,单个会话往往持续时间长、上下文依赖强,并且可能伴随多轮消息往返和中间状态回传。若多个会话共享同一队列,容易出现消息阻塞、上下文乱序、不同用户任务相互干扰等问题。LiteTopic 适用于将单个 AI 会话映射为独立的消息流。每个会话可绑定独立 LiteTopic,由系统按顺序处理消息,满足长会话场景对上下文顺序性和隔离性的要求。具体优势如下:
  • 会话级隔离:每个会话独立承载,减少不同会话之间的相互干扰。
  • 严格顺序处理:默认单队列模型,更适合需要保持上下文顺序的 AI 会话链路。
  • 支持海量动态会话:可支撑百万级 AI 会话,无需为每个会话预先维护传统队列资源。
  • Multi-Agent 协同任务编排
  • 在企业级 AI 应用中,一个用户请求往往需要由多个 Agent 分工协作完成,例如任务拆解、任务处理、结果汇总等。这类场景对消息链路的隔离性、异步解耦和资源弹性提出了更高要求。LiteTopic 适用于承载 Supervisor(主 Agent) 与 Sub-Agent(子 Agent) 之间的任务分发和结果回收。系统可按任务动态创建 LiteTopic,任务完成后自动释放,支持多智能体协作场景下的异步解耦与并行处理。具体优势如下:
  • 任务级隔离:不同 Agent、不同任务之间互不干扰,避免任务间相互阻塞。
  • 动态创建与自动释放:适合临时性、按需创建的 Agent 任务通信链路。
  • 异步并行处理:支持主流程快速下发任务,子任务独立处理并回传结果。
  • 结果有序且隔离:每个任务拥有独立 LiteTopic,便于任务分发与结果回收。
限制说明
  • 轻量主题为邀测功能,如需使用,请联系客户经理。
  • 仅 5.x 版本的 RocketMQ 实例支持该功能。
创建轻量主题
前提条件
创建 5.x 版本 RocketMQ 实例时,已添加轻量主题功能标签,标签键:rmq:sys:version-capability,标签值:lite-topic。创建实例的具体操作,请参见创建实例
操作步骤
  1. 实例列表页面,单击目标实例名称。
  1. Topic 管理页签,单击创建 Topic
  1. 在创建 Topic 面板,设置如下参数。
  • 参数
    说明
    Topic 名称
    设置 Topic 的名称。命名规则如下:
    • 长度为 3~127 个字符。
    • 只能包含英文、数字、中划线(-)或下划线(_)。
    • 同一实例下 Topic 名称必须唯一,不同实例间的 Topic 名称可以重复。
    • Topic 名称中不可包含以下保留字符或特殊前缀。
    • 保留字符:RMQ_SYS_TRANS_OP_HALF_TOPIC、BenchmarkTest、TBW102、OFFSET_MOVED_EVENT、SELF_TEST_TOPIC、RMQ_SYS_TRANS_HALF_TOPIC、SCHEDULE_TOPIC_XXXX、RMQ_SYS_TRACE_TOPIC
    • 特殊前缀:rocketmq-broker-、%RETRY%、rmq_sys_、%DLQ%
    消息类型
    选择轻量消息
    自动删除
    当轻量主题连续经过指定时长无新消息写入时,将被自动删除。默认开启,您可以单击开关关闭。
    过期时间
    当开启自动删除时,您需要设置该轻量主题的过期时间,单位为分钟,可取范围为 30~720 之间的整数,默认值为 60。
    描述
    设置该轻量主题的描述信息。
  1. 单击创建。
查看轻量主题详细信息
前提条件
已创建轻量主题。
操作步骤
  1. 实例列表页面,单击目标实例名称。
  1. Topic 管理页签,单击目标轻量主题名称。
  1. 您可以在主题详情页面,查看轻量主题的基本信息消费组信息密钥权限云监控信息。
  • 基本信息
  • 参数
    说明
    Topic 名称
    轻量主题的名称。
    您可以单击复制图标复制名称。
    状态
    轻量主题的运行状态。
    描述
    轻量主题的描述信息。
    您可以单击编辑图标编辑描述信息。
    消息类型
    轻量主题对应的消息类型,取值为轻量消息
    自动删除 LiteTopic
    轻量主题是否开启自动删除。
    您可以单击编辑,修改该设置。具体操作,请参见编辑轻量主题自动删除信息
    创建时间
    轻量主题的创建时间。
    所属实例
    轻量主题所属的实例 ID。
  • 消费组信息
  • 您可以在该区域查看轻量主题关联的消费组信息。关于消费组的更多信息,请参见创建 Group
  • 参数
    说明
    Group ID
    轻量主题关联的消费组的 Group ID。
    您可以单击 ID 进入该 Group 的详情页面。
    消费模式
    轻量主题的消费模式。
    • LITE_SELECTIVE:用于订阅 Lite 类型的 Topic。
    • CLUSTERING:用于订阅非 Lite 类型的其它类型 Topic。
    订阅规则
    订阅的规则,控制台直接透传消费组订阅此 Topic 时指定的字符串,一般为*TAG1 || TAG2
  • 密钥权限
  • 关于密钥权限的更多信息,请参见密钥权限
  • 云监控
编辑轻量主题自动删除信息
前提条件
已创建轻量主题。
操作步骤
  1. 实例列表页面,单击目标实例名称。
  1. 您可以选择以下任一方式打开编辑对话框。
  • 方式一:在 Topic 管理页签,单击目标轻量主题操作列的编辑
  • 方式二:
  1. Topic 管理页签,单击目标轻量主题名称。
  1. 基本信息区域,单击自动删除 Topic 后的编辑
  1. 编辑对话框中打开、关闭自动删除或设置过期时间
  1. 设置完成后,单击保存
删除轻量主题
前提条件
  • 已创建轻量主题。
  • 已删除目标轻量主题绑定所有LITE_SELECTIVE消费模式的 Group。
操作步骤
  1. 实例列表页面,单击目标实例名称。
  1. Topic 管理页签,单击目标轻量主题操作列的删除。
  1. 在删除对话框中,确认待删除的 Topic 名称和所在的实例 ID。
说明
若系统检测到当前轻量主题存在绑定的LITE_SELECTIVE消费模式的 Group,您需要选中此消费模式的 Group,并单击批量删除,删除绑定关系。
  1. 单击删除
最近更新时间:2026.06.22 18:39:50
这个页面对您有帮助吗?
有用
有用
无用
无用