如何在Akka中监督actors和处理异常

import akka.actor.{Actor, ActorSystem, Props, OneForOneStrategy}
import akka.actor.SupervisorStrategy._
import scala.concurrent.duration._

class ChildActor extends Actor {
  def receive: Receive = {
    case "fail" => throw new Exception("Simulating failure")
    case msg => println(s"Received message: $msg")
  }
  
  override def preRestart(reason: Throwable, message: Option[Any]): Unit = {
    println(s"Restarting child actor due to: $reason")
    super.preRestart(reason, message)
  }
}

class ParentActor extends Actor {
  override val supervisorStrategy = OneForOneStrategy(maxNrOfRetries = 3, withinTimeRange = 1.minute) {
    case _: Exception => Restart
  }
  
  val childActor = context.actorOf(Props[ChildActor], "childActor")
  
  def receive: Receive = {
    case msg => childActor ! msg
  }
}

val system = ActorSystem("SupervisionExample")
val parentActor = system.actorOf(Props[ParentActor], "parentActor")

parentActor ! "Hello"
parentActor ! "fail"
parentActor ! "World"

Thread.sleep(1000)
system.terminate()