美文网首页k8snetty
Akka Cluster Bootstrap官方文档

Akka Cluster Bootstrap官方文档

作者: alexwu59 | 来源:发表于2019-07-31 14:21 被阅读0次

    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节点。

    相关文章

      网友评论

        本文标题:Akka Cluster Bootstrap官方文档

        本文链接:https://www.haomeiwen.com/subject/gkunrctx.html