kubernetes内部使用Scala Akka的服务发现

Question

我面临着使用Akka进行服务发现的问题。我最近将我的应用程序从Kubernetes版本1.18迁移到1.21。服务发现在较旧版本上工作正常，但似乎在1.21版上不起作用。以下是错误日志： -

 play.api.UnexpectedException: Unexpected exception[IllegalStateException: Service ${serviceName} was not found by service locator]                                         
     at play.api.http.HttpErrorHandlerExceptions$.throwableToUsefulException(HttpErrorHandler.scala:358)                                                                 
     at play.api.http.DefaultHttpErrorHandler.onServerError(HttpErrorHandler.scala:264)                                                                                  
     at play.core.server.AkkaHttpServer$$anonfun$2.applyOrElse(AkkaHttpServer.scala:430)                                                                                 
     at play.core.server.AkkaHttpServer$$anonfun$2.applyOrElse(AkkaHttpServer.scala:422)                                                                                 
     at scala.concurrent.impl.Promise$Transformation.run(Promise.scala:454)                                                                                              
     at akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:63)                                                                             
     at akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:100)                                                                         
     at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.scala:18)                                                                                          
     at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:94)                                                                                           
     at akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:100)              

配置文件看起来像： -

akka.management {
  cluster.bootstrap {
    contact-point-discovery {
      discovery-method = kubernetes-api
      service-name = ${serviceName}
      required-contact-point-nr = ${REQUIRED_CONTACT_POINT_NR}
    }
  }

Answer 1

首先，确保您的如有记录。到目前为止，这是最常见的错误：不给予发现机制适当的权限。

其次，尝试手动指定 POD-LABEL-SELECTOR 而不是指定服务名称。这就是我最近所做的事情，也是文档中的默认值。因此，也许您处于无权查询无头服务的情况下，但是您可以直接通过POD-Label-Selector查询POD。

从根本上说，它在做什么是微不足道的。它正在针对K8S API运行一个非常简单的查询（并且可以手动指定），并获得了POD IP的列表。 （然后，它进入了Akka群集机制，在其中它可以做更复杂的事情来建立和修改群集，但是此查询非常简单。）因此，从根本上讲，唯一可能是错误的事情是：

• 查询是错误的。 （要么您的查询不存在，要么查询中有错字或暗示查询。）
• 查询的权限是错误的，因此您的ServiceAccount可以执行查询。