Akka是由各种角色和功能的Actor组成的,工作的主要原理是把一项大的计算任务分割成小环节,再按各环节的要求构建相应功能的Actor,然后把各环节的运算托付给相应的Actor去独立完成。Akka是个工具库(Tools-Library),不是一个软件架构(Software-Framework),我们不需要按照Akka的框架格式去编写程序,而是直接按需要构建Actor去异步运算一项完整的功能,这样让用户在不知不觉中自然的实现了多线程并发软件编程(concurrent programming)。按这样的描述,Actor就是一种靠消息驱动(Message-driven)的运算器,我们可以直接调用它来运算一段程序。消息驱动模式的好处是可以实现高度的松散耦合(loosely-coupling),因为系统部件之间不用软件接口,而是通过消息来进行系统集成的。消息驱动模式支持了每个Actor的独立运算环境,又可以在运行时按需要灵活的对系统Actor进行增减,伸缩自如,甚至可以在运行时(runtime)对系统部署进行调配。Akka的这些鲜明的特点都是通过消息驱动来实现的。

曾经看到一个关于Actor模式的观点:认为Actor并不适合并发(concurrency)编程,更应该是维护内部状态的运算工具。听起来好像很无知,毕竟Actor模式本身就是并发模式,如果不适合并发编程,岂不与Akka的发明意愿相左。再仔细研究了一下这个观点的论述后就完全认同了这种看法。在这里我们分析一下这种论述,先看看下面这段Actor用法伪代码:

移动开发培训,Android培训,安卓培训,手机开发培训,手机维修培训,手机软件培训

 class QueryActor extends Actor {    override def receive: Receive = {      case GetResult(query) => 
        val x = db.RunQuery(query)
        val y = getValue(x)
        sender() ! computeResult(x,y)
    }
  }
  val result: Future[Any] = QueryActor ? GetResult(...)

网友评论