AKKA 2.3.6 Scala 文档

微内核

注:本节未经校验,如有问题欢迎提issue

Akka微内核的目的是提供一个捆绑机制,以便将 Akka 应用程序作为一个单一有效载荷分发,而不需要在 Java 应用程序服务器中运行,或手动创建一个启动脚本。

Akka 微内核包含在Akka下载中.

要通过微内核运行应用,你需要创建一个 Bootable 类来处理应用的启动和关闭。下面例子中有介绍。

将你的应用jar包放在 deploy 目录下,并把依赖放入lib目录下以便自动装载并放在类路径中。

要启动内核使用 bin 目录下的脚本, 将应用启动类传进来.

以下是akka下载包中的一个应用与微内核一起运行的例子. 它可以用以下的命令运行 (在unix系统上): 启动脚本添加 config 目录作为类路径第一个元素,其次是lib/*。它以akka.kernel.Main为主类运行 java 并提供引导类作为参数。

(基于 unix 的系统)示例命令:

bin/akka sample.kernel.hello.HelloKernel

使用 Ctrl-C 来中断并退出微内核.

在Windows机器上你可以使用 bin/akka.bat 脚本.

以下是Hello Kernel 示例 (参考 HelloKernel创建一个Bootable 类):

package sample.kernel.hello

import akka.actor.{ Actor, ActorSystem, Props }
import akka.kernel.Bootable

case object Start

class HelloActor extends Actor {
  val worldActor = context.actorOf(Props[WorldActor])

  def receive = {
    case Start => worldActor ! "Hello"
    case message: String =>
      println("Received message '%s'" format message)
  }
}

class WorldActor extends Actor {
  def receive = {
    case message: String => sender() ! (message.toUpperCase + " world!")
  }
}

class HelloKernel extends Bootable {
  val system = ActorSystem("hellokernel")

  def startup = {
    system.actorOf(Props[HelloActor]) ! Start
  }

  def shutdown = {
    system.shutdown()
  }
}