使用 scala akka spray 对 http 服务器进行非常基本的测试时出错

Question

我做了一个非常基本的喷雾罐测试：

• Akka 2.10 2.24
• Scala 2.10.3
• 喷雾罐 1.3.1
• sbt 0.13
• IntelliJ 13

这是我的代码：

val myListener: ActorRef = system.actorOf(Props[TestHttpListener], "httpListener")
IO(Http) ! Http.Bind(myListener, interface = "localhost", port = 8080)

httpListener 以 Http.Register(self) 响应 Http.Connected。

我使用 sbt 来运行我的代码。它以AbstractMethodError 失败：

[ERROR] [07/12/2014 18:46:48.364] [default-akka.actor.default-dispatcher-5] [ActorSystem(default)] Uncaught error from thread [default-akka.actor.default-dispatcher-5] shutting down JVM since 'akka.jvm-exit-on-fatal-error' is enabled
java.lang.AbstractMethodError: spray.can.HttpManager.akka$actor$ActorLogging$_setter_$log_$eq(Lakka/event/LoggingAdapter;)V
        at akka.actor.ActorLogging$class.$init$(Actor.scala:335)
        at spray.can.HttpManager.<init>(HttpManager.scala:29)
        at spray.can.HttpExt$$anonfun$1.apply(Http.scala:153)
        at spray.can.HttpExt$$anonfun$1.apply(Http.scala:153)
        at akka.actor.TypedCreatorFunctionConsumer.produce(Props.scala:422)
        at akka.actor.Props.newActor(Props.scala:331)
        at akka.actor.ActorCell.newActor(ActorCell.scala:534)
        at akka.actor.ActorCell.create(ActorCell.scala:560)
        at akka.actor.dungeon.FaultHandling$class.finishCreate(FaultHandling.scala:135)
        at akka.actor.dungeon.FaultHandling$class.faultCreate(FaultHandling.scala:129)
        at akka.actor.ActorCell.faultCreate(ActorCell.scala:338)
        at akka.actor.dungeon.FaultHandling$class.faultRecreate(FaultHandling.scala:58)
        at akka.actor.ActorCell.faultRecreate(ActorCell.scala:338)
        at akka.actor.ActorCell.invokeAll$1(ActorCell.scala:428)
        at akka.actor.ActorCell.systemInvoke(ActorCell.scala:447)
        at akka.dispatch.Mailbox.processAllSystemMessages(Mailbox.scala:262)
        at akka.dispatch.Mailbox.run(Mailbox.scala:218)
        at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:385)
        at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
        at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
        at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
        at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)

Answer 1

在 Scala 世界中，谨慎对待版本非常重要，因为一切都在快速发展，并且无法保证主要版本之间的向后兼容性。

Spray 取决于 Akka，this page 包含有关支持组合的信息。

spray 1.3.1 是针对 Scala 2.10.3 和 Akka 2.3.0 以及 Scala 2.11.1 和 Akka 2.3.2 构建的。

因此，如果您使用 Scala 2.10.3，则 Akka 的正确版本至少应为 2.3.0。

此外，我认为您从this 页面关注的示例不是很好。

首先，它忽略了这样一个事实，即使用IO(Http) ! Http.Bind(...) 初始化事物的代码必须在演员内部。收到Http.Bind 的演员尝试回复Http.Bound，由于来电者不是演员，您会收到死信。

所以，我建议这样做：

class MyApp extends Actor {

  implicit val system = context.system

  override def receive: Receive = {
    case "start" =>
      val myListener: ActorRef = system.actorOf(Props[TestHttpListener], "httpListener")
      IO(Http) ! Http.Bind(myListener, interface = "localhost", port = 8080)
  }
}

然后从你的应用程序的main() 方法中你需要做：

val myApp: ActorRef = system.actorOf(Props[MyApp], "myApp")
myApp ! "start"

从示例中不太容易理解的另一件事是，在您的侦听器 Actor 中，您不仅需要处理消息，还需要在每个连接上注册自己：

class TestHttpListener extends Actor {
  def receive = {
    case HttpRequest(HttpMethods.GET, Uri.Path("/ping"), _, _, _) =>
      sender() ! HttpResponse(entity = "PONG")

    case c : Tcp.Connected =>
      sender() ! Http.Register(self)
  }
}