Я могу создать актеров с 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!
для второго вызова. Наверное, я использую неправильный шаблон здесь. Может кто-то помочь, как достичь этого? Мне нужно
- Создание участников по требованию
- Поиск действующих лиц по id, а если нет, создайте их
- Способность уничтожать, так как я не знаю, понадобится ли она снова.
Должен ли я использовать Диспетчер или Маршрутизатор для этого?
Решение В качестве предлагаемого я использую конкретный Супервайзер, который содержит доступных участников на карте. Его можно попросить предоставить одного из его детей.
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 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]
}
...
}