Scala Akka HTTP客户端连接无法复用问题排查

嘿，我一眼就发现问题所在了——你当前的实现完全没用到Akka HTTP的连接池机制，而是每次请求都创建全新的TCP连接，这自然谈不上复用了。

具体问题分析 #

你的dispatch方法里调用的http.outgoingConnection是Akka HTTP提供的单次连接创建API：每次调用这个方法，都会建立一个新的TCP连接来处理当前请求，请求完成后连接就会被关闭。不管你调用多少次，它都不会复用之前的连接，这直接导致了你的测试里6次请求产生6个新连接。

而你想要的连接复用，需要依赖Akka HTTP内置的连接池实现，对应的API是http.singleRequest（底层基于连接池）或者cachedHostConnectionPool这类专门的连接池API。

修复方案 #

我们需要把dispatch方法改成使用连接池API，同时正确配置本地绑定地址。下面是修改后的客户端实现：

class AkkaConPoolingHttpClient(
  override val timeout: Option[FiniteDuration] = None,
  val localBinding: Option[InetSocketAddress] = None,
  val userAgentHeader: Option[String] = None)(
  implicit val config: HttpClient.Config,
  val system: ActorSystem,
  val materializer: Materializer) extends AkkaHttpClient {
  protected val http = Http()
  
  // 基于本地绑定地址配置连接设置
  private val connectionSettings = localBinding match {
    case Some(addr) => ClientConnectionSettings(system)
      .withLocalAddress(addr)
      .withSocketOptions(_.withReuseAddress(true))
    case None => ClientConnectionSettings(system)
  }
  
  // 自定义连接池设置（可选，可调整最大连接数等参数）
  private val poolSettings = ConnectionPoolSettings(system)
    .withConnectionSettings(connectionSettings)

  override def dispatch(request: HttpRequest): Future[HttpResponse] = {
    val preparedRequest = userAgentHeader match {
      case Some(userAgent) => fixUri(request.withHeaders(request.headers :+ headers.`User-Agent`(userAgent)))
      case None => fixUri(request)
    }
    // 使用singleRequest，底层自动复用连接池
    http.singleRequest(preparedRequest, settings = poolSettings)
  }
}

object AkkaConPoolingHttpClient {
  private def fixUri(request: HttpRequest): HttpRequest = request.withUri(request.uri.toRelative)
}

关键修改点说明 #

1. 替换连接创建方式：用http.singleRequest替代outgoingConnection，singleRequest内部会自动管理连接池，负责连接的复用、创建和销毁。
2. 正确配置本地绑定：把本地绑定地址配置到ClientConnectionSettings中，而不是每次请求都传参——连接池会基于统一的设置来创建连接，保证复用的连接都使用指定的本地地址。
3. 可选的连接池调优：通过ConnectionPoolSettings可以调整连接池的最大连接数、空闲超时等参数，进一步优化连接复用策略。

测试验证 #

修改后再运行你的测试代码，你会发现连接数会控制在连接池的最大限制内（默认是每个主机4个连接），完全符合你的预期。

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