akka实现的actor

1. import akka.actor.Actor
2. import akka.actor.Props
3. import akka.event.Logging
4.  
5. class MyActor extends Actor {
6. val log = Logging(context.system, this)
7. def receive = {
8. case "test" ⇒ log.info("received test")
9. case _ ⇒ log.info("received unknown message")
10. }
11. }

需要提供一个接受的所有消息的模式匹配规则，如果你希望处理未知的消息，你需要象上例一样提供一个缺省的case分支。否则会有一个 akka.actor.UnhandledMessage(message, sender, recipient) 被发布到 Actor系统（ActorSystem）‘的 事件流（EventStream）中。