上下文改变阿克卡演员的行为

Question

我正在学习如何使用上下文。为了控制我的参与者的状态，我使用以下代码：

class MyActor extends Actor {

  override def receive: Receive = {
     println("Happens here")
     active(Set.empty)
   }

  def active(isInSet: Set[String]): Receive = {
    case Add(key) =>
      context.become(active(isInSet+key))
    case Contains(key) =>
      sender() ! isInSet(key)
    case ShowAll =>
      println(isInSet.toSeq)
  }

}

case class Add(key: String)
case class Contains(key: String)
object ShowAll


object DemoBecome extends App{

override def main(args: Array[String]): Unit = {

 val system = ActorSystem("BecomeUnbecome")
 val act = system.actorOf(Props(classOf[MyActor]), "demoActor")

 act ! Add("1")
 act ! ShowAll
 act ! Add("2")
 act ! ShowAll

 Thread.sleep(10000)
 System.exit(0)

}

当我发送第一条消息时，“接收”工作并打印消息，第二条消息不显示后，这是我的输出：

Happens here
Set()
Vector(1)
Set(1)
Vector(1, 2)

如果我改变接收方式，为此：

def receive = {
  case a: Add => println("happens here Add" )
  case c: Contains => println("happens here Contains")
  case ShowAll => println("happens here Show")
}

我收到以下输出：

happens here Add
happens here Show
happens here Add
happens here Show

所以我试着跟踪“接收”被“阻止”的时刻，但没有成功，我的疑问是：当我使用上下文时。在《我的演员》中，Akka如何以及何时处理第一次之后的信息？

Answer 1

当您使用context.become时，您正在更改演员中的行为。这意味着，当参与者使用默认的接收行为启动它时。但是，当它收到消息时，它会打印消息在这里发生，并使用部分函数active来处理它。

因为，在活动中您调用上下文。变为（活动（））参与者的行为会发生变化。从现在起，当消息被发送到参与者时，它将执行部分功能active，而不是receive方法，这就是为什么您不会看到在输出中多次发生。