是否可以在 Actor 内部发出 Akka HTTP 核心客户端请求？

Question

下面是一个简单的参与者，它需要进行 HTTP 调用以从 API 接收数据。根据 Akka HTTP Core Request-Level Client-Side API 只有 ActorSystem 和 ActorMaterializer 是隐式需要的。

class MyActor extends Actor {

  import context.system
  implicit val materializer = ActorMaterializer()

  override def receive: Receive = {
    case _ => {
      val responseFuture: Future[HttpResponse] = Http().singleRequest(HttpRequest(uri = "http://akka.io"))
      responseFuture onComplete {
        case Success(res) => println(res)
        case Failure(t) => println("An error has occured: " + t.getMessage)
      }
    }
  }
}

但是，在尝试编译应用程序时，我收到以下错误消息：

Error:(18, 48) ambiguous implicit values: both value context in trait Actor of type => akka.actor.ActorContext and method system in trait ActorContext of type => akka.actor.ActorSystem match expected type akka.actor.ActorRefFactory
  implicit val materializer = ActorMaterializer()

Error:(18, 48) implicit ActorRefFactory required: if outside of an Actor you need an implicit ActorSystem, inside of an actor this should be the implicit ActorContext
  implicit val materializer = ActorMaterializer()

Error:(18, 48) not enough arguments for method apply: (implicit context: akka.actor.ActorRefFactory)akka.stream.ActorMaterializer in object ActorMaterializer. Unspecified value parameter context.
  implicit val materializer = ActorMaterializer()

Error:(22, 70) could not find implicit value for parameter fm: akka.stream.Materializer 
  val responseFuture: Future[HttpResponse] = Http().singleRequest(HttpRequest(uri = "http://akka.io"))

Error:(22, 70) not enough arguments for method singleRequest: (implicit fm: akka.stream.Materializer)scala.concurrent.Future[akka.http.scaladsl.model.HttpResponse]. Unspecified value parameter fm.
  val responseFuture: Future[HttpResponse] = Http().singleRequest(HttpRequest(uri = "http://akka.io"))

Error:(23, 22) Cannot find an implicit ExecutionContext. You might pass an (implicit ec: ExecutionContext) parameter to your method or import scala.concurrent.ExecutionContext.Implicits.global.
  responseFuture onComplete {

Error:(23, 22) not enough arguments for method onComplete: (implicit executor: scala.concurrent.ExecutionContext)Unit. Unspecified value parameter executor.
  responseFuture onComplete {

这是在 Akka Actor 中进行 HTTP 调用的正确方法吗？

编辑

包含 import ExecutionContext.Implicits.global 以修复最后两个 ExecutionContext 错误。

Answer 1

创建 ActorMaterializer 需要隐式 ActorRefFactory。 Actor 特征中定义的上下文属性扩展了 ActorRefFactory，并且它是隐式的。您显式导入的上下文系统属性是 ActorRefFactory 的另一个隐式候选者，因为 ActorSystem 扩展了 ActorRefFactory。

我的建议是删除导入并在需要的地方显式传递它。

class MyActor extends Actor {

  // Do not import context.system
  // import context.system
  implicit val materializer = ActorMaterializer()

  override def receive: Receive = {
    case _ => {
      // use context.system explicitly
      val responseFuture: Future[HttpResponse] = Http(context.system)
        .singleRequest(HttpRequest(uri = "http://akka.io"))
      responseFuture onComplete {
        case Success(res) => println(res)
        case Failure(t) => println("An error has occured: " + t.getMessage)
      }
    }
  }
}

是否可以在 Actor 内部发出 Akka HTTP 核心客户端请求？

Is it possible to make an Akka HTTP core client request inside an Actor?

scala

akka

akka-http