正在加载模式…

📬

消息队列(MQ)

异步消息传递系统，在分布式智能体系统中实现 AI 智能体与服务之间的解耦通信

复杂度: high多智能体

30秒速览

是什么: 智能体不再彼此直接调用，而是把消息发送到队列，从而实现异步处理并解耦服务依赖。
何时使用: 多个智能体需要在互不阻塞的情况下协调工作、应对波动的负载，或在故障后恢复而不丢失任务。
注意: 消息顺序和重复处理会变得复杂；跨队列、生产者与消费者排查分布式故障的难度显著上升。

向AI专家咨询此模式

打开助手并预填您的问题,发送前可先确认。

以MCP服务器形式获取此目录为该模式调优提示词

异步消息传递系统，在分布式智能体系统中实现 AI 智能体与服务之间的解耦通信

Asynchronous agent communication
Message persistence and durability
Priority-based task distribution
Multi-agent coordination
Fault tolerance and recovery
Scalable load balancing
Event-driven workflows
Dead letter queue handling

The Agent Architect

每周一个模式、一个权衡、一个生产事故案例。为构建智能体系统的人准备的每周简报。

每周一封邮件,一键退订。您的地址仅用于发送简报。

参考资料

该模式所依据的论文、规范和代码仓库。

SEDA: An Architecture for Well-Conditioned, Scalable Internet Services (2001)
Kafka: a Distributed Messaging System for Log Processing (NetDB 2011)
Kafka versus RabbitMQ (2017)arXiv:1709.00333

由本目录背后的工程师执行

为你的智能体架构做一次评审

本页讲的是一个模式。真实系统会同时跑几十个，而多数故障恰恰出在它们的衔接处。我们按本目录的 288 个模式评审你的整体设计：架构、可靠性、评测与成本，每一条结论都对应到能修复它的模式。

€750（原价 €1,500），一周交付，书面报告加讲解通话，9月30日前

查看评审

模式

正在加载模式…

设计模式与技术

正在加载模式…

📬

消息队列(MQ)

异步消息传递系统，在分布式智能体系统中实现 AI 智能体与服务之间的解耦通信

复杂度: high多智能体

30秒速览

是什么: 智能体不再彼此直接调用，而是把消息发送到队列，从而实现异步处理并解耦服务依赖。
何时使用: 多个智能体需要在互不阻塞的情况下协调工作、应对波动的负载，或在故障后恢复而不丢失任务。
注意: 消息顺序和重复处理会变得复杂；跨队列、生产者与消费者排查分布式故障的难度显著上升。

向AI专家咨询此模式

打开助手并预填您的问题,发送前可先确认。

以MCP服务器形式获取此目录为该模式调优提示词

核心机制

消息队列通过持久化队列在生产者与消费者之间实现异步、解耦的通信。Broker 提供投递保证 (至少一次、至多一次，有时为恰好一次)、排序选项 (按分区/组)、确认、重试与死信处理。常见实现包括 Apache Kafka (基于日志的分区、消费者组)、RabbitMQ/AMQP (队列、交换机、绑定)、AWS SQS 与 Google Pub/Sub 等云队列、NATS JetStream 以及 Redis Streams。

工作流 / 步骤

生产者发布消息 (可带键以控制排序/分区)。
Broker 持久化/入队并按配置复制，同时暴露消费滞后/偏移量或队列深度。
消费者以预取/流控方式拉取或接收消息，并在超时与预算内处理。
成功则确认；失败则带退避重试或转入死信队列 (DLQ)。
运维人员监控指标，并为吞吐量与 SLO 调整分区、消费者与配额。

最佳实践

设计幂等消费者，并使用幂等键安全处理重复消息。

用超时限定处理时长；实现指数退避 + 抖动；限制重试次数并使用 DLQ。

明确选择投递语义；为每个主题/队列记录排序保证。

使用消费者组与分区/分片实现水平扩展；避免热键。

施加背压：调优预取/流控；适当批处理；限制在途消息数。

校验消息模式 (例如 Avro/Protobuf/JSON Schema)；使用模式注册表与兼容性规则。

隔离副作用；使用 Outbox 模式保证 DB→队列的原子性；在受支持处确保 exactly-once。

传输中与静态加密；强制授权 (RBAC、IAM) 与按租户配额。

保持消息精简；大 blob 存于外部并传引用；谨慎使用压缩。

观测：输出滞后、队列深度、重投次数与失败原因；结合消息 ID 添加链路追踪。

不适用场景

超低延迟的同步请求/响应路径中，队列开销会突破 SLO → 优先直接 RPC (gRPC/REST)。

高吞吐流上要求严格全局有序，而 broker 无法在不严重损失吞吐的情况下保证。

简单且紧耦合的集成，引入队列只会增加运维复杂度而无明显收益。

常见陷阱

依赖跨分区/队列的隐式顺序；消息键设置不一致。

重试时的非幂等副作用 → 重复与数据损坏。

由于缺少背压或扩容不足，队列无限增长且消费滞后加剧。

重试风暴与惊群效应；缺少熔断器与带抖动的退避。

broker 中承载大载荷；缺少模式演进策略导致消费者失效。

核心特性

投递语义：至少一次 / 至多一次 / 恰好一次 (取决于平台)。

排序控制：分区键、FIFO 组、排序键。

持久性与复制；确认与重投策略。

DLQ、TTL 以及定时/延迟投递。

消费者组、预取/流控与背压。

模式注册表与兼容模式；消息版本管理。

KPI / 成功指标

端到端延迟 p50/p95/p99；发布与消费延迟。

按主题/队列与消费者组统计的吞吐量 (msgs/s、MB/s)。

消费滞后/队列深度；最旧消息时长；重投/DLQ 率。

重试与重复率；处理成功/失败率；MTTR。

Broker 健康度：ISR/复制、分区 leader 均衡、存储利用率。

成本 KPI：出口流量、存储、请求计费 (托管服务)。

Token / 资源消耗

资源画像：序列化/压缩与 broker 协调消耗 CPU；缓冲区消耗内存；持久化日志消耗磁盘 I/O；复制与客户端流量消耗网络。

通过批处理与压缩优化；合理设置分区数与消费者并发；限制消息大小 (例如 SQS 256 KB、Pub/Sub 10 MB、Kafka 可配置)。

避免内嵌大 blob；存于外部并发送引用；按租户施加配额与限流。

最佳应用场景

微服务解耦；异步工作流；后台任务处理。

事件驱动架构与扇出处理；审计/事件日志。

削峰填谷与突发平滑；下游背压控制。

跨区域缓冲与间歇性连接下的韧性。

参考资料与延伸阅读

学术论文

实现指南

工具与库

Apache Kafka、RabbitMQ、AWS SQS、Google Pub/Sub、NATS JetStream、Redis Streams
客户端 SDK：librdkafka/Confluent 客户端、Sarama (Go)、Spring Kafka/AMQP、aio-pika、AWS SDK
任务队列：Celery、Sidekiq、Resque、BullMQ、RQ

社区与讨论

异步消息传递系统，在分布式智能体系统中实现 AI 智能体与服务之间的解耦通信

Asynchronous agent communication
Message persistence and durability
Priority-based task distribution
Multi-agent coordination
Fault tolerance and recovery
Scalable load balancing
Event-driven workflows
Dead letter queue handling

The Agent Architect

每周一个模式、一个权衡、一个生产事故案例。为构建智能体系统的人准备的每周简报。

每周一封邮件,一键退订。您的地址仅用于发送简报。

参考资料

该模式所依据的论文、规范和代码仓库。

SEDA: An Architecture for Well-Conditioned, Scalable Internet Services (2001)
Kafka: a Distributed Messaging System for Log Processing (NetDB 2011)
Kafka versus RabbitMQ (2017)arXiv:1709.00333

由本目录背后的工程师执行

为你的智能体架构做一次评审

€750（原价 €1,500），一周交付，书面报告加讲解通话，9月30日前

查看评审

正在加载模式…

消息队列(MQ)

30秒速览

向AI专家咨询此模式

消息队列: 概览

The Agent Architect

参考资料

为你的智能体架构做一次评审

模式

正在加载模式…

设计模式与技术

正在加载模式…

消息队列(MQ)

30秒速览

向AI专家咨询此模式

核心机制

工作流 / 步骤

最佳实践

不适用场景

常见陷阱

核心特性

KPI / 成功指标

Token / 资源消耗

最佳应用场景

参考资料与延伸阅读

学术论文

实现指南

工具与库

社区与讨论

消息队列: 概览

The Agent Architect

参考资料

为你的智能体架构做一次评审

模式

设计模式与技术

正在加载模式…

设计模式与技术

核心机制

工作流 / 步骤

最佳实践

不适用场景

常见陷阱

核心特性

KPI / 成功指标

Token / 资源消耗

最佳应用场景

参考资料与延伸阅读

学术论文

实现指南

工具与库

社区与讨论

设计模式与技术