我正在尝试使用 Akka 为自定义应用程序协议实现 TCP 服务器。我正在尝试按照此处给出的示例:http ://doc.akka.io/docs/akka/2.0/scala/io.html在 for...yield 循环中执行非阻塞 IO。
我发现当我从 yield 块内部抛出异常时,我无法从块外部捕获它。我想我对 Akka 或 Scala 在这里的工作方式有一个根本的误解,我会很感激任何提示。
我将代码归结为:
import akka.actor._
import java.net.InetSocketAddress
class EchoServer(port: Int) extends Actor {
val state = IO.IterateeRef.Map.async[IO.Handle]()(context.dispatcher)
override def preStart {
IOManager(context.system) listen new InetSocketAddress(port)
}
def receive = {
case IO.NewClient(server) =>
val socket = server.accept()
state(socket) flatMap (_ => EchoServer.processRequest(socket))
case IO.Read(socket, bytes) =>
state(socket)(IO.Chunk(bytes))
case IO.Closed(socket, cause) =>
state(socket)(IO.EOF(None))
state -= socket
}
}
object EchoServer extends App
{
def processRequest(socket: IO.SocketHandle): IO.Iteratee[Unit] =
{
println( "In process request")
try {
for {
bs <- IO take 1
} yield {
println("I'll get here")
throw new Exception("Hey-o!")
println("But not here ... as expected")
}
} catch {
case e: Exception => println("And not here ... wtf?"); IO.Done() // NEVER GETS HERE
}
}
ActorSystem().actorOf(Props(new EchoServer(8080)))
}
在这里遵循要点可能更方便:https ://gist.github.com/2296554
谁能解释为什么在这种情况下控制无法到达我的 catch 块?
我注意到,如果我在 Akka 中打开调试日志记录,我会在输出中看到这条消息:
[DEBUG] [04/03/2012 22:42:25.106] [EchoServerActorSystem-akka.actor.default-dispatcher-1] [Future] Hey-o!
所以我猜异常是由 Akka 调度程序处理的?谁能解释这怎么可能?