Scala-Unit7-Scala并发编程模型AKKA

//创建CallMe类继承Actor，它包含了对消息处理的业务逻辑
class CallMe extends Actor{
  //重写recevie方法，负责接收和处理消息
  override def receive: Receive = {
    case "Hunter is cool" => println("You are Right")
    case "Hunter is ugly" => println("You are wrong")
    case "stop" => {
      //关闭代理ActorRef
      context.stop(self)
      //关闭ActorSystem
      context.system.terminate()
    }
  }
}

object CallMe {
  //1.创建ActorSystem对象
  private val acFactory = ActorSystem("AcFactory")
  //2.调用ActorSystem对象的ActorOf方法，创建代理callRef
  private val callRef = acFactory.actorOf(Props[CallMe],"CallMe")

  def main(args: Array[String]): Unit = {
    //3.发送消息， ！代表发送的意思
    callRef ! "Hunter is cool"
    callRef ! "Hunter is ugly"
    callRef ! "stop"
  }
}

class BoyActor(val b:ActorRef) extends Actor{
  override def receive: Receive = {
    case "你好，mm" => {
      b ! "你好，mm"
    }
    case "你好，gg" => {
      println("你好，gg")
      b ! "我能约你吃饭么？"
    }
    case "叔叔，我们不约！" =>{
      println("叔叔，我们不约!")
      context.stop(self)
      context.system.terminate()
    }
  }
}

class GirlActor(val g:ActorRef) extends Actor{
  override def receive: Receive = {
    case "你好，mm" =>{
      println("你好，mm")
      g ! "你好，gg"
    }
    case "我能约你吃饭么？" =>{
      println("我能约你吃饭么？")
      g ! "叔叔，我们不约！"
    }
  }
}

object WeChat {
  private val weChat = ActorSystem("WeChat")
  private val boyRef: ActorRef = weChat.actorOf(Props(new BoyActor(girlRef)),"Boy")
  private val girlRef: ActorRef = weChat.actorOf(Props(new GirlActor(boyRef)),"Girl")

  def main(args: Array[String]): Unit = {
    boyRef ! "你好，mm"
  }
}