
# AkkaのActorをテストする（Java編）

AkkaのActorをテストした時のメモ。
メモなので間違ってたら指摘いただけるとありがたいです。

## 事前準備

### テストで使用するサンプルActor

```java
static class MyActor extends UntypedActor {
  public void onReceive(Object o) throws Exception {
    if (o.equals("say42")) {
      getSender().tell(42, getSelf());
    } else if (o instanceof Exception) {
      throw (Exception) o;
    }
  }
  public boolean testMe() { return true; }
}
```

## TIPS

### 適当なActorを作りたい

```java
@Test
public void testActor() {
    new JavaTestKit(system) {{
        final TestProbe worker = new TestProbe(system);
        ActorRef workerActorRef = worker.ref(); // ActorRefを取得できる
    }};
}
```

ActorRefを引数に取るメソッドや、ActorRefをメッセージとしてやり取りする時に使う

## Actorインスタンス内のメソッドをテストする

```java
@Test
public void demonstrateTestActorRef() {
  final Props props = Props.create(MyActor.class);
  final TestActorRef<MyActor> ref = TestActorRef.create(system, props, "testA");
  final MyActor actor = ref.underlyingActor(); // Actorインスタンスの取得
  assertTrue(actor.testMe());
}
```

通常ActorRefからはActorのインスタンスを取得することはできないが、
TestActorRefをつかうとActorのインスタンスを取得出来るようになる。
取得したインスタンスでメソッドを実行することで単体テストする

### メッセージ受信のテスト
```java
@Test
public void testActorRef() {
        new JavaTestKit(system) {{
            final TestProbe aggregator = new TestProbe(system);

            String message = "test message";
            aggregator.ref().tell(message, getRef());
            aggregator.expectMsg(message);
            assertEquals(getRef(), aggregator.lastSender());
        }};
}
```

TestProbeを使って適当なActorを作る。
ActorRefを取得してメッセージを送信して、expectMsgでメッセージが受信されたことのテストをする。
lastSender()でどこからメッセージが来たかもテスト出来る


## Actor停止挙動のテスト

```java
@Test
public void testActorRef() {
    new JavaTestKit(system) {{
      final Props props = Props.create(MyActor.class);
      final TestActorRef<MyActor> target = TestActorRef.create(system, props, "testA");

      final JavaTestKit probe = new JavaTestKit(system);
      probe.watch(target);
      target.tell(PoisonPill.getInstance(), ActorRef.noSender());
      final Terminated msg = probe.expectMsgClass(Terminated.class);
      assertEquals(msg.getActor(), target);
    }};
}
```

targetをJavaTestKitで監視しておいて、PoisonPillを送る。
そのあと、Terminatedメッセージを受信することを確認する
応用すれば、他のアクターを殺すようなReaperのテストでも使えそう。



## 参考
* http://doc.akka.io/docs/akka/2.4.0/java/testing.html#Built-In_Assertions
* http://qiita.com/reoring/items/3baeac37ba0d63f39693


AkkaのActorをテストする（Java編）


http://letitcrash.com/post/30165507578/shutdown-patterns-in-akka-2  
を読んでのメモ
☆が付いてるのは所感
それ以外は記事の適当に訳してまとめたもの

# Shutdown Patterns in Akka 2

「すべての処理が終了したらActorSystemをシャットダウンするにはAkkaにどう命令したらいい？」

以下を議論する

* 「適切なタイミング」でシャットダウンするための簡単な方法
* 同じことをやるためのそれほど簡単ではない方法

## What the Heck Does “Finished” Mean?

* まず “Finished” をどう定義するか
* 「メールボックスが空になった時」（正確に言えば間違ってるけど）
    - まだメッセージを送信してないアクターがいる可能性があるから
    - 図のようにメースボックスの中身を全部飲み込んで処理中のやつがいたりするしね
* 一気のみするアクターが数百発生する確率は低い
    - ただ確率が上がるごとにそのアプリは終わりに近づくけどね
    - それが0.004%だったとしてもアルゴリズムをデザインするプラットフォームとしては疑わしい
* 「アクターが機能しているか知ることができるので、メールボックスがからじゃない時と機能しているときは停止しないで！」
    - そうはいうけどこういう時↓は停止したくないでしょ？
        + もしアクターが未来の作業を生成していたら？
        + 別のマシンの要求を待っていたら？
    - 逆にアプリを動作実態とは逆に"ビジー"に保つ単純な何かがいるとしたら永遠にアプリを実行し続ける？
        + ふつうやらないよね

## The DABOWoTeD Pattern（Do A Bunch Of Work Then Die pattern）

* 「房ごとに死んでいくパータン」
    - ☆DABOWoTeDの発音になんか意味があるらしいけど分からなかった
* 24/365で動いてるアプリはシャットダウン時の動きをそんなに気にしてないんじゃない
    - ハードウェア障害に対応するほうが頻繁だと思うし
* 仕事をさせるために幾つかのアクターを房にする
    - その仕事が「完了」している時がシャットダウンするとき

### Futures

* Futures はすべてが完了したのを知る簡単な方法
    - シーケンシャルに処理できる
* 基本的に大きなfork-joinをやってるだけ
    - すべてがjoin upした時にそのシステムをシャットダウンする

### Acotr

* “Finished”が明確じゃない
    - アルゴリズムにアクターが高いレベルで入り込んでいるから

### The Reaper

* 死神
    - アクターの死を監視するアクター
    - 監視しているアクター（図では緑）がすべて死んだ時システムを終了させる
    - 死んだアクターの通知をすべて集めた時、死神がシステムを終了に向かわせる


### Reaper Code

* Reaper自体は簡単、ActorRefを監視してそれらが死んだ時にキックするメソッドを作るだけ

### A “Production” Reaper

* 死神の簡単さから考えて、Production Reaperを作ることができる
    - すべての魂を集め終わったらActorSystemをシャットダウンするような

### Testing the Reaper

* Akka の テストキットを使ってReaperをテストする



## Application with PoisonPill

* Reaper はとても柔軟
    - あるゴールがメールボックスから排出される場合
* メッセージの束をアクターに送り、他のアクターにもメッセージが送られるシステムが有るとする
    - メールボックスからあるキーが排出された時にシャットダウンしたい
        + そういう時は PoisonPill メッセージを利用する
        + PoisonPill はActorのメールボックスに入り、やがてActorを殺す
            * 重要なのはPoisonPillより前に受け取ったメッセージはすべて処理されるということ
            * system.stpoを使ってActorを殺した場合にはそうならない
    - 最後のPoisonPillが処理されるとReaperがキックされActorSystemがシャットダウンされる
* ☆PoisonPillを受け取ったら自殺するようにActorを作ればいいのか

## Conclusion

* Akkaはあなたが何をやってるか知らない
    - しってるのはあなた自身だけ
* Reaperパターンはシステムに抽象レベルを設定するために使用された
    - Actorの基本的な機能を使用してアプリケーションに「システムレベル」の振る舞いを追加するための



Akka

AkkaのActorをテストする（Java編）

Shutdown Patterns in Akka 2 を読んでのメモ