正告
此模块以后被标记为可能会更改,因为它是一项新性能,取得理论应用状况的反馈后确定最终确定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。
可扩展性
该群集工具仅实用于大量消费者,无奈很好地扩大到大范畴。在大型集群中,倡议应用角色限度节点数量,分片守护程序过程将在其上运行。