Есть ли способ отправить значения из актера в actorRef в ActorSystem - PullRequest
Новая
       12

Есть ли способ отправить значения из актера в actorRef в ActorSystem

0 голосов
/ 15 ноября 2018

У меня есть два актера, закодированные следующим образом. 

class Actor1 extends Actor {
    val r : ActorRef = actorOf (Props[Actor2], "master")

    def receive: Receive = {
        case class Mul (a,b) =>
            r ! CalcMul (a,b)

        case class MulReply (ans) =>
            println("Multiply result : " + ans)
            // want to send "ans" value to testObject..
    }
}

class Actor2 extends Actor {

    def receive: Receive = {
        case class CalcMul (a,b) =>
            sender ! MulReply (a*b)
    }
}

object testObject extends App {
    val a = ActorSystem("ActorSystem").actorOf(Props[Actor1], "root")

    a ! CalcMul (5, 15)
    // how to receive "ans" value here?
}

Я могу получить и распечатать результат в Actor1, но мне нужны эти значения в testObject, чтобы я мог использовать их для будущих операций.Не может быть метод receive в testObject, как это сделано для получения сообщения в Actor1 от Actor2, поэтому не может отправить их методом tell.

1 Ответ

0 голосов
/ 15 ноября 2018

Если вы хотите получить ответ от актера, вы можете использовать шаблон запроса для этой цели. 

import akka.actor.{Actor, ActorRef, ActorSystem, Props}
import akka.pattern._
import akka.util.Timeout

import scala.concurrent.ExecutionContext.Implicits.global
import scala.concurrent.Future
import scala.concurrent.duration.SECONDS


case class CalsMul(a: Int, b: Int)

  class Actor1 extends Actor {
    val r: ActorRef = context.actorOf(Props[Actor2], "master")

    def receive: Receive = {
      case req: CalsMul =>
        println("received message by Actor1")
        r forward req
    }
  }

  class Actor2 extends Actor {

    def receive: Receive = {
      case request: CalsMul =>
        println("received message by Actor2")
        Future.successful(request.a * request.b) pipeTo sender
    }
  }

  object testObject extends App {
    implicit val system: ActorSystem = ActorSystem("ActorSystem")
    val a: ActorRef = system.actorOf(Props[Actor1], "root")
    implicit val timeout: Timeout = Timeout(20, SECONDS)

    println(system, "sending message to Actor1")
    val ans: Future[Int] = (a ? CalsMul(5, 15)).mapTo[Int] // as you are returning the multiplication of a*b

    ans.foreach(println)
  }

Примечание: Операции с привязкой к ЦП не рекомендуется использовать с субъектами, это может отрицательно повлиять на производительность вашего приложения

...