- 文档首页
消息队列 RocketMQ版
用户指南
Topic 管理
轻量主题管理
轻量主题管理
本文介绍如何管理轻量主题(LiteTopic)功能。
LiteTopic 是消息队列 RocketMQ 5.x 版实例提供的一种适用于海量、细粒度、动态变化的通信场景的主题类型。与传统 Topic 相比,有如下优势:
- 海量主题资源:支持百万级的动态 Topic 资源和自动化的生命周期管理。
- 灵活订阅模型:同一消费组内每个消费者可以订阅不同的 LiteTopic 集合,并支持动态增减订阅,打破传统组内订阅关系一致的限制,实现订阅隔离与排他消费。
- 顺序消息保证:每个 LiteTopic 内仅包含单一队列,消息严格顺序存储、顺序消费,且只能被一个消费者线程处理。
- 自动化生命周期:发送或订阅时 LiteTopic 自动创建,过期无新消息后自动删除,无需手动维护资源创建与回收,大幅降低管理复杂度。
- 精细化资源隔离:支持存储与权限的细粒度隔离,可针对单个 LiteTopic 实施独立权限控制与存储管理。
- 在企业级大模型的长会话场景中,单个会话往往持续时间长、上下文依赖强,并且可能伴随多轮消息往返和中间状态回传。若多个会话共享同一队列,容易出现消息阻塞、上下文乱序、不同用户任务相互干扰等问题。LiteTopic 适用于将单个 AI 会话映射为独立的消息流。每个会话可绑定独立 LiteTopic,由系统按顺序处理消息,满足长会话场景对上下文顺序性和隔离性的要求。具体优势如下:
- 会话级隔离:每个会话独立承载,减少不同会话之间的相互干扰。
- 严格顺序处理:默认单队列模型,更适合需要保持上下文顺序的 AI 会话链路。
- 支持海量动态会话:可支撑百万级 AI 会话,无需为每个会话预先维护传统队列资源。
- 在企业级 AI 应用中,一个用户请求往往需要由多个 Agent 分工协作完成,例如任务拆解、任务处理、结果汇总等。这类场景对消息链路的隔离性、异步解耦和资源弹性提出了更高要求。LiteTopic 适用于承载 Supervisor(主 Agent) 与 Sub-Agent(子 Agent) 之间的任务分发和结果回收。系统可按任务动态创建 LiteTopic,任务完成后自动释放,支持多智能体协作场景下的异步解耦与并行处理。具体优势如下:
- 任务级隔离:不同 Agent、不同任务之间互不干扰,避免任务间相互阻塞。
- 动态创建与自动释放:适合临时性、按需创建的 Agent 任务通信链路。
- 异步并行处理:支持主流程快速下发任务,子任务独立处理并回传结果。
- 结果有序且隔离:每个任务拥有独立 LiteTopic,便于任务分发与结果回收。
- 仅 5.x 版本的 RocketMQ 实例支持该功能。
创建 5.x 版本 RocketMQ 实例时,已添加轻量主题功能标签,标签键:rmq:sys:version-capability,标签值:lite-topic。创建实例的具体操作,请参见创建实例。 - 在 Topic 管理页签,单击创建 Topic。
已创建轻量主题。
- 在 Topic 管理页签,单击目标轻量主题名称。
- 您可以在主题详情页面,查看轻量主题的基本信息、消费组信息、密钥权限和云监控信息。
- 您可以在该区域查看轻量主题关联的消费组信息。关于消费组的更多信息,请参见创建 Group。
已创建轻量主题。
- 方式一:在 Topic 管理页签,单击目标轻量主题操作列的编辑。
- 在 Topic 管理页签,单击目标轻量主题名称。
- 在基本信息区域,单击自动删除 Topic 后的编辑。
- 在编辑对话框中打开、关闭自动删除或设置过期时间。
- 已删除目标轻量主题绑定所有LITE_SELECTIVE消费模式的 Group。
- 在 Topic 管理页签,单击目标轻量主题操作列的删除。
- 在删除对话框中,确认待删除的 Topic 名称和所在的实例 ID。
说明
若系统检测到当前轻量主题存在绑定的LITE_SELECTIVE消费模式的 Group,您需要选中此消费模式的 Group,并单击批量删除,删除绑定关系。
最近更新时间:2026.06.22 18:39:50