0

给定以下 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" , "testrole2"]
    seed-nodes = [
      "akka://ClusterSystem@127.0.0.1:25251",
      "akka://ClusterSystem@127.0.0.1:25252"]
    downing-provider-class = "akka.cluster.sbr.SplitBrainResolverProvider"
  }
}

为了辨别演员中的角色，我使用：

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，这是一个可行的解决方案吗？

4

1 回答 1

1

如果您要将不同的角色分配给不同的节点，则这些节点不能使用相同的配置。实现这一点的最简单方法是通过 n1"testRole1"在其akka.cluster.roles列表中和 n2"testRole2"在其akka.cluster.roles列表中。

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

于 2021-06-07T11:50:43.157 回答