sockets - 停止 Akka HTTP 服务器

Question

拥有一个简单的 Akka HTTP 服务器：

package org.package.some

import akka.actor.{IOManager, IO, Actor}
import java.net.InetSocketAddress

class HttpServerActor extends Actor {    
  val state = IO.IterateeRef.Map.async[IO.Handle]()(context.dispatcher)

  override def preStart() {
    IOManager(context.system) listen new InetSocketAddress(8000)
  }

  def receive = {
    case IO.NewClient(server) =>
      val socket = server.accept()
      state(socket) flatMap (_ => RequestProcessor.processRequest(socket))

    case IO.Read(socket, bytes) =>
      state(socket)(IO Chunk bytes)

    case IO.Closed(socket, cause) =>
      state(socket)(IO EOF None)
      state -= socket

    case "STOP" => 
      println("WHAT'S HERE??")
  }
}

如何停止服务器，即关闭端口 8000 上的服务器套接字？

仅仅杀死演员没有任何效果：仍然有netstat -a | grep 8000一句话说端口仍在被监听。

Answer 1

IOManager.listen返回 a ServerHandle，它有一个close方法。

class HttpServerActor extends Actor {
  val state = IO.IterateeRef.Map.async[IO.Handle]()(context.dispatcher)
  var handle: ServerHandle = _

  override def preStart() {
    handle = IOManager(context.system) listen new InetSocketAddress(8000)
  }

  def receive = {
    // ...
    case "STOP" => 
      handle.close()
  }
}