spray-can simple-http-server示例如何处理Bound消息？

Question

在spray-can HTTP服务器示例中,当我运行服务器时,我没有看到日志中显示任何"绑定"消息:

https://github.com/spray/spray/tree/master/examples/spray-can/simple-http-server/src/main

但是,如果我尝试创建自己的服务器,并忽略该Bound消息,我会让他们去死信:

$ sbt run
[info] Set current project to pingpong (in build file:/D:/Projects/pingpong/)
[info] Updating {file:/D:/Projects/pingpong/}pingpong...
[info] Resolving jline#jline;2.12.1 ...
[info] Done updating.
[info] Running drozdyuk.pingpong.Main
[INFO] [08/03/2015 20:05:47.246] [default-akka.actor.default-dispatcher-2] [akka
://default/user/IO-HTTP/listener-0] Bound to localhost/127.0.0.1:8081
[INFO] [08/03/2015 20:05:47.246] [default-akka.actor.default-dispatcher-2] [akka
://default/deadLetters] Message [akka.io.Tcp$Bound] from Actor[akka://default/us
er/IO-HTTP/listener-0#-892116855] to Actor[akka://default/deadLetters] was not d
elivered. [1] dead letters encountered. This logging can be turned off or adjust
ed with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letter
s-during-shutdown'.

我的问题主要是出于好奇,如何Bound在示例中处理消息？吞下它们或其他东西是某种日志记录吗？

我的代码Main.scala:

package drozdyuk.pingpong

import akka.actor.{ActorSystem, Props}
import akka.io.IO
import spray.can.Http

object Main extends App {
  implicit val system = ActorSystem()

  // the handler actor replies to incoming HttpRequests
  val handler = system.actorOf(Props[WebService], name = "handler")

  val PORT = 8081
  val DOMAIN = "localhost"
  IO(Http) ! Http.Bind(handler, interface = DOMAIN, port = PORT)
}

和我的WebService.scala:

package drozdyuk.pingpong

import akka.actor._
import spray.http.HttpMethods.{GET}
import spray.can.Http
import spray.http.{HttpRequest, HttpResponse, Uri}

class WebService extends Actor with ActorLogging {
    def receive = {
      // New connection - register self as handler
      case _: Http.Connected => sender ! Http.Register(self)

      case HttpRequest(GET, Uri.Path("/ping"), _, _, _) =>
        sender ! HttpResponse(entity = "pong")

      case HttpRequest(GET, Uri.Path("/pong"), _, _, _) =>
        sender ! HttpResponse(entity = "ping")


      case _: HttpRequest => sender ! HttpResponse(status = 404, entity = "Unknown resource!")


    }
}

Answer 1

你可以使用的另一个版本tell在Main:

IO(Http).tell(Http.Bind(handler, interface = DOMAIN, port = PORT), sender = handler)

然后Bound在WebService中处理消息:

class WebService extends Actor with ActorLogging {
    def receive = {
        case Http.Bound(address) =>
        //all other cases...
    }
}

在你的情况下,你正在使用

def !(message: Any)(implicit sender: ActorRef = Actor.noSender): Unit

并且在范围内没有隐式发送者,Main因此noSender将使用默认值.