Akka Cluster Bootstrap通过使用Akka Discovery方法对等节点形成(或加入)群集。 它是使用在动态部署环境(如Kubernetes或AWS)中替代配置静态种子节点。
先决条件
Cluster Bootstrap需要两个部分:Akka Discovery和Akka Management
Cluster Bootstrap需要选择一个集群发现机制,好的推荐默认的是DNS。
依赖
添加akka-management-cluster-bootstrap和一个或多个发现机制以用于发现过程。下面的配置是使用DNS发现机制
libraryDependencies ++= Seq(
"com.lightbend.akka.management" %% "akka-management-cluster-bootstrap" % "1.0.1",
"com.typesafe.akka" %% "akka-discovery" % "2.5.21"
)
注意:akka-discovery已经是akka-management-cluster-bootstrap的传递依赖,但在应用程序的构建中明确定义它以使Akka版本与应用程序中的其他依赖项保持一致是很好的。 所有Akka模块的版本必须相同,例如 akka-actor,akka-discovery和akka-cluster必须是同一版本。
支持的最低Akka版本是2.5.21。 对于akka-discovery使用相同的Akka版本,与应用程序中的其他Akka依赖项一样。 建议使用最新的Akka补丁版本,并且可以使用2.5.21以后的版本。
使用
首先Akka management先启动:
// bootstrap使用Akka Management来托管http路由
AkkaManagement(system).start()
// 需要明确的启动Bootstrap
ClusterBootstrap(system).start()
配置中不配置种子节点,并且在每个节点上调用start()。
需要在application.conf增加下面的配置信息,其他的具体参考reference.conf:
akka.management.cluster.bootstrap.contact-point-discovery.service-name:此集群实例的部署环境中的唯一名称,用于在服务发现中查找对等项。 如果未设置,它将从ActorSystem名称派生。
akka.management.cluster.bootstrap.contact-point-discovery.discovery-method:预期的服务发现机制(来自Akka Discovery提供的选择)。 如果未设置,则从akka.discovery.method返回到系统范围的默认值。
Bootstrap如何工作
- 每个节点都公开一个HTTP连接点 /bootstrap/seed-nodes。 这是由akka-management-cluster-bootstrap提供的,并通过启动Akka管理自动公开。
- 在引导期间,每个节点重复地查询服务发现以获得初始接触点(contact point),直到至少找到contact-point-discovery.required-contact-point-nr中定义的接触点的数量。
- 然后,每个节点探测找到的联系点的/ bootstrap / seed-nodes 服务短点列表,以查看是否已形成集群
1.如果存在现有集群,则它将加入集群并完成引导。
2.如果不存在集群,则每个节点返回一个空的种子节点列表。 在这种情况下,在这些接触点的节点中处于最低地址的那个节点形成一个新的cluster集群,开始将他通告为种子节点。 - 其他节点将开始查看自己加入的/ bootstrap / seed-nodes节点列表,并将加入其集群。
加入的优先机制
由于Akka Cluster允许节点使用多种不同的方法连接到集群,因此严格定义每个方法的优先级,如下所示:
1.如果akka.cluster.seed-nodes(在你的application.conf中)非空,那么这些节点将被连接,即使调用了bootstrap调用了start,bootstrap也不会执行,但会记录一个警告。
2.如果在引导程序完成之前调用了显式的cluster.join或cluster.joinSeedNodes,则该连接将优先于引导程序(但不建议这样做,请参阅下文)。
3.Cluster Bootstrap内部机制,需要一些时间才能完成,但最终会发出joinSeednodes。
注意:不建议混合各种连接机制。 选择一种机制并坚持下去,以避免在群集形成过程中出现任何意外。 例如。 如果您要使用Bootstrap机制,请不要设置akka.cluster.seed节点。