「Agent 工程化」方向-RocketMQ for AI Agent 异步通信架构演进与 Qoder 生产落地实践 LiteTopic 新特性发布 阿里云百炼网关 Qoder Cloud Agents

LiteTopic新特性发布×阿里云百炼网关×QoderCloudAgents1趋势与方案2发布与生态3生产与落地1趋势与方案2发布与生态3生产与落地Agent走向复杂任务，挑战转向等待、恢复与资源分配AGENT任务状态提交执行等待恢复完成02任务的连续性0302任务的连续性03有限GPU资源的分配AgentHarness演进：构建高可靠的“执行控制面(ControlPlane)”架构解耦持久化执行将执行状态与进度Checkpoint持久化，全面转向事(Event-Driven)。优雅处理异步回调、长时互操作性AgentSkills将复杂工作流高度封装，实现上下文执行控制升级AGENT任务状态完成等待恢复执行提交完成等待恢复执行创建会话队列触发任务执行监听状态事件结果回写后恢复消费结果并清理01彻底的状态外置(StatelessApp)02资源释放(ResourceYielding)03原生断点续传(Resumability)消息队列的断点Offset继续执行，八大底层能力支撑：打造Agent会话队列的“极致掌控力”02.自动创建Auto-Create03.TTL清理队列Auto-Expire04.暂停消费Suspend队列级的“暂停键”05.全量订阅WildcardSubscribe07.排它订阅ExclusiveSubscribe07.排它订阅ExclusiveSubscribeMCPAgenticMessagingPrimitivesA2ATransportRocketMQFlinkConnectorOpenClawRocketMQChannelSpringCloudGatewayRocketMQRate核心目标：少改业务代码，用标准协议与插件接入异步Agen超出请求响应的消息模式本轮Roadmap周期本轮Roadmap周期TaskasLiteTopicMCPAgenticsemanticsTaskasLiteTopic6subscribe4RocketMQLiteTopiceventsubscribe45task:Atask:Btask:C1.客户端访问任意副本；处理程序仅进行入队操作4.Worker发布结果，键（key）为tas2.仅在持久化入队后才返回句柄——重启或扩缩容绝不会丢失任务5.结果被持久保留——延迟订阅者可读取当前状态3.一个Task对应一个LiteTopic，LiteTopic以TaskID命名6.01.创建Task与LiteTopic02.异步执行并回写ProgressRUN03.途中追加控制事件04.断连后回放并继续Agent/LLM流式接口依赖SSE/WebSocket长连接；一次推理跨越数秒到数分钟、多轮工具调03Token与GPU成本被浪费03Token与GPU成本被浪费02不支持*通配订阅02不支持*通配订阅LiteTopic会话连续性：断连不丢、续连不重、体验无感0101每会话一条独立队列02通配订阅+无状态应用03断连接管·Offset续推应用节点1Web端1原连接（已断开）x开原连接（已断开）x取消订阅chat/Session2取消订阅chat/Session2Web端2)生成Token1.携带Session2自动重连到节点2生成Token01付费客户不能被普通客户拖累SLAFIRST普通客户不能被付费客户挤掉突发流量不能引发雪崩ANTI-SPIKE01付费客户不能被普通客户拖累SLAFIRST普通客户不能被付费客户挤掉突发流量不能引发雪崩ANTI-SPIKEwatermarkthresholdVIP/PaidClusterAvalancheRegularARegularB(long-tailwatermarkthresholdVIP/PaidClusterAvalancheRegularARegularB(long-tail)80xBurstTenantQuotaguaranteePreciseper-tenantthrottleNoblanketcut02消费者以*通配订阅父Topic--T,I不存在时发送即自动创建不存在时发送即自动创建订阅全部LiteTopicA/B持续正常消费国订阅全部LiteTopicA/B持续正常消费国--------------------Suspend(LiteTopicC)消费后调用消费后调用集群容量充足即可持续扩展QoderCloudAgents的Agents工程实践01长程任务状态延续Serverless云端Agent托管与执行平台02大量会