EventMesh 发布由腾讯贡献的 CNCF Serverless Workflow Engine 实现

EventMesh 动态事件驱动的应用程序运行时，能够用动态插件式基础服务对系统进行解耦，支持不同技术栈的混合多云、复杂分布的拓扑结构等广泛用例。以事件驱动为核心，增强事件处理能力，优化编排协调过程，并提供联邦治理机制。为企业实现数字化转型提供了应用进程间通信的全套解决方案，帮助企业降低系统复杂度，节约开发维护成本。

EventMesh v1.7.0是进入Apache孵化后更新的第6个版本，本次版本为大家带来了 14 个新增特性，其中重磅的EventMesh Workflow Engine特性来自于腾讯的朱同学(GitHub id Walter)贡献，同时强化了 28 个模块，完善和修复了 22 个可能的安全问题，在文档和代码风格方面做了 9 处改进……具体有哪些，请大家下滑了解一下，关于分布式运行时用起来有多爽？效果怎么样？案例有哪些？欢迎来社区讨论!

EventMesh架构图 EventMesh v1.7.0版本新增的主要特性：

支持工作流引擎与服务编排

EventMesh Workflow Engine在本次版本与大家见面，其设计的整体架构如下图所示：

EventMesh Workflow架构图工作流引擎核心部分分为了两个模块：EventMesh Workflow与EventMesh Catalog，同时插件部分包含了：Task、Queue、Scheduler、Protocol、Store、Naming。核心部分提供了系统运行所需的最小功能集，而插件是独立的组件，包含自定义的各种业务代码，用来向核心系统增强或扩展额外的业务能力。基于这种自上而下的3层存算分离插件化架构，可以扩展出不同类型的事件存储(MQ/SQL/NO-SQL等)和不同的通信协议(grpc/http/cloudevents等)。

EventMesh Workflow交互图从上图中我们可以看到，应用服务通过AsyncAPI来描述定义服务，并通过SDK向EventMesh Catalog服务注册，Catalog服务实现服务的解析与发现；基于配置化理念，EventMesh Workflow DSL遵从CNCF Serverless Workflow Spec，解析后的DSL包含了State\Action\Function\Event\Retry模块，同时工作流的事件收发统一采用了CloudEvents标准事件协议，EventMesh实例实现交互。如下图所示，为下单-支付-运送 Workflow DSL示例：

Workflow DSL 示例图 EventMesh Workflow运行时特性： • 持久化 1. 工作流任务是持久化存储， 2.任务调度完成时间不做约束，可以是几秒，几分，甚至几小时。 • 可靠性 1. 任务执行是可靠的，在失败后是完全可自愈的。 2. 任务状态机保障工作流执行的状态在面对故障和中断时保持不变，并从最新状态恢复执行。 • 可扩展性 Task，Workflow-Engine，Scheduler组件可以集群模式部署，快速水平扩展，提升系统整体吞吐。 • 可观测性 1. Workflow执行过程溯源，包括过程耗时，执行链路 2. 关键指标，日志上报，基于OpenTelemetry标准

多元化事件存储与注册中心的支持

除了上面的工作流引擎特性以外，本次版本还扩展了不同的事件存储插件(RabbitMQ\Pulsar\Knative\Redis\Pravega等)，用户可以根据自己的业务场景来选择不同的存储插件。并支持集成zookeeper作为注册中心，同时扩展了pinpoint作为EventMesh trace的插件。

多语言客户端的扩充

本次版本客户端部分新增了Rust SDK，同时在现有JavaSDK基础上支持对接EventMesh Workflow与Catalog服务的功能，并配备了相应的demo示例，方便用户体验workflow功能。 GitHub repo：https://github.com/apache/incubator-eventmesh Gitee repo：https://gitee.com/WeBank/EventMesh Website：https://eventmesh.incubator.apache.org/ WeChat ID：EventMesh Slack（indate 2023-01-06）：https://join.slack.com/t/apacheeventmesh/shared_invite/zt-1kzy4mlx2-0_20N_T3pwiZ1zR_Y8Vmgg

特性