如何在Spray.routing中安全地同时处理路由请求？

Question

Spray HTTP服务器的示例使用似乎使服务器按顺序而不是并发地处理请求变得非常容易。这是正确的，因为示例显示了作为一次处理一个请求的执行元实现的路由对象（FacePalm？**)。这似乎是一个普遍的问题。

有没有一种方法使用Spray.Routing在到达路由之前分叉执行？

import akka.actor.ActorSystem
import spray.http.{MediaTypes, HttpEntity}
import spray.routing.SimpleRoutingApp
import scala.concurrent.Future

class MySimpleServer(val system: ActorSystem, val HOST: String, val PORT: Int) extends SimpleRoutingApp {

  implicit val _system: ActorSystem = system
  import _system.dispatcher

  def main(args: Array[String]): Unit = {
    startServer(interface = HOST, port = PORT) {
      get {
        path("work1") {
          complete {
            // Asynchronously process some work
            Future.apply {
              Thread.sleep(1000)
              HttpEntity(
                MediaTypes.`text/html`,
                "OK"
              )
            }
          }
        } ~
          path("work2") {
            complete {
              // Synchronously process some work and block all routing for this Actor.
              // Oh sh*t!
              Thread.sleep(1000)
              HttpEntity(
                MediaTypes.`text/html`,
                "OK"
              )
            }
          } 
      }
    }
  }
}

**由于路由通常是一个无状态的操作，所以让路由器和参与者看起来并没有什么好处，对吗？

对于我使用过的每一个其他webserver，几乎在接受TCP连接后立即对处理程序进程或线程的连接进行分叉控制（more Sensitionly(IMO)）。（我认为）这样可以最大限度地提高接收连接的速率，并最大限度地降低无意阻塞的风险--至少，完全避免了路由中的无意阻塞。

  detach() {
    get {...} ..
 }

 val responses = (0 until 10)
    .map { _ => (IO(Http) ? HttpRequest(GET, s"${TEST_BASE_URL}work1")).mapTo[HttpResponse] }
    .map { response => Await.result(response, 5 seconds) }

Answer 1

实际上，即使您的work2路由也有可能使HTTP执行器处于饥饿状态，因为future.apply中使用的executioncontext是system.dispatcher，即喷雾HttpServiceActor的上下文。我们可以为长期运行的期货提供一个不同的执行上下文，这样我们就不会冒着饿死Spray的风险。

不过，为了回答您的问题，有一个名为detach的指令，它将在某些ExecutionContext中运行路由的其余部分，从而可能将更多的资源留给传入的请求...但由于它是一个指令,分叉只在路由命中后发生。