AKKA/Scala检测到关闭的TCP连接？

Question

我试图使用Akka和Scala编写一个TCP服务器，它将实例化参与者，并在客户端分别连接和断开连接时停止参与者。我有一个TCP绑定执行器，

 class Server extends Actor{
   import Tcp._
   import context.system

   IO(Tcp) ! Bind(self, new InetSocketAddress("localhost", 9595))

   def receive = {

     case Bound(localAddress) =>
       println("Server Bound")
       println(localAddress)

     case CommandFailed(_: Bind) => context stop self

     case Connected(remote, local)=>
       val handler = context.system.actorOf(Props[ConnHandler])
       val connection = sender()
       connection ! Register(handler)
   }
 }

上面实例化localhost:9595上的TCP侦听器，并将处理程序参与者注册到每个连接。

case received => {...}
case PeerClosed => {
    println("Stopping")
    //Other actor stopping, cleanup.
    context stop self
}

我没有在附近配置的非Windows机器上进行测试，因为我认为这与我在Windows上运行有关，因为在搜索之后，我发现了一个仍然打开的bug--https://github.com/akka/akka/issues/17122-它指的是在基于Windows的系统上错过了一些关闭事件。

我是否在代码中犯了一个愚蠢的错误，或者这是上面链接的bug的一部分？

虽然我可以在received（data）的情况下编写关闭连接的代码，但是，由于网络断开或其他原因导致的断开将使服务器处于不可恢复的状态，要求重新启动应用程序，因为它将使一个次要的共享参与者处于表示客户端仍然连接的状态，因此服务器将拒绝来自该用户的进一步连接。

编辑：

我已经通过添加一个看门狗计时器执行器来解决这个问题，该执行器具有在一定时间后触发的周期性操作。每当连接上发生事件时，ConnHandler执行器将重置看门狗计时器。虽然不理想，但它做了我想做的事情。

Answer 1

编辑12/9/2016：即使客户端意外断开连接，ConnHandler也会收到PeerClosed消息。