为什么我的请求是由Spray-HTTP中的一个线程来处理的？

Question

我使用spray-can、spray-http 1.3.2和akka 2.3.6设置了一个http服务器。我的application.conf没有任何akka（或spray）条目。我的演员代码：

class TestActor extends HttpServiceActor with ActorLogging with PlayJsonSupport {
  val route = get { 
    path("clientapi"/"orders") { 
       complete {{
            log.info("handling request")
            System.err.println("sleeping "+Thread.currentThread().getName)
            Thread.sleep(1000)
            System.err.println("woke up "+Thread.currentThread().getName)
            Seq[Int]()
       }}
    }
  }

  override def receive: Receive = runRoute(route)
}

开始是这样的：

val restService = system.actorOf(Props(classOf[TestActor]), "rest-clientapi")

IO(Http) ! Http.Bind(restService, serviceHost, servicePort)

当我发送10个并发请求时，它们都被spray立即接受并转发给不同的dispatcher Actor（根据akka的日志配置，我已从applicaiton.conf中删除，以免影响结果），但所有这些请求都由同一个线程处理，该线程会Hibernate，并且只有在唤醒后才会接收下一个请求。

Answer 1

从您的代码中，我看到只有一个TestActor来处理所有请求，因为您只使用System.ActorOf创建了一个。您知道，actorof并不是每个请求都创建新的执行元--更重要的是，这里有val，所以它只有一个执行元。此执行元逐个依次处理请求，您的路由在此执行元内处理。dispatcher没有理由再拾取一些线程，而每次仅有的一个线程只由一个actor使用，因此日志中只有一个线程（但不保证）--我假设它是池中的第一个线程。

Fork-join executor在这里什么都不做，只是给出第一个且始终相同的自由线程，因为没有更多的参与者需要与当前线程并行的线程。因此，它每次只接收一个任务。即使是“工作窃取”--它也不起作用，除非您有一些被阻止（并标记为具有托管块）的线程可以从其中“窃取”资源。thread.sleep(1000)本身不会自动标记线程-您应该用scala.concurrent.blocking包围它以使用“工作窃取”。无论如何，它仍然只有一个线程，而您只有一个演员。

如果您需要有几个actor来处理请求--只需传递一些akka路由器actor（它与spray-router没有任何共同之处）：

val restService = context.actorOf(RoundRobinPool(5).props(Props[TestActor]), "router")