关于akka:Sharded-Daemon-Process

59次阅读

共计 726 个字符,预计需要花费 2 分钟才能阅读完成。

正告
此模块以后被标记为可能会更改,因为它是一项新性能,取得理论应用状况的反馈后确定最终确定 API。这意味着 API 或语义能够更改,而不会收回正告或弃用期限。还不建议您在生产中立刻应用此模块。

模块信息

要应用 Akka Sharded 守护过程,必须在我的项目中增加以下依赖项:

介绍

分片守护过程提供了一种运行 N 个 actor 的办法,每个 actor 都有一个从 0 开始的数字 ID,而后在整个集群中放弃流动,并保持平衡。当须要从新均衡时,actor 将进行,并由在所有节点上放弃流动运行的节点触发,而后在新节点上启动(放弃流动应被视为实现细节,并且在未来的版本中可能会更改)。

预期的用例是将数据处理工作负载调配给肯定数量的 workers,每个 worker 都须要解决数据子集。通常须要依据 CQRS 应用程序中所有 EventSourcedBehaviors 可用的事件流来创立投影。应用 N 个标记中的一个标记事件,这些标记用于在 N 个 worker 之间调配生产、更新投影的工作量。

对于须要放弃单个 worker 存活的状况,请参阅“群集单例”

根本例子
要设置一组与 Sharded Daemon 过程一起运行的 actor,集群中的每个节点在启动时都须要运行雷同的初始化:

提供了一种额定的工厂办法,以实现进一步的可配置性并为 actor 提供失常的进行音讯。

actors 寻址

在须要将音讯发送给守护过程 actors 的用例中,倡议将零碎接待员与一个 ServiceKey 一起应用,所有守护过程 actors 都将其注册到播送中,或者须要更细粒度的消息传递时应用单个 ServiceKey。

可扩展性

该群集工具仅实用于大量消费者,无奈很好地扩大到大范畴。在大型集群中,倡议应用角色限度节点数量,分片守护程序过程将在其上运行。

正文完
 0