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
这个页面对您有帮助吗?
有用
有用
无用
无用