akka http:服务器绑定行为不正常

问题描述 投票:0回答:1

我有以下代码:

val serverSource = Http().bind("localhost", 8080)
val connectionSink = Sink.foreach[IncomingConnection] {
    connection => println(s"Accepted incoming connection from ${connection.remoteAddress}")
  }
val serverBindingFuture = serverSource.to(connectionSink).run()
serverBindingFuture.onComplete {
    case Success(binding) => {
      println("Server binding successful")
      binding.terminate(10 seconds)
    }
    case Failure(ex) => println(s"Server binding failed $ex")
}

如摘要所示,我将在10秒钟后终止服务器绑定。因此,我希望如果在此期限到期之前发送请求,我应该得到消息“接受的来自...的传入连接”。

但是我发现我总是收到'无法访问此站点'的消息,并且从不打印消息。

akka-http
1个回答
0
投票

如摘要所示,我将在10秒钟后终止服务器绑定。因此,我希望如果在此期限到期之前发送请求,我应该得到消息“接受的来自...的传入连接”。

© www.soinside.com 2019 - 2024. All rights reserved.