Akka Http调用outgoingConnection无返回也不进入catch块卡死问题

问题根因 #

• 代码存在基础语法和逻辑错误：
  • Scala 中 Try 结构会自动捕获代码块内的非致命异常，返回 Success 或 Failure 实例，本身不会向外抛出异常，你在 Try 表达式后追加的 catch 块完全不会触发
  • httpConnection 的实际类型是 Try[Flow[HttpRequest, HttpResponse, Future[Http.OutgoingConnection]]]，你在模式匹配时直接匹配 Flow 和 Exception 类型，漏掉了 Success、Failure 的包装层，匹配失败时会抛出 MatchError，逻辑完全不符合预期
• 程序卡住的核心原因是 Akka HTTP 的流设计特性：
  • outgoingConnection 仅返回连接的定义蓝图，不会在定义阶段真实建立连接，连接建立、请求发送的逻辑都是在调用 runWith 启动流之后才会执行
  • 默认配置下 Akka HTTP 没有强制设置连接超时、请求响应超时，如果目标地址不可达、网络不通或服务端无响应，Sink.head 会无限等待响应结果，直接表现为程序卡住

修复方案 #

首先修正语法错误，补充超时和异步异常处理逻辑：

import scala.concurrent.duration._
import akka.stream.scaladsl.{Flow, Source, Sink}
import akka.http.scaladsl.Http
import akka.http.scaladsl.model.{HttpRequest, HttpResponse}
import scala.util.{Try, Success, Failure}

// 移除无效的catch块，Try本身会封装异常
lazy val httpConnection: Try[Flow[HttpRequest, HttpResponse, Future[Http.OutgoingConnection]]] = Try {
  logger("Logger statement")
  Http().outgoingConnection(host, port)
}

httpConnection match {
  // 正确匹配Success包装的Flow
  case Success(flow) => 
    Source.single(request)
      .via(flow)
      // 添加请求超时，5秒无响应就抛出超时异常
      .completionTimeout(5.seconds)
      .runWith(Sink.head)
      // 处理流运行阶段的异步异常
      .recover {
        case e: Exception => 
          logger(s"请求执行失败: ${e.getMessage}")
          throw e
      }
  // 匹配Try封装的定义阶段异常
  case Failure(e) => 
    logger(s"获取连接定义失败: ${e.getMessage}")
}

如果仍存在连接卡住问题，可以在 application.conf 中添加全局客户端超时配置：

akka.http.client {
  connecting-timeout = 3s
  idle-timeout = 5s
}

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