用途：为事件驱动架构、后台任务处理和服务解耦提供异步通信模式，适用于长耗时操作阻塞 HTTP 请求、服务解耦、保证投递、事件流分析、工作流编排和后台任务等场景。
主要能力：给出消息代理选型决策树——事件流/日志聚合选 Apache Kafka，简单后台任务选 Celery+BullMQ+Asynq 等任务队列，复杂工作流/Saga 选 Temporal，请求-回复/RPC 选 NATS，复杂路由选 RabbitMQ，已用 Redis 可选 Redis Streams；并提供吞吐与延迟对比。同时覆盖事件命名规范（Domain.Entity.Action.Version）、事件 Schema 结构、死信队列、幂等性、SSE 前端任务状态更新等模式，以及需避免的反模式（长操作同步 API、非幂等消费者、忽略 DLQ、用 Kafka 做请求-回复）。
使用方式：按需安装依赖，如 Python 用 pip install confluent-kafka celery[redis] temporalio aio-pika redis，TypeScript 用 npm install kafkajs bullmq @temporalio/client amqplib ioredis，Rust 用 cargo add rdkafka lapin async-nats redis，Go 用 go get 对应 SDK。仓库提供 examples/ 与 references/ 目录及 scripts 脚本（如 python scripts/kafka_producer_consumer.py、python scripts/validate_message_schema.py）。
限制：资料未提供具体收费、价格、平台支持范围与效果数据；部分示例代码与参考文档需在仓库内查看，本介绍不展开完整代码。