Akka 使用系列之一: 快速入门

  Actor 模型由 Carl Hewitt 于上世纪70年代早期提出，目的是为了解决分布式编程中一系列的编程问题。Actor 的要点包括：Actor 是一个个相互之间独立的实体; Actor 可以通过消息来通信，一个 Actor 收到其他Actor的信息后，可以根据需要作出各种相应反应；消息的类型可以是任意的，消息的内容也可以是任意的；当一个 Actor 收到多个消息时，它先建立一个消息队列，将接收到的消息就放入队列，每次从队列中取出一个消息体进行处理。

  Akka 是一个用 Scala 编写的库，用于简化编写容错的、高可伸缩性的 Actor 模型应用。Akka 使得开发人员可以更轻松地开发具有容错性、可扩展性和跨平台的并发程序，在工业界得到了广泛应用。

   下面我们将从一个学生老师例子出发，快速入门 Actor 模型。例子是从博客 [ rerun ](http://rerun.me/2014/09/11/introducing-actors-akka-notes-part-1/) 拿来的 (我就是看这个博客学习 Akka 的，强烈推荐英语好的同学看看)。这个例子有两个角色，一个是勤学好问的学生，一个是睿智的老师。每天早上，学生都会给老师发送一封邮件，向老师请教问题；而老师看到邮件之后，通过邮件给学生发送答案。在这个过程中，有几点需要注意：

  Akka 用于简化编写容错的、高可伸缩性的 Actor 模型应用，即我们很容易用 Akka 实现上述学生老师的 Actor 模型。我们先建立老师 Actor, 将老师 Actor 实现成一个服务（我是不是想歪了），代码如下所示。

class TeacherActor extends Actor {
  def receive = {
    case "1+1等于多少?"           => {
      val originalSender = sender;//
      sender ! "1+1等于2"
    }
    case "历史上规模最大的众筹行动是什么？" => {
      val originalSender = sender;//
      sender ! "历史上规模最大的众筹行动是 +1s"
    }
    case "腾讯第一网红是谁？"     => {
      val originalSender = sender;//
      sender ! "腾讯第一网红是\"我去\""
    }
    case _              => {
      val originalSender = sender;//
      sender ! "这个问题，老师也得查查书"
    }
  }
}

object TeacherServices extends App { 
  
  val config = ConfigFactory
              .parseResources("lietal.conf")
              .getConfig("RemoteServerSideActor")
  //读入配置
  val system = ActorSystem("TeacherService",  config)
  //使用配置，建立 Actor 模型系统 ActorSystem。
  //ActorSystem 是访问 Actor 模型系统的接口，类似于 Spark 的 SparkContext。

  system.actorOf(Props[TeacherActor], "teacherActor") 
  //创建TearcherActor，返回一个引用
  //teacherActor 是 Actor 的名，客户端需要用
}

class StudentActor extends Actor{
  val path = "akka.tcp://remote-system@127.0.0.1:4999/"
              +"user/teacherActor" 
  // 远程Actor的路径，通过该路径能够获取到远程Actor的一个引用
  val remoteServerRef = context.actorSelection(path) 
  // 获取到远程Actor的一个引用，通过该引用可以向远程Actor发送消息

  def receive = {
      case res:String => {
        println (res)
        //打印出从老师 Actor 获得的答案
      }
      case time:Long => {
        remoteServerRef ! "历史上规模最大的众筹行动是什么？";
      }
    }
}

object StudentSimulator extends App{
  val config = ConfigFactory
               .parseResources("lietal.conf")
               .getConfig("RemoteClientSideActor")
  //读入客户端配置
  val actorSystem = ActorSystem("StudentClient",  config);
  //使用配置，建立 ActorSystem
  val studentActor = actorSystem.actorOf(Props[StudentActor])
  //获得 StudentActor 的一个引用。
  //在程序中 Actor 不能直接被访问。
  //所有操作都必须通过 ActorRef 引用。
  
  while(true){
      studentActor ! 7.toLong    // 7 点起床。。
      Thread.sleep(5000) // 假装一天过去了
  }
}

RemoteServerSideActor {
  akka {
    actor {
      provider = "akka.remote.RemoteActorRefProvider"
    }
    remote {
      enabled-transports = ["akka.remote.netty.tcp"]
      netty.tcp {
        hostname = "127.0.0.1"
        port = 4999
      }
    }
  }
}

RemoteClientSideActor {
  akka {
    actor {
      provider = "akka.remote.RemoteActorRefProvider"
    }
    remote {
      enabled-transports = ["akka.remote.netty.tcp"]
      netty.tcp {
        hostname = "127.0.0.1"
        port = 5000
      }
    }
  }
}

  完整项目代码已经上传到 [Github](https://github.com/algorithmdog/AkkaUsageLearner) 上了，需要的同学自取。将完整项目打包之后，分别以 TearcherService 和 StudentClient 为主类运行程序，老师 Actor 和学生 Actor 之间的通信就运行起来了。下面是老师服务端运行的结果。

   一开始我只想实现一个单机版本的老师学生 Actor，实现之后发现不能体现 Akka 的特点，因此又实现一个网络版的老师学生 Actor。实现完网络版之后，稍微加深了对 Actor 之间消息传递的理解。完整项目代码已经上传到 [Github](https://github.com/algorithmdog/AkkaUsageLearner) 上啦。

   本文主要参考了 http://shiyanjun.cn/archives/1178.html 和 http://rerun.me/2014/09/11/introducing-actors-akka-notes-part-1/ 两篇博客。第一篇博客注重实战，代码比较完整；第二篇则深入浅出的解释了相关的概念原理。推荐大家阅读。