Akka 基本的な使い方 (Scala)
[最終更新] (2019/06/03 00:40:10)
最近の投稿
注目の記事

概要

Akka 2.4.2 を用いたサンプルコード集です。動作には Java 8 以降が必要です。

Akka requires that you have Java 8 or later installed on your machine.

インストール方法は複数提供されています。その一部を記載します。

公式ドキュメント (2.4.2)

アクターの生成

アクター (スレッド) は生成されると無限ループに入ります。receive したメッセージを逐次処理します。アクター内でアクターを生成することもできます。スレッドセーフにするために、やり取りするメッセージは val で宣言した String, Int や Map などのイミュータブルなものにすべきです。

import akka.actor.ActorSystem
import akka.actor.Props
import akka.actor.Actor
import akka.event.Logging

class MyActor extends Actor {
  val log = Logging(context.system, this) // ロガー

  // アクター内でアクターを生成できます。
  val child = context.actorOf(Props(classOf[MyActor2], "myArg3", "myArg4"), name = "myChild")

  def receive = {
    case s: String => {
      log.info("received: %s" format s)
      child ! s
    }
    case _ => {
    }
  }
}

class MyActor2(arg1: String, arg2: String) extends Actor {
  val log = Logging(context.system, this)
  def receive = {
    case s: String => {
      log.info("args: %s, %s, received: %s" format (arg1, arg2, s))
    }
    case _ => {
    }
  }
}

object Main {
  def main(args: Array[String]): Unit = {

    // とても重い処理。アプリケーション内に一つだけ作るようにします。
    val system = ActorSystem("mySystem") // 名前はログなどに記載されます。

    // アクターの設定。イミュータブルにすることでスレッドセーフにします。
    val props1 = Props[MyActor]
    val props2 = Props(classOf[MyActor2], "myArg1", "myArg2") // 引数あり

    // アクターの生成。ActorRef が返ります。
    val actor1 = system.actorOf(props1, name = "myActor1") // 名前はログなどで使用されます。
    val actor2 = system.actorOf(props2, name = "myActor2") // 名前の重複はアクター間で許されません。

    while(true) {
      actor1 ! "hi actor1"
      actor2 ! "hi actor2"
      Thread.sleep(1000)
    }
  }
}

出力ログ

[INFO] [02/27/2016 22:32:42.277] [mySystem-akka.actor.default-dispatcher-3] [akka://mySystem/user/myActor2] args: myArg1, myArg2, received: hi actor2
[INFO] [02/27/2016 22:32:42.277] [mySystem-akka.actor.default-dispatcher-4] [akka://mySystem/user/myActor1] received: hi actor1
[INFO] [02/27/2016 22:32:42.278] [mySystem-akka.actor.default-dispatcher-5] [akka://mySystem/user/myActor1/myChild] args: myArg3, myArg4, received: hi actor1

アクターの停止

生成したアクターは stop で停止できます。システム全体を停止するためには terminate を使用します。system.shutdown は非推奨になりました。アクター内で生成したアクターの場合は watch で監視することで正常に停止した際に Terminated を receive して独自の処理を実行できます。

import akka.actor.ActorSystem
import akka.actor.Props
import akka.actor.Actor
import akka.actor.ActorRef
import akka.actor.Terminated
import akka.pattern.ask // '?' を使用するため
import akka.util.Timeout
import scala.concurrent.duration._ // "5 seconds" を利用するため
import scala.concurrent.Await
import scala.concurrent.Future
import scala.language.postfixOps

class MyActor extends Actor {

  // 子スレッドを生成して監視。障害時の停止は検知できません。正常終了を検知します。
  val child = context.actorOf(Props[MyActor2], name = "myChild")
  context.watch(child)

  // 依頼元
  var lastSender: ActorRef = context.system.deadLetters // 既定は `/dev/null` 相当の deadLetters

  def receive = {
    case "kill" => {
      context.stop(child) // 停止処理
      lastSender = sender // 返信先
    }
    case Terminated(`child`) => {
      // https://www.qoosky.io/techs/c7921ddb98 に記載したとおり
      // 変数へのバインドを回避する目的でバッククォートで囲んでいます。
      lastSender ! "finished"
    }
    case _ => {
      context.stop(self) // 自分を停止することもできます。
    }
  }
}

class MyActor2 extends Actor {
  def receive = {
    case _ => {
    }
  }
}

object Main {
  def main(args: Array[String]): Unit = {
    val system = ActorSystem("mySystem")

    // アクターを生成
    val props = Props[MyActor]
    val actor = system.actorOf(props, name = "myActor")
    Thread.sleep(1000)

    // (子スレッドの) 停止を要請
    implicit val timeout = Timeout(5 seconds) // '?' の暗黙の引数として必要な情報です。
    val future: Future[Any] = actor ? "kill"
    // val future: Future[String] = ask(actor, "kill").mapTo[String] // としても同じです。

    // 同期して待つ (非同期ではない。ここで処理が停止)
    val result = Await.result(future, timeout.duration).asInstanceOf[String]
    // val result = Await.result(future, timeout.duration) // ↑の後者の場合は String に変換済み。

    println(result)

    // アクターの停止
    system.stop(actor)
    Thread.sleep(1000)

    // システムの停止 (`system.shutdown` は非推奨になりました。)
    system.terminate
  }
}

出力結果

finished

アクター障害発生時の復旧

例外が発生してもアクターは自動で再起動します。再起動時に独自の処理をフックして入れ込むことができます。

import akka.actor.ActorSystem
import akka.actor.Props
import akka.actor.Actor
import akka.event.Logging

class MyActor extends Actor {
  val log = Logging(context.system, this)

  // preStart -> preRestart -> postRestart/preStart -> postStop
  // [---- Old Instance ----] [-------- New Instance --------]
  // [---- Old Child -------] [-------- New Child -----------]
  // <---------------- Same MailBox ------------------------->

  // New Instance のコンストラクト時にも実行されます。
  val child = context.actorOf(Props[MyActor2], name = "myChild")

  override def preStart: Unit = {
    log.info("preStart")
  }

  override def preRestart(reason: Throwable, message: Option[Any]): Unit = {
    // これを定義しない場合は `preStart` の処理が実行されます。
    // (その際 `context.stop(child)` は実行されます)
    log.info("preRestart")
    if (message.nonEmpty)
      log.info("last message was: %s" format message)
    context.stop(child) // stop しないと old child が残存し `myChild` で名前が重複するため例外が発生します。
  }

  override def postRestart(reason: Throwable): Unit = {
    log.info("postRestart")
  }

  override def postStop: Unit = {
    log.info("postStop")
  }

  def receive = {
    case "crash" => {
      throw new Exception
    }
    case s: String => {
      log.info(s)
      child ! s
    }
    case _ => {
    }
  }
}

class MyActor2 extends Actor {
  val log = Logging(context.system, this)

  override def preStart: Unit = {
    log.info("preStart")
  }

  override def postStop: Unit = {
    log.info("postStop")
  }

  def receive = {
    case s: String => {
      log.info(s)
    }
    case _ => {
    }
  }
}

object Main {
  def main(args: Array[String]): Unit = {
    val system = ActorSystem("mySystem")

    // アクターの生成
    val props = Props[MyActor]
    val actor = system.actorOf(props, name = "myActor")
    Thread.sleep(1000)

    // メッセージを送信
    actor ! "crash"

    while(true) {
      Thread.sleep(1000)
      actor ! "hi"
    }
  }
}

実行結果

[INFO] [02/28/2016 03:10:43.461] [mySystem-akka.actor.default-dispatcher-5] [akka://mySystem/user/myActor/myChild] preStart
[INFO] [02/28/2016 03:10:43.461] [mySystem-akka.actor.default-dispatcher-4] [akka://mySystem/user/myActor] preStart
[ERROR] [02/28/2016 03:10:44.473] [mySystem-akka.actor.default-dispatcher-3] [akka://mySystem/user/myActor] null
java.lang.Exception
    at myapp.MyActor$$anonfun$receive$1.applyOrElse(Main.scala:42)
    at akka.actor.Actor$class.aroundReceive(Actor.scala:480)
    at myapp.MyActor.aroundReceive(Main.scala:8)
    at akka.actor.ActorCell.receiveMessage(ActorCell.scala:526)
    at akka.actor.ActorCell.invoke(ActorCell.scala:495)
    at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
    at akka.dispatch.Mailbox.run(Mailbox.scala:224)
    at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
    at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
    at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
    at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
    at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)

[INFO] [02/28/2016 03:10:44.474] [mySystem-akka.actor.default-dispatcher-5] [akka://mySystem/user/myActor] preRestart
[INFO] [02/28/2016 03:10:44.474] [mySystem-akka.actor.default-dispatcher-5] [akka://mySystem/user/myActor] last message was: Some(crash)
[INFO] [02/28/2016 03:10:44.478] [mySystem-akka.actor.default-dispatcher-2] [akka://mySystem/user/myActor/myChild] postStop
[INFO] [02/28/2016 03:10:44.483] [mySystem-akka.actor.default-dispatcher-5] [akka://mySystem/user/myActor] postRestart
[INFO] [02/28/2016 03:10:44.483] [mySystem-akka.actor.default-dispatcher-5] [akka://mySystem/user/myActor/myChild] preStart
[INFO] [02/28/2016 03:10:45.467] [mySystem-akka.actor.default-dispatcher-6] [akka://mySystem/user/myActor] hi
[INFO] [02/28/2016 03:10:45.468] [mySystem-akka.actor.default-dispatcher-2] [akka://mySystem/user/myActor/myChild] hi
[INFO] [02/28/2016 03:10:46.472] [mySystem-akka.actor.default-dispatcher-5] [akka://mySystem/user/myActor] hi
[INFO] [02/28/2016 03:10:46.472] [mySystem-akka.actor.default-dispatcher-2] [akka://mySystem/user/myActor/myChild] hi

アクターの検索

actorSelection によって、アクターを検索できます。ただし、この方法は特殊な場合に有用なものであって、通常は ActorRef をコンストラクト時に渡したり、メッセージ内で ActorRef を受け渡しすることが推奨されます。

It is always preferable to communicate with other Actors using their ActorRef instead of relying upon ActorSelection. Exceptions are

sending messages using the At-Least-Once Delivery facility
initiating first contact with a remote system

In all other cases ActorRefs can be provided during Actor creation or initialization, passing them from parent to child or introducing Actors by sending their ActorRefs to other Actors within messages.

import akka.actor.{Actor, ActorIdentity, ActorRef, ActorSystem, Identify, Props}
import akka.event.Logging
import akka.pattern.ask
import akka.util.Timeout
import scala.concurrent.{Await, Future}
import scala.concurrent.duration._
import scala.language.postfixOps

class MyActor extends Actor {
  val log = Logging(context.system, this)

  val identifyId = 1 // 問い合わせ番号
  val child = context.actorOf(Props[MyActor2], name = "myChild")

  var lastSender = context.system.deadLetters

  def receive = {
    case "search" => {
      context.actorSelection("/user/myActor/myChild") ! Identify(identifyId) // 絶対パス

      // その他の指定方法
      // context.actorSelection("../myActor/myChild") ! Identify(identifyId) // 相対パス
      // context.actorSelection("myChild") ! Identify(identifyId) // 相対パス (`./myChild` の意味)
      // context.actorSelection("myChi*") ! Identify(identifyId) // ワイルドカード

      lastSender = sender
    }
    case ActorIdentity(`identifyId`, Some(ref)) => {
      log.info("found")
      lastSender ! ref // 検索結果を返す
    }
    case ActorIdentity(`identifyId`, None) => {
      log.info("not found")
    }
    case s: String => {
      log.info(s)
      child ! s
    }
    case _ => {
    }
  }
}

class MyActor2 extends Actor {
  val log = Logging(context.system, this)
  def receive = {
    case s: String => {
      log.info(s)
    }
    case _ => {
    }
  }
}

object Main {
  def main(args: Array[String]): Unit = {
    val system = ActorSystem("mySystem")
    implicit val timeout = Timeout(5 seconds)

    // アクターの生成
    val props = Props[MyActor]
    val actor = system.actorOf(props, name = "myActor")
    Thread.sleep(1000)

    // アクター内で別のアクターの検索を要請
    val future: Future[Any] = actor ? "search"
    val result = Await.result(future, timeout.duration).asInstanceOf[ActorRef]
    result ! "hi child"

    // アクター外で検索する場合
    val identifyId = 2
    val future2: Future[Any] = system.actorSelection("/user/myActor") ? Identify(identifyId)
    val result2 = Await.result(future2, timeout.duration)
    result2 match {
      case ActorIdentity(`identifyId`, Some(ref)) => {
        ref ! "hi"
      }
      case ActorIdentity(`identifyId`, None) => {
      }
      case _ => {
      }
    }

    while(true) {
      Thread.sleep(1000)
    }
  }
}

実行結果

[INFO] [02/28/2016 16:33:46.923] [mySystem-akka.actor.default-dispatcher-5] [akka://mySystem/user/myActor] found
[INFO] [02/28/2016 16:33:46.924] [mySystem-akka.actor.default-dispatcher-4] [akka://mySystem/user/myActor/myChild] hi child
[INFO] [02/28/2016 16:33:46.925] [mySystem-akka.actor.default-dispatcher-4] [akka://mySystem/user/myActor] hi
[INFO] [02/28/2016 16:33:46.925] [mySystem-akka.actor.default-dispatcher-4] [akka://mySystem/user/myActor/myChild] hi

ケースクラスをメッセージとして渡す

import akka.actor.ActorSystem
import akka.actor.Props
import akka.actor.Actor
import akka.event.Logging

case class MyCaseClass(prop1: Int, prop2: String)

class MyActor extends Actor {
  val log = Logging(context.system, this)

  def receive = {
    case MyCaseClass(prop1, prop2) => {
      log.info("prop1: %d, prop2: %s" format (prop1, prop2))
    }
    case _ => {
    }
  }
}

object Main {
  def main(args: Array[String]): Unit = {
    val system = ActorSystem("mySystem")

    // アクターの生成
    val props = Props[MyActor]
    val actor = system.actorOf(props, name = "myActor")

    // ケースクラスを渡す
    val msg = new MyCaseClass(123, "abc")

    while(true) {
      Thread.sleep(1000)
      actor ! msg
    }
  }
}

実行結果

[INFO] [02/28/2016 18:52:19.758] [mySystem-akka.actor.default-dispatcher-2] [akka://mySystem/user/myActor] prop1: 123, prop2: abc

アクターの状態遷移

import akka.actor.ActorSystem
import akka.actor.Props
import akka.actor.Actor
import akka.event.Logging

class MyActor extends Actor {
  val log = Logging(context.system, this)

  def angry: Receive = {
    case "be angry" => {
      log.info("already angry")
    }
    case "be happy" => {
      log.info("angry -> happy")
      context.become(happy)
    }
    case _ => {
      log.info("unbecome angry")
      context.unbecome
    }
  }

  def happy: Receive = {
    case "be angry" => {
      log.info("happy -> angry")
      context.become(angry)
    }
    case "be happy" => {
      log.info("already happy")
    }
    case _ => {
      log.info("unbecome happy")
      context.unbecome
    }
  }

  def receive = {
    case "be angry" => {
      log.info("become angry")
      context.become(angry)
    }
    case "be happy" => {
      log.info("become happy")
      context.become(happy)
    }
    case _ => {
    }
  }
}

object Main {
  def main(args: Array[String]): Unit = {
    val system = ActorSystem("mySystem")

    // アクターの生成
    val props = Props[MyActor]
    val actor = system.actorOf(props, name = "myActor")

    // 状態遷移
    actor ! "be angry"
    Thread.sleep(1000)

    actor ! "be happy"
    Thread.sleep(1000)

    actor ! "be happy"
    Thread.sleep(1000)

    actor ! "dummy"
    Thread.sleep(1000)

    // 終了
    system.terminate
  }
}

実行結果

[INFO] [02/28/2016 18:58:28.370] [mySystem-akka.actor.default-dispatcher-3] [akka://mySystem/user/myActor] become angry
[INFO] [02/28/2016 18:58:29.370] [mySystem-akka.actor.default-dispatcher-5] [akka://mySystem/user/myActor] angry -> happy
[INFO] [02/28/2016 18:58:30.371] [mySystem-akka.actor.default-dispatcher-5] [akka://mySystem/user/myActor] already happy
[INFO] [02/28/2016 18:58:31.374] [mySystem-akka.actor.default-dispatcher-3] [akka://mySystem/user/myActor] unbecome happy

他のアクターへのメッセージの転送

forward すると sender を維持しつつ他のアクターにメッセージを転送できます。以下の例で ! によっていつもどおり送信した場合は Actor[akka://mySystem/user/myActor#-1013060199] からのメッセージであることが分かります。一方、転送した場合はアクター外からのメッセージのため Actor[akka://mySystem/deadLetters] が sender となっています。

import akka.actor.ActorSystem
import akka.actor.Props
import akka.actor.Actor
import akka.event.Logging

class MyActor extends Actor {
  val log = Logging(context.system, this)

  val child = context.actorOf(Props[MyActor2], name = "myChild")

  def receive = {
    case s: String => {
      log.info(s)
      child.forward(s) // 転送
      child ! s // コピー送信
    }
    case _ => {
    }
  }
}

class MyActor2 extends Actor {
  val log = Logging(context.system, this)
  def receive = {
    case s: String => {
      log.info(s)
      log.info(sender.toString)
    }
    case _ => {
    }
  }
}

object Main {
  def main(args: Array[String]): Unit = {
    val system = ActorSystem("mySystem")

    // アクターの生成
    val props = Props[MyActor]
    val actor = system.actorOf(props, name = "myActor")

    // メッセージを送信
    actor ! "hi"
    Thread.sleep(1000)

    // 終了
    system.terminate
  }
}

実行結果

[INFO] [02/28/2016 19:05:33.851] [mySystem-akka.actor.default-dispatcher-4] [akka://mySystem/user/myActor] hi
[INFO] [02/28/2016 19:05:33.851] [mySystem-akka.actor.default-dispatcher-2] [akka://mySystem/user/myActor/myChild] hi
[INFO] [02/28/2016 19:05:33.851] [mySystem-akka.actor.default-dispatcher-2] [akka://mySystem/user/myActor/myChild] Actor[akka://mySystem/deadLetters]
[INFO] [02/28/2016 19:05:33.851] [mySystem-akka.actor.default-dispatcher-2] [akka://mySystem/user/myActor/myChild] hi
[INFO] [02/28/2016 19:05:33.851] [mySystem-akka.actor.default-dispatcher-2] [akka://mySystem/user/myActor/myChild] Actor[akka://mySystem/user/myActor#-1013060199]

子アクター内で発生した例外処理

アクターを生成したアクターは Supervisor とよばれ、子アクター内で発生した例外処理を行います。supervisorStrategy を override することで、既定の例外処理の設定を上書きできます。system.actorOf() を利用して生成したトップレベルのアクターは User Guardian Actor によって Supervise されるため、例外処理をカスタマイズするためには別の方法が必要です。

import akka.actor.ActorSystem
import akka.actor.Props
import akka.actor.Actor
import akka.event.Logging
import akka.actor.OneForOneStrategy // それぞれの子アクターが個別に例外処理される
// import akka.actor.AllForOneStrategy // ある子アクターで例外が発生すると、他のすべての子アクターにも同じ例外処理を適用
// ↑ひとつが壊れるとすべてダメになるケースで使用します。
import akka.actor.SupervisorStrategy._
import scala.concurrent.duration._
import scala.language.postfixOps

class MyActor extends Actor {
  val log = Logging(context.system, this)

  val child = context.actorOf(Props[MyActor2], name = "myChild")

  // ここで例外処理を設定。
  // ウィンドウサイズ 60 秒で 10 回を越えて Restart が発生すると、例外処理を行わずに Stop します。
  override val supervisorStrategy = OneForOneStrategy(maxNrOfRetries = 10, withinTimeRange = 1 minute) {
    case _: ArithmeticException => Resume // ゼロ除算など。握り潰して何もなかったことにする (Resume)
    case _: NullPointerException => Restart
    case _: IllegalArgumentException => Stop
    case _: Exception => Escalate // MyActor で発生した例外として扱う
  }

  def receive = {
    case s: String => {
      log.info(s)
      child ! s
    }
    case _ => {
    }
  }
}

class MyActor2 extends Actor {
  val log = Logging(context.system, this)

  override def preStart: Unit = {
    log.info("preStart")
  }

  override def preRestart(reason: Throwable, message: Option[Any]): Unit = {
    log.info("preRestart")
  }

  override def postRestart(reason: Throwable): Unit = {
    log.info("postRestart")
  }

  override def postStop: Unit = {
    log.info("postStop")
  }

  def receive = {
    case "let's throw ArithmeticException" => {
      throw new ArithmeticException
    }
    case "let's throw NullPointerException" => {
      throw new NullPointerException
    }
    case "let's throw IllegalArgumentException" => {
      throw new IllegalArgumentException
    }
    case "let's throw Exception" => {
      throw new Exception
    }
    case _ => {
    }
  }
}

object Main {
  def main(args: Array[String]): Unit = {
    val system = ActorSystem("mySystem")

    // アクターの生成
    val props = Props[MyActor]
    val actor = system.actorOf(props, name = "myActor")
    Thread.sleep(1000)

    actor ! "let's throw ArithmeticException"
    Thread.sleep(1000)
    actor ! "let's throw NullPointerException"
    Thread.sleep(1000)
    actor ! "let's throw IllegalArgumentException"
    Thread.sleep(1000)
    actor ! "let's throw Exception"
    Thread.sleep(1000)

    // 終了
    system.terminate
  }
}

実行結果

[INFO] [02/28/2016 21:36:08.122] [mySystem-akka.actor.default-dispatcher-5] [akka://mySystem/user/myActor/myChild] preStart
[INFO] [02/28/2016 21:36:09.121] [mySystem-akka.actor.default-dispatcher-3] [akka://mySystem/user/myActor] let's throw ArithmeticException ←Resume
[WARN] [02/28/2016 21:36:09.127] [mySystem-akka.actor.default-dispatcher-4] [akka://mySystem/user/myActor/myChild] null
[INFO] [02/28/2016 21:36:10.125] [mySystem-akka.actor.default-dispatcher-3] [akka://mySystem/user/myActor] let's throw NullPointerException ←Restart
[ERROR] [02/28/2016 21:36:10.127] [mySystem-akka.actor.default-dispatcher-2] [akka://mySystem/user/myActor/myChild] null
java.lang.NullPointerException
    at myapp.server.MyActor2$$anonfun$receive$2.applyOrElse(Main.scala:62)
    at akka.actor.Actor$class.aroundReceive(Actor.scala:480)
    at myapp.server.MyActor2.aroundReceive(Main.scala:38)
    at akka.actor.ActorCell.receiveMessage(ActorCell.scala:526)
    at akka.actor.ActorCell.invoke(ActorCell.scala:495)
    at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
    at akka.dispatch.Mailbox.run(Mailbox.scala:224)
    at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
    at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
    at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
    at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
    at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)

[INFO] [02/28/2016 21:36:10.128] [mySystem-akka.actor.default-dispatcher-2] [akka://mySystem/user/myActor/myChild] preRestart
[INFO] [02/28/2016 21:36:10.130] [mySystem-akka.actor.default-dispatcher-2] [akka://mySystem/user/myActor/myChild] postRestart
[INFO] [02/28/2016 21:36:11.129] [mySystem-akka.actor.default-dispatcher-5] [akka://mySystem/user/myActor] let's throw IllegalArgumentException ←Stop
[ERROR] [02/28/2016 21:36:11.130] [mySystem-akka.actor.default-dispatcher-5] [akka://mySystem/user/myActor/myChild] null
java.lang.IllegalArgumentException
    at myapp.server.MyActor2$$anonfun$receive$2.applyOrElse(Main.scala:65)
    at akka.actor.Actor$class.aroundReceive(Actor.scala:480)
    at myapp.server.MyActor2.aroundReceive(Main.scala:38)
    at akka.actor.ActorCell.receiveMessage(ActorCell.scala:526)
    at akka.actor.ActorCell.invoke(ActorCell.scala:495)
    at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
    at akka.dispatch.Mailbox.run(Mailbox.scala:224)
    at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
    at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
    at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
    at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
    at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)

[INFO] [02/28/2016 21:36:11.132] [mySystem-akka.actor.default-dispatcher-5] [akka://mySystem/user/myActor/myChild] postStop
[INFO] [02/28/2016 21:36:12.133] [mySystem-akka.actor.default-dispatcher-2] [akka://mySystem/user/myActor] let's throw Exception ←Stop された後のため `child ! s` としても dead letters 行き。
[INFO] [02/28/2016 21:36:12.135] [mySystem-akka.actor.default-dispatcher-4] [akka://mySystem/user/myActor/myChild] Message [java.lang.String] from Actor[akka://mySystem/user/myActor#-1824119388] to Actor[akka://mySystem/user/myActor/myChild#-563721550] was not delivered. [1] dead letters encountered. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.

Future の扱い方

この続きが気になる方は

Akka 基本的な使い方 (Scala)

残り文字数は全体の約 26 %
tybot
100 円
* プログラミング情報の有料公開およびご購入について
* ご購入済みの方はこちらからログイン
関連ページ
    Spring Boot における非同期処理
    概要 こちらのページで環境を構築した Spring Boot について、非同期処理の基本的な実装方法をまとめます。 関連する公式ドキュメント Creating Asynchronous Methods Scheduling Tasks Consuming a RESTful Web Service Task Execution and Scheduling
    Akka HTTP サンプルコード (Scala)
    概要 こちらに記載した Akka アクターを用いて実装された汎用 HTTP フレームワークです。Spray の後継です。コアモジュールである akka-http-core は 2016/2/17 に experimental が外れました。akka-http などのいくつかのサブモジュールは 2016/3/1 現在 experimental のままですが、基本的な機能に関しては大きな仕様変更はな
    Akka HTTP Scala アプリケーションのデーモン化
    概要 こちらで基本的な使用方法をまとめた Akka HTTP Scala アプリケーションをデーモン化します。 参考サイト Apache Commons Daemonを使ってJavaのデーモンプログラムを作る Start and stop a Scala application in production
    Go 言語の基本的な使い方
    概要 Go 言語に関する基本的な事項を記載します。 モジュール、パッケージ、ライブラリ、アプリケーション 一つ以上の関数をまとめたものをパッケージとして利用します。更に一つ以上のパッケージをまとめたものをモジュールとして利用します。モジュールにはライブラリとして機能するものと、アプリケーションとして機能するものがあります。