Я могу создавать актеров с помощью actorOf и смотреть их с помощью actorFor. Теперь я хочу получить актера с помощью некоторого id:String, и если он не существует, я хочу, чтобы он был создан. Что-то вроде этого:
def getRCActor(id: String):ActorRef = {
Logger.info("getting actor %s".format(id))
var a = system.actorFor(id)
if(a.isTerminated){
Logger.info("actor is terminated, creating new one")
return system.actorOf(Props[RC], id:String)
}else{
return a
}
}
Но это не работает, так как isTerminated всегда верно, и я получаю исключение actor name 1 is not unique! для второго вызова. Я думаю, что я использую неправильный шаблон здесь. Может кто-нибудь помочь, как этого добиться? я нуждаюсь
- Создание актеров по запросу
- Поиск актеров по идентификатору и, если их нет, создать их
- Возможность уничтожить дальше, так как я не знаю, понадобится ли мне это снова
Должен ли я использовать Dispatcher или Router для этого?
Решение Как было предложено, я использую конкретный супервизор, который содержит доступных актеров на карте. Можно попросить предоставить одного из его детей.
class RCSupervisor extends Actor {
implicit val timeout = Timeout(1 second)
var as = Map.empty[String, ActorRef]
def getRCActor(id: String) = as get id getOrElse {
val c = context actorOf Props[RC]
as += id -> c
context watch c
Logger.info("created actor")
c
}
def receive = {
case Find(id) => {
sender ! getRCActor(id)
}
case Terminated(ref) => {
Logger.info("actor terminated")
as = as filterNot { case (_, v) => v == ref }
}
}
}
Его компаньон объект
object RCSupervisor {
// this is specific to Playframework (Play's default actor system)
var supervisor = Akka.system.actorOf(Props[RCSupervisor])
implicit val timeout = Timeout(1 second)
def findA(id: String): ActorRef = {
val f = (supervisor ? Find(id))
Await.result(f, timeout.duration).asInstanceOf[ActorRef]
}
...
}
