Java中使用akka手记一

什么是actor?

  • Actor模型在并发编程中是比较常见的一种模型。很多开发语言都提供了原生的Actor模型。例如erlang,scala等。
  • 它由Carl Hewitt于上世纪70年代早期提出，目的是为了解决分布式编程中一系列的编程问题。
  • Actor模型的本质已经被强调了无数遍：万物皆Actor。Actor之间只有发送消息这一种通信方式。
  • 一个Actor如何处理多个Actor的请求呢？它先建立一个消息队列，每次收到消息后，就放入队列，而它每次也从队列中取出消息体来处理。通常我们都使得这个过程是循环的。让Actor可以时刻处理发送来的消息。

什么是akka?

Akka是一个用Scala编写的库，用于简化编写容错的、高可伸缩性的Java和Scala的Actor模型应用。

  • 下面以在java项目中使用akka写代码为例子。

依赖

  • maven项目
  • java6 or 7
  • 添加akka相关的包
1
  2
  3
  4
  5
  6
  7
  8
  9
  10
  11
  12
  13
  14
  15
  16
  17
  18
  19
  20
  
<dependency>
              <groupId>com.typesafe.akka</groupId>
              <artifactId>akka-actor_2.10</artifactId>
              <version>2.3.1</version>
          </dependency>
          <dependency>
              <groupId>com.typesafe.akka</groupId>
              <artifactId>akka-remote_2.10</artifactId>
              <version>2.3.1</version>
          </dependency>
          <dependency>
              <groupId>com..protobuf</groupId>
              <artifactId>protobuf-java</artifactId>
              <version>2.5.0</version>
          </dependency>
          <dependency>
              <groupId>com.typesafe.akka</groupId>
              <artifactId>akka-testkit_2.10</artifactId>
              <version>2.3.1</version>
          </dependency>

依赖包解析

  • akka-actor 核心包，有这个包就可以写简单的代码了
  • akka-remote 远程包，有这个包，才能够跨进程和网络调用
  • protobuf-java 不解释了，之所有是要声明版本，是因为pb的版本太低会造成消息传递过程中序列化反序列化有问题
  • akka-testkit 测试集，有这个包，写test case方便

常见问题

  • Q:shutting down JVM since ‘akka.jvm-exit-on-fatal-error’ is enabled
  • A:所有出错的时候都会有这个提示，快速错误退出是一个常见的机制，让系统最快时间发现错误。
  • Q:java.lang.ClassNotFoundException: akka.remote.RemoteActorRefProvider
  • A:没有添加进来akka-remote的时候会这样
  • Q:class akka.remote.WireFormats$AkkaControlMessage overrides final method getUnknownFields.()Lcom//protobuf/UnknownFieldSet
  • A:这是pb版本太低导致的，声明到2.5.0或以上

例子

  • 这是typesafe的经典例子。
  • 所有actor的配置都在classpath中。
  • 此例启动了两个system（简称为worker与creator）：startRemoteWorkerSystem && startRemoteCreationSystem
  • worker使用calculator.conf，在2552端口侦听。
  • creator使用remotecreation.conf，定义了它的worker在远程的2552端口，路径在creationActor下，自己的端口为2554。

creator中的逻辑

  • creator启动后，调用了schedule，进行了一秒一次的随机调用乘法或除法。
  • 具体的计算，在creationActor这个actor中完成。
  • 而creationActor这个actor被定义到了远程2552端口的进程中执行。
1
  2
  3
  4
  5
  6
  7
  8
  
akka {
    actor {
      deployment {
        "/creationActor/*" {
          remote = "akka.tcp://CalculatorWorkerSystem@127.0.0.1:2552"
        }
      }
    }

运行中进程观察

  • run CreationApplication.java
  • 一个进程 启动了一个端口
  • 进程通过这个端口，产生随机算式，交给另一个进程（这里是同一个进程）。

代码


原创文章如转载，请注明：转载自五四陈科学院[http://www.54chen.com]

捐款订阅54chen
捐赠说明