paperbot · PL 论文追踪

全部论文 待读 收藏

P2 RocketMQ-A2A: Reliable Session-Level Replayable Event Streams for Large-Scale Multi-Agent Collaboration

RocketMQ-A2A:面向大规模多智能体协作的可靠会话级可重放事件流
FSE Proceedings of the 34th ACM International Conference on the Foundations of Software Engineering2026匹配度 3/10 · 该论文聚焦多智能体系统在生产环境中的分布式消息中间件、会话重放与容错,属于 Agentic 系统的基础设施层,而非用户核心关注的静态分析、形式化验证、浮点程序分析或贝叶斯程序分析。其工业落地和工程实现虽与用户偏好有交集,但与“PL→AI”或“AI→PL”的研究问题无直接技术关联。引用 0 inbox
Li Zhou, Shuo Zhang, Juntao Ji, Shijie Zhang, Ke Zhao, Yubao Fu, Qingshan Lin
crossref: 2026-09-12dblp: 2026-09-12

AI 速览

一句话:提出会话中心的可重放事件流模型与 Lite-Topic,解决大规模多智能体协作的突发流量、隔离及故障恢复难题。

论文研究阿里云生产级多智能体系统(MAS)的部署瓶颈,核心挑战在运维而非模型:突发流量导致进程内排队、内存压力与 GC 抖动,海量并发下会话隔离昂贵,中间上下文未持久化使故障难恢复。作者提出 RocketMQ-A2A,将每次协作会话建模为持久、可重放的事件流,并用消息中间件解耦任务调度与结果投递,为数千万并发会话提供独立回复流、重放恢复和可审计 A2A 调用链;同时开源 Lite-Topic,以 TTL 管理低开销短生命周期回复通道。评测显示,持久 MQ 积压吸收突发压力,在 25 倍负载下降低堆增长与 Full GC;Lite-Topic 支持数千万级会话隔离;重放使中断任务在下游故障后恢复完成。系统已部署于阿里云百炼。

问题
生产级多智能体系统在阿里云部署时面临突发流量、内存压力与 GC 抖动、海量并发会话隔离昂贵,以及中间上下文未持久化导致故障难恢复等运维瓶颈。
方法
提出会话中心交互模型 RocketMQ-A2A,将每次协作会话建模为持久可重放事件流,通过消息中间件解耦任务调度与结果投递,并提供开源 Lite-Topic 以 TTL 管理低开销短生命周期回复通道。
评估
在 25 倍负载下验证持久 MQ 积压可吸收突发压力并降低下游堆增长与 Full GC,Lite-Topic 支持数千万级会话隔离,重放可使中断任务在下游故障后恢复完成;系统已部署于阿里云百炼平台。
原文摘要(Abstract)

We investigated deployment bottlenecks of production multi-agent systems (MAS) at Alibaba Cloud. We found that the dominant challenges are operational rather than model-centric: bursty traffic causes in-process queuing, memory pressure, and garbage-collection (GC) jitter; session isolation becomes expensive under massive concurrency; and failures are hard to recover from when intermediate context is not persistently recorded and replayable. We propose RocketMQ-A2A, a session-centric interaction model for production MAS. RocketMQ-A2A models each collaboration session as a persistent, replayable event stream, and decouples task scheduling from result delivery through message middleware. This design targets up to tens of millions of concurrent sessions, each with an independent reply stream, and provides replay-based recovery and auditable traces for asynchronous Agent-to-Agent (A2A) call chains without requiring application teams to implement custom isolation, ordering, and replay mechanisms. We implemented and open-sourced RocketMQ-A2A and Lite-Topic in Apache RocketMQ. Lite-Topic provides low-overhead, short-lived session reply channels with TTL-based lifecycle management. Our evaluation shows that durable MQ backlogs absorb burst pressure and reduce downstream heap growth and Full GC under 25× load, Lite-Topic supports session isolation at the tens-of-millions scale, and replay enables interrupted tasks to resume and complete after downstream failures. Our solution has been deployed in production on Alibaba Cloud Model Studio (Bailian), an enterprise-grade platform for building and operating LLM applications end-to-end.

链接与引用

DOI 原文 · PDF(开放获取) · DBLP

BibTeX
@inproceedings{ZhouZJZZFL26,
  title = {RocketMQ-A2A: Reliable Session-Level Replayable Event Streams for Large-Scale Multi-Agent Collaboration},
  author = {Li Zhou and Shuo Zhang and Juntao Ji and Shijie Zhang and Ke Zhao and Yubao Fu and Qingshan Lin},
  booktitle = {FSE},
  year = {2026},
  doi = {10.1145/3803437.3805231}
}