如何在 Akka 集群中的节点级别指定角色？

如何解决如何在 Akka 集群中的节点级别指定角色？

鉴于以下 appliction.conf :

akka {
  loglevel = debug
  actor {
    provider = cluster

    serialization-bindings {
      "sample.cluster.CborSerializable" = jackson-cbor
    }
  }
  remote {
    artery {
      canonical.hostname = "127.0.0.1"
      canonical.port = 0
    }
  }
  cluster {
roles= ["testrole1","testrole2"]
    seed-nodes = [
      "akka://ClusterSystem@127.0.0.1:25251","akka://ClusterSystem@127.0.0.1:25252"]
    downing-provider-class = "akka.cluster.sbr.SplitBrainResolverProvider"
  }
}

为了区分我使用的 Actor 中的角色：

void register(Member member) {

if (member.hasRole("testrole1")) {
 //start actor a1
}
else if (member.hasRole("testrole2")) {
 //start actor a2
}
}

从 src (https://doc.akka.io/docs/akka/current/cluster-usage.html) 编辑

要为节点启用角色，我使用以下配置：

在 application.conf 中，我为角色配置了数组，但这似乎是在集群级别而不是节点级别。换句话说，似乎不可能配置 application.conf 以指示 Akka 集群在节点 n1 上启动 actor a1，在节点 n2 上启动 actor a2？是否应该在 application.conf 中的 akka.cluster 级别指定注释细节？

对于每个节点，是否需要指定多个application.conf配置文件？

例如 testrole1 的 application.conf

akka {
  loglevel = debug
  actor {
    provider = cluster

    serialization-bindings {
      "sample.cluster.CborSerializable" = jackson-cbor
    }
  }
  remote {
    artery {
      canonical.hostname = "127.0.0.1"
      canonical.port = 0
    }
  }
  cluster {
roles= ["testrole1"]
    seed-nodes = [
      "akka://ClusterSystem@127.0.0.1:25251","akka://ClusterSystem@127.0.0.1:25252"]
    downing-provider-class = "akka.cluster.sbr.SplitBrainResolverProvider"
  }
}

testrole2 的 application.conf :

akka {
  loglevel = debug
  actor {
    provider = cluster

    serialization-bindings {
      "sample.cluster.CborSerializable" = jackson-cbor
    }
  }
  remote {
    artery {
      canonical.hostname = "127.0.0.1"
      canonical.port = 0
    }
  }
  cluster {
roles= ["testrole2"]
    seed-nodes = [
      "akka://ClusterSystem@127.0.0.1:25251","akka://ClusterSystem@127.0.0.1:25252"]
    downing-provider-class = "akka.cluster.sbr.SplitBrainResolverProvider"
  }
}

上面定义的每个application.conf之间的区别是akka.cluster.roles的值要么是“testrole1"，要么是"testrole2"。

应该如何配置 application.conf 以便指示 Akka 集群在节点 n1 上启动actor a1，在节点 n2 上启动actor a2？是否应该在 application.conf 中的 akka.cluster 级别指定节点详细信息？

更新：

另一种选择是通过环境变量传递角色名称？我刚刚注意到这里明确说明了这一点：https://doc.akka.io/docs/akka/current/typed/cluster.html“节点角色在名为 akka.cluster.roles 的配置属性中定义，通常在启动脚本中定义为系统属性或环境变量。”在这种情况下，对所有节点使用相同的 application.conf 文件，但每个节点使用一个环境变量。例如，更新的 appliction.conf（注意添加了“ENV_VARIABLE”）

akka {
  loglevel = debug
  actor {
    provider = cluster

    serialization-bindings {
      "sample.cluster.CborSerializable" = jackson-cbor
    }
  }
  remote {
    artery {
      canonical.hostname = "127.0.0.1"
      canonical.port = 0
    }
  }
  cluster {
roles= ["ENV_VARIABLE"]
    seed-nodes = [
      "akka://ClusterSystem@127.0.0.1:25251","akka://ClusterSystem@127.0.0.1:25252"]
    downing-provider-class = "akka.cluster.sbr.SplitBrainResolverProvider"
  }
}

集群启动脚本通过 ENV_VARIABLE 参数确定每个节点的角色，这是一个可行的解决方案吗？

解决方法

如果您要将不同的角色分配给不同的节点，则这些节点不能使用相同的配置。完成此操作的最简单方法是通过 n1 在其 "testRole1" 列表中具有 akka.cluster.roles 并且 n2 在其 "testRole2" 列表中具有 akka.cluster.roles。

akka.cluster 配置中的所有内容只是配置该节点以参与集群（它在该节点上配置集群组件）。集群的节点之间的一些设置必须相同（例如 SBR 设置），但 n1 上的设置不会影响 n2 上的设置。