面向 Agent 时代的
事件驱动基础设施
Apache EventMesh 是云原生事件中间件，通过统一事件总线连接服务、系统和 AI Agent。 无服务器、可扩展、协议无关 — 为下一代分布式应用而生。
v1.12.0
最新版本
2.1k+
GitHub Stars
300+
贡献者
20+
连接器
核心能力
构建事件驱动架构
所需的一切
从简单的发布/订阅到复杂的事件编排，EventMesh 提供构建弹性、可扩展、 解耦分布式系统的全套基础设施。
高吞吐事件处理
每秒百万级事件，亚毫秒延迟。支持 RocketMQ、Kafka、AutoMQ 等可插拔事件存储引擎。
CloudEvents 原生
CNCF CloudEvents 规范一等公民支持。跨所有连接器和协议的标准化事件格式。
多协议网关
HTTP、gRPC、TCP、WebSocket 协议统一到一个事件网格。无需改码即可协议转换。
事件编排
基于 Serverless Workflow 的内置事件工作流引擎。用声明式 YAML 定义复杂事件编排。
可靠投递保障
支持至少一次、最多一次、精确一次投递语义。事件存储内置重试、死信队列和事务支持。
安全与治理
内置 mTLS、OAuth2 和 RBAC。事件 Schema 注册中心、审计日志和限流，满足生产级安全需求。
架构设计
分层设计
极致灵活
四层解耦架构 — 每层可独立扩展和替换。 自由组合连接器、协议和事件存储，适配你的基础设施。
v1.12 新特性
A2A 协议支持
Agent 消息总线
EventMesh 正在从传统事件中间件演进为 AI Agent 间通信的统一消息总线， 基于 A2A（Agent-to-Agent）协议构建。
- Agent 发现与路由 — Agent 通过事件网格注册能力并动态发现对等节点
- 异步任务委派 — 长时间运行的 Agent 任务，基于回调的事件完成语义
- 流式通信 — SSE 和 gRPC streaming 支持实时 Agent 交互
- 协议桥接 — 无缝桥接 A2A 与现有 CloudEvents 和遗留消息系统
- 可观测性 — OpenTelemetry 原生链路追踪，贯穿整个 Agent 通信链
🔍
研究 Agent
数据采集
🪨
EventMesh 总线
A2A 协议
📊
分析 Agent
信号处理
⚡
执行 Agent
订单路由
🛡️
风控 Agent
合规检查
📝
报告 Agent
摘要生成
🤖
LLM Agent
推理引擎
生态系统
连接一切
开箱即用的连接器。EventMesh 与你现有的基础设施无缝集成 — 无需推倒重来。
发布
订阅
# 通过 HTTP 发布 CloudEvent curl -X POST http://127.0.0.1:10105/eventmesh/publish/TEST-TOPIC-HTTP-ASYNC -H "Content-Type: application/json" -d '{ "name": "eventmesh", "pass": "password" }' # 响应: { "success": true, "retCode": 0 } 🚀 事件已发布！
加入 EventMesh 社区
Apache EventMesh 是 Apache 软件基金会顶级项目。 加入 300+ 贡献者，共建事件驱动基础设施的未来。