Scala Akka gRPC客户端调用服务端成功却未收到返回结果如何解决？

问题原因及对应解决方法 #

核心原因梳理 #

你遇到的一元gRPC调用请求成功入库但无返回的问题，基本是以下4种常见原因导致：

1. 客户端侧没有正确处理Akka gRPC返回的异步Future
2. 服务端侧返回的Future缺少正确的执行上下文绑定，完成信号没有同步到gRPC网络栈
3. 客户端超时配置过短，响应返回前请求已被销毁
4. 服务端业务逻辑抛出异常被隐式吞掉，没有触发gRPC的响应回包逻辑

分步解决 #

• 优先检查客户端Future处理逻辑
  Akka gRPC自动生成的客户端方法返回值是Future[GeoPoint]类型，属于异步结果，直接赋值不会同步拿到返回值，必须通过回调或者阻塞等待（仅测试场景用）的方式获取结果，示例代码：

import scala.concurrent.Await
import scala.concurrent.duration._
import scala.util.{Success, Failure}

// 测试场景阻塞获取结果，生产环境禁止使用，会阻塞线程
val result = Await.result(savedGeoPoint, 10.seconds)

// 生产环境使用异步回调处理结果
savedGeoPoint.onComplete {
  case Success(point) => println(s"调用成功，返回结果：$point")
  case Failure(e) => println(s"调用失败，错误信息：$e")
}(client.executionContext)

• 修复服务端Future上下文绑定与异常捕获
  scalapb-runtime-grpc的服务方法返回的Future依赖正确的执行上下文传递完成信号，如果你的GeoRepository.save用了自定义的线程池，没有绑定到gRPC服务的执行上下文，或者业务逻辑抛出异常没有被捕获，就会出现无返回的问题，修改服务端代码如下：

// 导入gRPC服务对应的执行上下文，生产环境建议配置独立的dispatcher
import scala.concurrent.ExecutionContext.Implicits.global

override def createGeoPoint(geoPoint: GeoPoint): Future[GeoPoint] =
  GeoRepository.save(geoPoint)
    // 显式捕获异常，避免异常被吞导致无响应
    .recover {
      case e: Exception =>
        e.printStackTrace()
        throw e
    }

• 调整Akka gRPC客户端超时配置
  在客户端的application.conf中添加如下配置，避免默认超时时间过短导致响应未到达就被丢弃：

akka.grpc.client.GeoService {
  host = "127.0.0.1"
  port = 8080
  enable-tls = false
  deadline = 10s
}

• 校验版本兼容性
  确保两个微服务生成代码用的Protobuf大版本一致，scalapb-runtime-grpc和Akka gRPC的gRPC协议版本兼容，避免序列化/反序列化失败导致无响应。

内容的提问来源于stack exchange，提问作者Jelly