从akka actor调用REST API（或者更一般地，从actor启动长时间运行的任务）

Question

来自akka新手的问题：假设在某个时候，我的一个参与者希望针对外部REST API发出HTTP请求。做这件事最好的方法是什么？（注意：对于希望在RDBMS中存储数据的参与者，我会问同样的问题）。

奥利维耶

Answer 1

这个问题现在已经很老了，但正如sourcedelica提到的，您的目标之一可能是编写不阻塞线程的反应代码。Spray的人最出名的是他们的异步HTTP服务器和令人敬畏的路由DSL（您可以使用它创建自己的API)，但他们也提供了一个Spray-client包，允许您的应用程序访问其他服务器。它基于未来，因此允许你在没有阻塞的情况下完成事情。菲利普·安德森写了一个说明性的例子；这里有几行可以给你这样的想法：

val pipeline: HttpRequest => Future[HttpResponse] = sendReceive

// create a function to send a GET request and receive a string response
def get(url: String): Future[String] = {
  val futureResponse = pipeline(Get(url))
  futureResponse.map(_.entity.asString)
}

如果您熟悉期货，您就知道如何在不阻塞的情况下进一步操作期货（就像map调用一样）。Spray的客户机库使用与服务器端相同的底层数据结构和概念，如果您要在一个应用程序中同时使用这两种结构和概念，这将非常方便。