Apache Pekko 框架概述

Apache Pekko 是一个开源的框架，旨在简化并发、分布式、弹性和弹性应用的开发。它基于 Actor 模型，提供了高层次的并发抽象，使开发者能够专注于业务逻辑，而无需处理底层的实现细节。Pekko 起源于 Akka 2.6.x 的分支，并在 Akka 采用商业源码许可证（Business Source License）之前诞生。两年前，Pekko 进入了 Apache 软件基金会的孵化阶段，去年发布了 1.0 版本，目前最新版本为 1.0.2。

现代计算机架构的挑战

在现代计算机架构中，即使在管理良好的数据中心环境中，组件崩溃、消息丢失和网络延迟波动等问题依然存在。Pekko 通过提供多线程行为，无需使用原子操作或锁等底层并发构造，帮助开发者应对这些挑战。此外，Pekko 还提供了透明的远程通信能力，简化了系统及其组件之间的通信，消除了编写和维护复杂网络代码的需求，并提供了基于需求动态扩展的集群高可用架构，从而构建弹性和可扩展的应用。

Actor 模型

Pekko 基于 Actor 模型，该模型提供了一种抽象层次，简化了正确的并发、并行和分布式系统的开发。Actor 是 Pekko 中的基本计算单元，封装了状态、行为、邮箱、子 actor 和监督策略。这种抽象使开发者能够以 actor 之间的通信来思考代码，类似于大型组织中的交流。

在 Actor 模型中，actor 通过发送消息进行通信，而不会转移执行线程。这种非阻塞通信使 actor 在相同时间内能够完成更多的工作，相比传统的方法调用更具效率。actor 的行为类似于对象，它们对消息做出反应，并在处理完当前消息后返回执行。接收到消息后，actor 可以执行以下三个基本操作：向已知的 actor 发送有限数量的消息；创建有限数量的新 actor；指定应用于下一条消息的行为。

Pekko 的模块化设计

Pekko 是一个模块化应用，包含多个模块以提供可扩展性。主要组件包括：

• Pekko Persistence：使 actor 能够在失败时或集群迁移期间持久化事件，提供了开发事件溯源应用的抽象。
• Pekko Streams：提供了流处理解决方案，无缝处理背压，并确保与其他 Reactive Streams 实现的互操作性。
• Connectors 模块：包括与 Kafka 和 Cassandra 等系统集成的连接器。
• Http 和 gRPC 模块：提供了 HTTP 和 gRPC 功能，以及一系列用于操作和管理 Pekko 集群的实用工具。

通过这些模块，Pekko 提供了一个全面的框架，帮助开发者构建高效、可靠且可扩展的分布式系统。