0

我正在尝试按照本文档使用 Lagom 框架创建 grpc 服务。这里的hello服务除了 grpc 服务外,还公开了 rest API。

现在,在 ApplicationLoader 中创建 lagom 服务器时,我们分配 grpc 服务 impl,additionalRouter如下所示:

abstract class HelloApplication(context: LagomApplicationContext)
  extends LagomApplication(context)
    with AhcWSComponents {

  // Bind the service that this server provides
  override lazy val lagomServer =
    serverFor[HelloService](wire[HelloServiceImpl])
    .additionalRouter(wire[HelloGrpcServiceImpl])

}

出于演示的目的,一切都很好,但我们可能不需要总是创建除 gRPC 端点之外的 REST 端点。在那种情况下,我将不需要HelloServiceHelloServiceImpl。问题是你将如何创建 lagom 服务器HelloGrpcServiceImpl?我无法找到任何文档或 API 本身能够实现这一目标的方法!

请建议。

4

1 回答 1

0

根据我作为对我的问题的评论提供的链接中的答案,解决方案如下所示:

trait PrimeGeneratorService extends Service {
  override def descriptor: Descriptor = named("prime-generator")
}

class PrimeGeneratorServiceImpl() extends PrimeGeneratorService

abstract class PrimeGeneratorApplication(context: LagomApplicationContext)
  extends LagomApplication(context) with AhcWSComponents {

  override lazy val lagomServer: LagomServer = {
    serverFor[PrimeGeneratorService](wire[PrimeGeneratorServiceImpl])
      .additionalRouter(wire[PrimeGeneratorGrpcServiceImpl])
  }

}

class PrimeGeneratorLoader extends LagomApplicationLoader {
  override def load(context: LagomApplicationContext): LagomApplication =
    new PrimeGeneratorApplication(context) {
      override def serviceLocator: ServiceLocator = NoServiceLocator
    }

  override def loadDevMode(context: LagomApplicationContext): LagomApplication =
    new PrimeGeneratorApplication(context) with LagomDevModeComponents

  override def describeService = Some(readDescriptor[PrimeGeneratorService])
}

在这里,我们必须分别创建虚拟服务特征和实现,即PrimeGeneratorServicePrimeGeneratorServiceImpl

不要忘记在加载器类中添加以下内容:

override def describeService = Some(readDescriptor[PrimeGeneratorService])
于 2021-07-18T18:01:46.010 回答