如何在 Scala 和 minikube 中使用 Akka 示例集群 kubernetes？

问题描述

我正在尝试运行 akka-sample-cluster-kubernetes-scala，因为建议使用 akka-management-cluster-bootstrap 将 Akka 集群部署到 minikube。运行 README 文件中推荐的每个步骤后，我可以看到在我的 kubectl 输出上运行的 pod：

$ kubectl get pods
NAME                    READY   STATUS    RESTARTS   AGE
appka-8b88f7bdd-485nx   1/1     Running   0          48m
appka-8b88f7bdd-4blrv   1/1     Running   0          48m
appka-8b88f7bdd-7qlc9   1/1     Running   0          48m

当我执行 ./scripts/test.sh 时，它似乎在最后一步失败了：

"No 3 MemberUp log events found"

而且我无法连接到自述文件中所述的给定地址。错误：

$ curl http://127.0.0.1:8558/cluster/members/
curl: (7) Failed to connect to 127.0.0.1 port 8558: Connection refused

从现在开始，我描述了我如何尝试找到无法使用示例 akka + kubernetes 项目的原因。我试图找出上述错误的原因。我想我必须执行 sbt run，即使示例项目中没有提到它。他们在 ${required_CONTACT_POINT_NR} 处的 application.conf 变量出现以下错误：

[错误] 线程“main”中的异常 com.typesafe.config.ConfigException$UnresolvedSubstitution：应用程序.conf @ jar:file:/home/felipe/workspace-idea/akka-sample-cluster-kubernetes-scala/target/bg-jobs/sbt_12a05599/job-1/target/d9ddd12d/64fe375d/akka-sample-cluster-kubernetes_2.13 -0.0.0-70-49d6a855-20210104-1057.jar!/application.conf： 19：无法解析对值的替换： ${required_CONTACT_POINT_NR}

#management-config
akka.management {
  cluster.bootstrap {
    contact-point-discovery {
      # pick the discovery method you'd like to use:
      discovery-method = kubernetes-api

      required-contact-point-nr = ${required_CONTACT_POINT_NR}
    }
  }
}
#management-config

所以，我想它没有从 kubernetes/akka-cluster.yml 文件中获取配置：name: required_CONTACT_POINT_NR。将其更改为 required-contact-point-nr = 3 或 4 我收到错误：

[error] SLF4J: A number (4) of logging calls during the initialization phase have been intercepted and are
[error] SLF4J: Now being replayed. These are subject to the filtering rules of the underlying logging system.
[error] SLF4J: See also http://www.slf4j.org/codes.html#replay
...
[info] [2021-01-04 11:00:57,373] [INFO] [akka.remote.RemoteActorRefProvider$RemotingTerminator] [] [appka-akka.actor.default-dispatcher-3] - Shutting down remote daemon. MDC: {akkaAddress=akka://appka@127.0.0.1:25520,sourceThread=appka-akka.remote.default-remote-dispatcher-9,akkaSource=akka://appka@127.0.0.1:25520/system/remoting-terminator,sourceActorSystem=appka,akkaTimestamp=10:00:57.373UTC}
[info] [2021-01-04 11:00:57,376] [INFO] [akka.remote.RemoteActorRefProvider$RemotingTerminator] [] [appka-akka.actor.default-dispatcher-3] - Remote daemon shut down; proceeding with flushing remote transports. MDC: {akkaAddress=akka://appka@127.0.0.1:25520,akkaTimestamp=10:00:57.375UTC}
[info] [2021-01-04 11:00:57,414] [INFO] [akka.remote.RemoteActorRefProvider$RemotingTerminator] [] [appka-akka.actor.default-dispatcher-3] - Remoting shut down. MDC: {akkaAddress=akka://appka@127.0.0.1:25520,akkaTimestamp=10:00:57.414UTC}
[error] Nonzero exit code returned from runner: 255
[error] (Compile / run) Nonzero exit code returned from runner: 255
[error] Total time: 6 s,completed Jan 4,2021 11:00:57 AM

解决方法

由于您尝试使用 sbt run，因此您收到联系点错误。 sbt run 将在 minikube 之外运行单个实例，这不是您想要的。而且由于它在 Minikube 之外运行，因此不会获取容器规范中设置的环境变量。脚本执行构建/部署，您不需要手动运行 sbt。

此外，主要错误不是与 8558 的连接，我不认为该配置会将该管理端口暴露在 minikube 之外。

所有三个容器都报告运行状态这一事实表明您实际上可能有一个正在运行的集群，而测试脚本可能只是缺少日志中的消息。正如其他人在评论中所说，来自其中一个容器的日志将有助于确定您是否有一个工作集群，并诊断集群形成中的任何问题。

对我的问题的回答和评论是正确的。我不需要运行 sbt run 来可视化网络浏览器中的输出。我缺少的是将集群节点的当前端口 port-forward 到输出端口。这在 akka-sample-cluster-kubernetes-scala 上没有指定，但我相信这是因为它们直接在 Google Kubernetes Engine 平台上运行，而不是首先在 minikube 中运行。

$ kubectl get pods -A
NAMESPACE     NAME                                        READY   STATUS      RESTARTS   AGE
appka-1       appka-8b88f7bdd-97zfl                       1/1     Running     0          9m10s
appka-1       appka-8b88f7bdd-bhv44                       1/1     Running     0          9m10s
appka-1       appka-8b88f7bdd-ff76s                       1/1     Running     0          9m10s
$ #### THIS COMMAND IS NOT IN THE README FILE OF THE DEMO ####
$ kubectl port-forward appka-8b88f7bdd-ff76s 8080
Forwarding from 127.0.0.1:8080 -> 8080
Forwarding from [::1]:8080 -> 8080

现在我可以看到输出了：

$ http GET http://127.0.0.1:8080/
HTTP/1.1 200 OK
Content-Length: 11
Content-Type: text/plain; charset=UTF-8
Date: Wed,06 Jan 2021 10:59:40 GMT
Server: akka-http/10.2.1

Hello world

akka akka akka-cluster kubernetes minikube scala scala

如何在 Scala 和 minikube 中使用 Akka 示例集群 kubernetes？

问题描述

解决方法

相关问答